$uids */
+ $uids = array_column($tasks, 'uid');
+
+ $client->waitForTask(max($uids));
+ }
+}
diff --git a/src/adapter/etl-adapter-seal/tests/Flow/ETL/Adapter/Seal/Tests/Backend/MemoryBackend.php b/src/adapter/etl-adapter-seal/tests/Flow/ETL/Adapter/Seal/Tests/Backend/MemoryBackend.php
new file mode 100644
index 0000000000..22cff09177
--- /dev/null
+++ b/src/adapter/etl-adapter-seal/tests/Flow/ETL/Adapter/Seal/Tests/Backend/MemoryBackend.php
@@ -0,0 +1,20 @@
+schema());
+ }
+}
diff --git a/src/adapter/etl-adapter-seal/tests/Flow/ETL/Adapter/Seal/Tests/Integration/Elasticsearch/SealExtractorTest.php b/src/adapter/etl-adapter-seal/tests/Flow/ETL/Adapter/Seal/Tests/Integration/Elasticsearch/SealExtractorTest.php
new file mode 100644
index 0000000000..16a7f9d66e
--- /dev/null
+++ b/src/adapter/etl-adapter-seal/tests/Flow/ETL/Adapter/Seal/Tests/Integration/Elasticsearch/SealExtractorTest.php
@@ -0,0 +1,13 @@
+engine, self::INDEX_NAME);
+
+ static::assertSame($extractor, $extractor->withPageSize(100));
+ }
+
+ public function test_with_search_builder_returns_the_same_extractor_instance(): void
+ {
+ $extractor = from_seal($this->engine, self::INDEX_NAME);
+
+ static::assertSame($extractor, $extractor->withSearchBuilder(static function (SearchBuilder $builder): void {}));
+ }
+}
diff --git a/src/adapter/etl-adapter-seal/tests/Flow/ETL/Adapter/Seal/Tests/Unit/SealLoaderTest.php b/src/adapter/etl-adapter-seal/tests/Flow/ETL/Adapter/Seal/Tests/Unit/SealLoaderTest.php
new file mode 100644
index 0000000000..b76d30c36f
--- /dev/null
+++ b/src/adapter/etl-adapter-seal/tests/Flow/ETL/Adapter/Seal/Tests/Unit/SealLoaderTest.php
@@ -0,0 +1,31 @@
+engine, self::INDEX_NAME)->load(rows(), flow_context());
+
+ static::assertSame(0, $this->engine->countDocuments(self::INDEX_NAME));
+ }
+
+ public function test_with_bulk_size_returns_the_same_loader_instance(): void
+ {
+ $loader = to_seal($this->engine, self::INDEX_NAME);
+
+ static::assertSame($loader, $loader->withBulkSize(50));
+ }
+}
diff --git a/src/bridge/symfony/http-foundation/src/Flow/Bridge/Symfony/HttpFoundation/DataStream.php b/src/bridge/symfony/http-foundation/src/Flow/Bridge/Symfony/HttpFoundation/DataStream.php
index ad0b6b69b9..70a7f0ff76 100644
--- a/src/bridge/symfony/http-foundation/src/Flow/Bridge/Symfony/HttpFoundation/DataStream.php
+++ b/src/bridge/symfony/http-foundation/src/Flow/Bridge/Symfony/HttpFoundation/DataStream.php
@@ -105,7 +105,7 @@ public function onComplete(StreamClosure $streamClosure): self
/**
* Create regular response where whole dataset is loaded into the memory.
* It's highly recommended to use limit transformation to avoid loading entire dataset into the memory.
- * Some extractors like Parquet/Elasticsearch/Doctrine allows also for setting offset directly on the extractor.
+ * Some extractors like Parquet/Doctrine allows also for setting offset directly on the extractor.
*/
public function response(Output $output): FlowBufferedResponse
{
diff --git a/src/core/etl/src/Flow/ETL/Attribute/Module.php b/src/core/etl/src/Flow/ETL/Attribute/Module.php
index a0e1d0b074..4e50e6fd53 100644
--- a/src/core/etl/src/Flow/ETL/Attribute/Module.php
+++ b/src/core/etl/src/Flow/ETL/Attribute/Module.php
@@ -31,6 +31,7 @@ enum Module: string
case PSR3_TELEMETRY_BRIDGE = 'PSR3_TELEMETRY_BRIDGE';
case PSR7_TELEMETRY_BRIDGE = 'PSR7_TELEMETRY_BRIDGE';
case S3_FILESYSTEM = 'S3_FILESYSTEM';
+ case SEAL = 'SEAL';
case SYMFONY_HTTP_FOUNDATION_TELEMETRY_BRIDGE = 'SYMFONY_HTTP_FOUNDATION_TELEMETRY_BRIDGE';
case SYMFONY_TELEMETRY_BUNDLE = 'SYMFONY_TELEMETRY_BUNDLE';
case TELEMETRY = 'TELEMETRY';
diff --git a/src/core/etl/src/Flow/ETL/Pipeline/Optimizer/BatchSizeOptimization.php b/src/core/etl/src/Flow/ETL/Pipeline/Optimizer/BatchSizeOptimization.php
index 2b9086a311..158591c0d5 100644
--- a/src/core/etl/src/Flow/ETL/Pipeline/Optimizer/BatchSizeOptimization.php
+++ b/src/core/etl/src/Flow/ETL/Pipeline/Optimizer/BatchSizeOptimization.php
@@ -43,7 +43,6 @@ final class BatchSizeOptimization implements Optimization
*/
private array $supportedLoaders = [
'Flow\ETL\Adapter\Doctrine\DbalLoader',
- 'Flow\ETL\Adapter\Elasticsearch\ElasticsearchPHP\ElasticsearchLoader',
'Flow\ETL\Adapter\PostgreSql\PostgreSqlLoader',
];
diff --git a/tools/box/composer.lock b/tools/box/composer.lock
index a0727b6056..4ecd976182 100644
--- a/tools/box/composer.lock
+++ b/tools/box/composer.lock
@@ -532,16 +532,16 @@
},
{
"name": "amphp/process",
- "version": "v2.0.3",
+ "version": "v2.1.0",
"source": {
"type": "git",
"url": "https://github.com/amphp/process.git",
- "reference": "52e08c09dec7511d5fbc1fb00d3e4e79fc77d58d"
+ "reference": "583959df17d00304ad7b0b32285373f985935643"
},
"dist": {
"type": "zip",
- "url": "https://api.github.com/repos/amphp/process/zipball/52e08c09dec7511d5fbc1fb00d3e4e79fc77d58d",
- "reference": "52e08c09dec7511d5fbc1fb00d3e4e79fc77d58d",
+ "url": "https://api.github.com/repos/amphp/process/zipball/583959df17d00304ad7b0b32285373f985935643",
+ "reference": "583959df17d00304ad7b0b32285373f985935643",
"shasum": ""
},
"require": {
@@ -555,7 +555,7 @@
"amphp/php-cs-fixer-config": "^2",
"amphp/phpunit-util": "^3",
"phpunit/phpunit": "^9",
- "psalm/phar": "^5.4"
+ "psalm/phar": "6.16.1"
},
"type": "library",
"autoload": {
@@ -588,7 +588,7 @@
"homepage": "https://amphp.org/process",
"support": {
"issues": "https://github.com/amphp/process/issues",
- "source": "https://github.com/amphp/process/tree/v2.0.3"
+ "source": "https://github.com/amphp/process/tree/v2.1.0"
},
"funding": [
{
@@ -596,7 +596,7 @@
"type": "github"
}
],
- "time": "2024-04-19T03:13:44+00:00"
+ "time": "2026-05-31T15:11:55+00:00"
},
{
"name": "amphp/serialization",
diff --git a/tools/infection/composer.lock b/tools/infection/composer.lock
index b74e254bd0..77bde4901d 100644
--- a/tools/infection/composer.lock
+++ b/tools/infection/composer.lock
@@ -1108,16 +1108,16 @@
},
{
"name": "sanmai/di-container",
- "version": "0.1.12",
+ "version": "0.1.16",
"source": {
"type": "git",
"url": "https://github.com/sanmai/di-container.git",
- "reference": "8b9ad72f6ac1f9e185e5bd060dc9479cb5191d8b"
+ "reference": "8b8a8859e992297259b220a92179439f9d185838"
},
"dist": {
"type": "zip",
- "url": "https://api.github.com/repos/sanmai/di-container/zipball/8b9ad72f6ac1f9e185e5bd060dc9479cb5191d8b",
- "reference": "8b9ad72f6ac1f9e185e5bd060dc9479cb5191d8b",
+ "url": "https://api.github.com/repos/sanmai/di-container/zipball/8b8a8859e992297259b220a92179439f9d185838",
+ "reference": "8b8a8859e992297259b220a92179439f9d185838",
"shasum": ""
},
"require": {
@@ -1175,7 +1175,7 @@
],
"support": {
"issues": "https://github.com/sanmai/di-container/issues",
- "source": "https://github.com/sanmai/di-container/tree/0.1.12"
+ "source": "https://github.com/sanmai/di-container/tree/0.1.16"
},
"funding": [
{
@@ -1183,7 +1183,7 @@
"type": "github"
}
],
- "time": "2026-01-27T08:25:46+00:00"
+ "time": "2026-05-30T11:27:18+00:00"
},
{
"name": "sanmai/duoclock",
diff --git a/web/landing/assets/codemirror/completions/dsl.js b/web/landing/assets/codemirror/completions/dsl.js
index 60f230488f..70d0a213f4 100644
--- a/web/landing/assets/codemirror/completions/dsl.js
+++ b/web/landing/assets/codemirror/completions/dsl.js
@@ -1,7 +1,7 @@
/**
* CodeMirror Completer for Flow PHP DSL Functions
*
- * Total functions: 761
+ * Total functions: 769
*
* This completer provides autocompletion for all Flow PHP DSL functions:
* - Extractors (flow-extractors)
@@ -1372,15 +1372,15 @@ const dslFunctions = [
const div = document.createElement("div")
div.innerHTML = `
- client_catalog_provider(Client $client, array $schemaNames = null, array $excludeTables = []) : CatalogProvider
+ client_catalog_provider(Client $client, array $schemaNames = null, ExclusionPolicy $exclusionPolicy = null) : CatalogProvider
- @param ?list $schemaNames
@param list $excludeTables
+ @param ?list $schemaNames
`
return div
},
- apply: snippet("\\Flow\\PostgreSql\\DSL\\client_catalog_provider(" + "$" + "{" + "1:client" + "}" + ", " + "$" + "{" + "2:schemaNames" + "}" + ", " + "$" + "{" + "3:excludeTables" + "}" + ")"),
+ apply: snippet("\\Flow\\PostgreSql\\DSL\\client_catalog_provider(" + "$" + "{" + "1:client" + "}" + ", " + "$" + "{" + "2:schemaNames" + "}" + ", " + "$" + "{" + "3:exclusionPolicy" + "}" + ")"),
boost: 10
}, {
label: "clock",
@@ -2072,6 +2072,24 @@ const dslFunctions = [
},
apply: snippet("\\Flow\\PostgreSql\\DSL\\column_type_varchar(" + "$" + "{" + "1:length" + "}" + ")"),
boost: 10
+ }, {
+ label: "column_type_xml",
+ type: "function",
+ detail: "flow\u002Ddsl\u002Dhelpers",
+ info: () => {
+ const div = document.createElement("div")
+ div.innerHTML = `
+
+ column_type_xml() : ColumnType
+
+
+ Create an XML data type.
+
+ `
+ return div
+ },
+ apply: snippet("\\Flow\\PostgreSql\\DSL\\column_type_xml()"),
+ boost: 10
}, {
label: "combine",
type: "function",
@@ -3446,21 +3464,6 @@ const dslFunctions = [
},
apply: snippet("\\Flow\\ETL\\DSL\\entry(" + "$" + "{" + "1:entry" + "}" + ")"),
boost: 10
- }, {
- label: "entry_id_factory",
- type: "function",
- detail: "flow\u002Ddsl\u002Dhelpers",
- info: () => {
- const div = document.createElement("div")
- div.innerHTML = `
-
- entry_id_factory(string $entry_name) : IdFactory
-
- `
- return div
- },
- apply: snippet("\\Flow\\ETL\\Adapter\\Elasticsearch\\entry_id_factory(" + "$" + "{" + "1:entry_name" + "}" + ")"),
- boost: 10
}, {
label: "enum_entry",
type: "function",
@@ -3567,40 +3570,127 @@ const dslFunctions = [
apply: snippet("\\Flow\\Telemetry\\DSL\\error_log_handler(" + "$" + "{" + "1:messageType" + "}" + ", " + "$" + "{" + "2:expandNewlines" + "}" + ", " + "$" + "{" + "3:messagePrefix" + "}" + ")"),
boost: 10
}, {
- label: "es_hits_to_rows",
+ label: "exception_if_exists",
type: "function",
- detail: "flow\u002Ddsl\u002Dhelpers",
+ detail: "flow\u002Ddsl\u002Ddata\u002Dframe",
info: () => {
const div = document.createElement("div")
div.innerHTML = `
- es_hits_to_rows(DocumentDataSource $source = Flow\\ETL\\Adapter\\Elasticsearch\\ElasticsearchPHP\\DocumentDataSource::...) : HitsIntoRowsTransformer
+ exception_if_exists() : SaveMode
- Transforms elasticsearch results into clear Flow Rows using [\'hits\'][\'hits\'][x][\'_source\'].
@return HitsIntoRowsTransformer
+ Alias for save_mode_exception_if_exists().
`
return div
},
- apply: snippet("\\Flow\\ETL\\Adapter\\Elasticsearch\\es_hits_to_rows(" + "$" + "{" + "1:source" + "}" + ")"),
+ apply: snippet("\\Flow\\ETL\\DSL\\exception_if_exists()"),
boost: 10
}, {
- label: "exception_if_exists",
+ label: "exclude_any",
type: "function",
- detail: "flow\u002Ddsl\u002Ddata\u002Dframe",
+ detail: "flow\u002Ddsl\u002Dhelpers",
info: () => {
const div = document.createElement("div")
div.innerHTML = `
- exception_if_exists() : SaveMode
+ exclude_any(ExclusionPolicy $policies) : ExclusionPolicy
-
- Alias for save_mode_exception_if_exists().
+ `
+ return div
+ },
+ apply: snippet("\\Flow\\PostgreSql\\DSL\\exclude_any(" + "$" + "{" + "1:policies" + "}" + ")"),
+ boost: 10
+ }, {
+ label: "exclude_ends_with",
+ type: "function",
+ detail: "flow\u002Ddsl\u002Dhelpers",
+ info: () => {
+ const div = document.createElement("div")
+ div.innerHTML = `
+
+ exclude_ends_with(string $suffix) : ExclusionPolicy
`
return div
},
- apply: snippet("\\Flow\\ETL\\DSL\\exception_if_exists()"),
+ apply: snippet("\\Flow\\PostgreSql\\DSL\\exclude_ends_with(" + "$" + "{" + "1:suffix" + "}" + ")"),
+ boost: 10
+ }, {
+ label: "exclude_exact",
+ type: "function",
+ detail: "flow\u002Ddsl\u002Dhelpers",
+ info: () => {
+ const div = document.createElement("div")
+ div.innerHTML = `
+
+ exclude_exact(string $name) : ExclusionPolicy
+
+ `
+ return div
+ },
+ apply: snippet("\\Flow\\PostgreSql\\DSL\\exclude_exact(" + "$" + "{" + "1:name" + "}" + ")"),
+ boost: 10
+ }, {
+ label: "exclude_pattern",
+ type: "function",
+ detail: "flow\u002Ddsl\u002Dhelpers",
+ info: () => {
+ const div = document.createElement("div")
+ div.innerHTML = `
+
+ exclude_pattern(string $pattern) : ExclusionPolicy
+
+ `
+ return div
+ },
+ apply: snippet("\\Flow\\PostgreSql\\DSL\\exclude_pattern(" + "$" + "{" + "1:pattern" + "}" + ")"),
+ boost: 10
+ }, {
+ label: "exclude_schema",
+ type: "function",
+ detail: "flow\u002Ddsl\u002Dhelpers",
+ info: () => {
+ const div = document.createElement("div")
+ div.innerHTML = `
+
+ exclude_schema(string $schema) : ExclusionPolicy
+
+ `
+ return div
+ },
+ apply: snippet("\\Flow\\PostgreSql\\DSL\\exclude_schema(" + "$" + "{" + "1:schema" + "}" + ")"),
+ boost: 10
+ }, {
+ label: "exclude_scoped",
+ type: "function",
+ detail: "flow\u002Ddsl\u002Dhelpers",
+ info: () => {
+ const div = document.createElement("div")
+ div.innerHTML = `
+
+ exclude_scoped(ExclusionPolicy $policy, SchemaObjectType $type = null, string $schema = null) : ExclusionPolicy
+
+ `
+ return div
+ },
+ apply: snippet("\\Flow\\PostgreSql\\DSL\\exclude_scoped(" + "$" + "{" + "1:policy" + "}" + ", " + "$" + "{" + "2:type" + "}" + ", " + "$" + "{" + "3:schema" + "}" + ")"),
+ boost: 10
+ }, {
+ label: "exclude_starts_with",
+ type: "function",
+ detail: "flow\u002Ddsl\u002Dhelpers",
+ info: () => {
+ const div = document.createElement("div")
+ div.innerHTML = `
+
+ exclude_starts_with(string $prefix) : ExclusionPolicy
+
+ `
+ return div
+ },
+ apply: snippet("\\Flow\\PostgreSql\\DSL\\exclude_starts_with(" + "$" + "{" + "1:prefix" + "}" + ")"),
boost: 10
}, {
label: "execution_context",
@@ -4120,7 +4210,7 @@ const dslFunctions = [
const div = document.createElement("div")
div.innerHTML = `
- from_csv(Path|string $path, bool $with_header = true, bool $empty_to_null = true, string $separator = null, string $enclosure = null, string $escape = null, int $characters_read_in_line = 1000, Schema $schema = null) : CSVExtractor
+ from_csv(Path|string $path, bool $with_header = true, bool $empty_to_null = true, string $separator = null, string $enclosure = null, string $escape = null, int $characters_read_in_line = 10485760, Schema $schema = null) : CSVExtractor
@param Path|string $path
@param bool $empty_to_null - @deprecated use $loader->withEmptyToNull() instead
@param bool $with_header - @deprecated use $loader->withHeader() instead
@param null|string $separator - @deprecated use $loader->withSeparator() instead
@param null|string $enclosure - @deprecated use $loader->withEnclosure() instead
@param null|string $escape - @deprecated use $loader->withEscape() instead
@param int<1, max> $characters_read_in_line - @deprecated use $loader->withCharactersReadInLine() instead
@param null|Schema $schema - @deprecated use $loader->withSchema() instead
@@ -4247,24 +4337,6 @@ const dslFunctions = [
},
apply: snippet("\\Flow\\ETL\\Adapter\\Http\\from_dynamic_http_requests(" + "$" + "{" + "1:client" + "}" + ", " + "$" + "{" + "2:requestFactory" + "}" + ")"),
boost: 10
- }, {
- label: "from_es",
- type: "function",
- detail: "flow\u002Ddsl\u002Dextractors",
- info: () => {
- const div = document.createElement("div")
- div.innerHTML = `
-
- from_es(array $config, array $parameters, array $pit_params = null) : ElasticsearchExtractor
-
-
- Extractor will automatically try to iterate over whole index using one of the two iteration methods:.
- from/size
- search_after
Search after is selected when you provide define sort parameters in query, otherwise it will fallback to from/size.
@param array{
hosts?: array,
connectionParams?: array,
retries?: int,
sniffOnStart?: bool,
sslCert?: array,
sslKey?: array,
sslVerification?: bool|string,
elasticMetaHeader?: bool,
includePortInHostHeader?: bool
} $config
@param array $parameters - https://www.elastic.co/guide/en/elasticsearch/reference/master/search-search.html
@param ?array $pit_params - when used extractor will create point in time to stabilize search results. Point in time is automatically closed when last element is extracted. https://www.elastic.co/guide/en/elasticsearch/reference/master/point-in-time-api.html - @deprecated use withPointInTime method instead
-
- `
- return div
- },
- apply: snippet("\\Flow\\ETL\\Adapter\\Elasticsearch\\from_es(" + "$" + "{" + "1:config" + "}" + ", " + "$" + "{" + "2:parameters" + "}" + ", " + "$" + "{" + "3:pit_params" + "}" + ")"),
- boost: 10
}, {
label: "from_excel",
type: "function",
@@ -4430,6 +4502,21 @@ const dslFunctions = [
},
apply: snippet("\\Flow\\ETL\\DSL\\from_rows(" + "$" + "{" + "1:rows" + "}" + ")"),
boost: 10
+ }, {
+ label: "from_seal",
+ type: "function",
+ detail: "flow\u002Ddsl\u002Dextractors",
+ info: () => {
+ const div = document.createElement("div")
+ div.innerHTML = `
+
+ from_seal(EngineInterface $engine, string $index) : SealExtractor
+
+ `
+ return div
+ },
+ apply: snippet("\\Flow\\ETL\\Adapter\\Seal\\from_seal(" + "$" + "{" + "1:engine" + "}" + ", " + "$" + "{" + "2:index" + "}" + ")"),
+ boost: 10
}, {
label: "from_sequence_date_period",
type: "function",
@@ -4751,21 +4838,6 @@ const dslFunctions = [
},
apply: snippet("\\Flow\\ETL\\DSL\\hash(" + "$" + "{" + "1:value" + "}" + ", " + "$" + "{" + "2:algorithm" + "}" + ")"),
boost: 10
- }, {
- label: "hash_id_factory",
- type: "function",
- detail: "flow\u002Ddsl\u002Dhelpers",
- info: () => {
- const div = document.createElement("div")
- div.innerHTML = `
-
- hash_id_factory(string $entry_names) : IdFactory
-
- `
- return div
- },
- apply: snippet("\\Flow\\ETL\\Adapter\\Elasticsearch\\hash_id_factory(" + "$" + "{" + "1:entry_names" + "}" + ")"),
- boost: 10
}, {
label: "host_detector",
type: "function",
@@ -8990,6 +9062,66 @@ const dslFunctions = [
},
apply: snippet("\\Flow\\PostgreSql\\DSL\\schema_view(" + "$" + "{" + "1:name" + "}" + ", " + "$" + "{" + "2:definition" + "}" + ", " + "$" + "{" + "3:isUpdatable" + "}" + ")"),
boost: 10
+ }, {
+ label: "seal_create_index",
+ type: "function",
+ detail: "flow\u002Ddsl\u002Dhelpers",
+ info: () => {
+ const div = document.createElement("div")
+ div.innerHTML = `
+
+ seal_create_index(EngineInterface $engine, string $index) : void
+
+ `
+ return div
+ },
+ apply: snippet("\\Flow\\ETL\\Adapter\\Seal\\seal_create_index(" + "$" + "{" + "1:engine" + "}" + ", " + "$" + "{" + "2:index" + "}" + ")"),
+ boost: 10
+ }, {
+ label: "seal_create_schema",
+ type: "function",
+ detail: "flow\u002Ddsl\u002Dhelpers",
+ info: () => {
+ const div = document.createElement("div")
+ div.innerHTML = `
+
+ seal_create_schema(EngineInterface $engine) : void
+
+ `
+ return div
+ },
+ apply: snippet("\\Flow\\ETL\\Adapter\\Seal\\seal_create_schema(" + "$" + "{" + "1:engine" + "}" + ")"),
+ boost: 10
+ }, {
+ label: "seal_drop_index",
+ type: "function",
+ detail: "flow\u002Ddsl\u002Dhelpers",
+ info: () => {
+ const div = document.createElement("div")
+ div.innerHTML = `
+
+ seal_drop_index(EngineInterface $engine, string $index) : void
+
+ `
+ return div
+ },
+ apply: snippet("\\Flow\\ETL\\Adapter\\Seal\\seal_drop_index(" + "$" + "{" + "1:engine" + "}" + ", " + "$" + "{" + "2:index" + "}" + ")"),
+ boost: 10
+ }, {
+ label: "seal_drop_schema",
+ type: "function",
+ detail: "flow\u002Ddsl\u002Dhelpers",
+ info: () => {
+ const div = document.createElement("div")
+ div.innerHTML = `
+
+ seal_drop_schema(EngineInterface $engine) : void
+
+ `
+ return div
+ },
+ apply: snippet("\\Flow\\ETL\\Adapter\\Seal\\seal_drop_schema(" + "$" + "{" + "1:engine" + "}" + ")"),
+ boost: 10
}, {
label: "select",
type: "function",
@@ -9874,7 +10006,7 @@ const dslFunctions = [
structure_entry(string $name, array $value, Type $type, Metadata $metadata = null) : Entry
- @param ?array
$value
@param Type $type
@return ($value is null ? Entry : Entry>)
+ @template TShape of array
@param ?TShape $value
@param StructureType|Type $type
@return ($value is null ? Entry : Entry)
`
return div
@@ -9925,7 +10057,7 @@ const dslFunctions = [
struct_entry(string $name, array $value, Type $type, Metadata $metadata = null) : Entry
- @param ?array
$value
@param Type $type
@return ($value is null ? Entry : Entry>)
+ @template TShape of array
@param ?TShape $value
@param StructureType|Type $type
@return ($value is null ? Entry : Entry)
- to_es_bulk_index(array $config, string $index, IdFactory $id_factory, array $parameters = []) : ElasticsearchLoader
-
-
- https://www.elastic.co/guide/en/elasticsearch/reference/master/docs-bulk.html.
In order to control the size of the single request, use DataFrame::chunkSize() method just before calling DataFrame::load().
@param array{
hosts?: array,
connectionParams?: array,
retries?: int,
sniffOnStart?: bool,
sslCert?: array,
sslKey?: array,
sslVerification?: bool|string,
elasticMetaHeader?: bool,
includePortInHostHeader?: bool
} $config
@param string $index
@param IdFactory $id_factory
@param array $parameters - https://www.elastic.co/guide/en/elasticsearch/reference/master/docs-bulk.html - @deprecated use withParameters method instead
-
- `
- return div
- },
- apply: snippet("\\Flow\\ETL\\Adapter\\Elasticsearch\\to_es_bulk_index(" + "$" + "{" + "1:config" + "}" + ", " + "$" + "{" + "2:index" + "}" + ", " + "$" + "{" + "3:id_factory" + "}" + ", " + "$" + "{" + "4:parameters" + "}" + ")"),
- boost: 10
- }, {
- label: "to_es_bulk_update",
- type: "function",
- detail: "flow\u002Ddsl\u002Dloaders",
- info: () => {
- const div = document.createElement("div")
- div.innerHTML = `
-
- to_es_bulk_update(array $config, string $index, IdFactory $id_factory, array $parameters = []) : ElasticsearchLoader
-
-
- https://www.elastic.co/guide/en/elasticsearch/reference/master/docs-bulk.html.
In order to control the size of the single request, use DataFrame::chunkSize() method just before calling DataFrame::load().
@param array{
hosts?: array,
connectionParams?: array,
retries?: int,
sniffOnStart?: bool,
sslCert?: array,
sslKey?: array,
sslVerification?: bool|string,
elasticMetaHeader?: bool,
includePortInHostHeader?: bool
} $config
@param string $index
@param IdFactory $id_factory
@param array $parameters - https://www.elastic.co/guide/en/elasticsearch/reference/master/docs-bulk.html - @deprecated use withParameters method instead
-
- `
- return div
- },
- apply: snippet("\\Flow\\ETL\\Adapter\\Elasticsearch\\to_es_bulk_update(" + "$" + "{" + "1:config" + "}" + ", " + "$" + "{" + "2:index" + "}" + ", " + "$" + "{" + "3:id_factory" + "}" + ", " + "$" + "{" + "4:parameters" + "}" + ")"),
- boost: 10
}, {
label: "to_excel",
type: "function",
@@ -10643,6 +10739,21 @@ const dslFunctions = [
},
apply: snippet("\\Flow\\ETL\\Adapter\\Parquet\\to_parquet(" + "$" + "{" + "1:path" + "}" + ", " + "$" + "{" + "2:options" + "}" + ", " + "$" + "{" + "3:compressions" + "}" + ", " + "$" + "{" + "4:schema" + "}" + ")"),
boost: 10
+ }, {
+ label: "to_seal",
+ type: "function",
+ detail: "flow\u002Ddsl\u002Dloaders",
+ info: () => {
+ const div = document.createElement("div")
+ div.innerHTML = `
+
+ to_seal(EngineInterface $engine, string $index) : SealLoader
+
+ `
+ return div
+ },
+ apply: snippet("\\Flow\\ETL\\Adapter\\Seal\\to_seal(" + "$" + "{" + "1:engine" + "}" + ", " + "$" + "{" + "2:index" + "}" + ")"),
+ boost: 10
}, {
label: "to_stderr",
type: "function",
@@ -11539,7 +11650,7 @@ const dslFunctions = [
type_structure(array $elements = [], array $optional_elements = [], bool $allow_extra = false) : Type
- @param array
> $elements
@param array> $optional_elements
@return Type>
+ @template T
@param array> $elements
@param array> $optional_elements
@return StructureType
Strongly typed. Memory efficient. One DataFrame API for CSV, JSON, XML, Parquet,
- Avro, REST, RDBMS, Elasticsearch, and more.
+ Avro, REST, RDBMS, SEAL, and more.
diff --git a/web/landing/templates/main/changelog.html.twig b/web/landing/templates/main/changelog.html.twig
index bdc6c650c1..6b98730f38 100644
--- a/web/landing/templates/main/changelog.html.twig
+++ b/web/landing/templates/main/changelog.html.twig
@@ -6,7 +6,7 @@
{%- block description -%}
Flow is a PHP-based, strongly typed data processing framework with low memory footprint that can process various data sources consistently.
- It offers a unified API for all data sources, including CSV, JSON, XML, Text, Parquet, Avro, Rest API, RDBMS, Elasticsearch / Meilisearch.
+ It offers a unified API for all data sources, including CSV, JSON, XML, Text, Parquet, Avro, Rest API, RDBMS, SEAL.
Flow not only enables you to process various data sources consistently, but also strives to accurately detect data types and cast them to the appropriate PHP types.
{%- endblock -%}
diff --git a/web/landing/templates/main/index.html.twig b/web/landing/templates/main/index.html.twig
index 91c9118195..7951e3b9a9 100644
--- a/web/landing/templates/main/index.html.twig
+++ b/web/landing/templates/main/index.html.twig
@@ -6,7 +6,7 @@
{%- block description -%}
Flow is a PHP-based, strongly typed data processing framework with low memory footprint that can process various data sources consistently.
- It offers a unified API for all data sources, including CSV, JSON, XML, Text, Parquet, Avro, Rest API, RDBMS, Elasticsearch / Meilisearch.
+ It offers a unified API for all data sources, including CSV, JSON, XML, Text, Parquet, Avro, Rest API, RDBMS, SEAL.
Flow not only enables you to process various data sources consistently, but also strives to accurately detect data types and cast them to the appropriate PHP types.
{%- endblock -%}
@@ -153,7 +153,7 @@ data_frame()
Unified, typed API
- One DataFrame for CSV, JSON, XML, Parquet, Avro, REST, RDBMS, Elasticsearch and Meilisearch.
+ One DataFrame for CSV, JSON, XML, Parquet, Avro, REST, RDBMS, SEAL.
Schemas inferred or declared — your call.
diff --git a/web/landing/tests/Flow/Website/Tests/Unit/Service/Manifest/PackageMetaTest.php b/web/landing/tests/Flow/Website/Tests/Unit/Service/Manifest/PackageMetaTest.php
index 1a6b2d302b..e3f1c0e3c4 100644
--- a/web/landing/tests/Flow/Website/Tests/Unit/Service/Manifest/PackageMetaTest.php
+++ b/web/landing/tests/Flow/Website/Tests/Unit/Service/Manifest/PackageMetaTest.php
@@ -62,7 +62,6 @@ public function test_for_dsl_module_returns_null_for_unknown_module(): void
#[TestWith(['flow-php/etl-adapter-xml', 'adapter', 'Adapter', 'XML'])]
#[TestWith(['flow-php/etl-adapter-http', 'adapter', 'Adapter', 'HTTP'])]
#[TestWith(['flow-php/etl-adapter-google-sheet', 'adapter', 'Adapter', 'Google Sheet'])]
- #[TestWith(['flow-php/etl-adapter-elasticsearch', 'adapter', 'Adapter', 'Elasticsearch'])]
#[TestWith(['flow-php/parquet', 'lib', 'Library', 'Parquet'])]
#[TestWith(['flow-php/postgresql', 'lib', 'Library', 'PostgreSQL'])]
#[TestWith(['flow-php/azure-sdk', 'lib', 'Library', 'Azure SDK'])]