Skip to content

Commit 0d75f65

Browse files
committed
Added parquet schema conversion to DSL
1 parent 8f7d720 commit 0d75f65

2 files changed

Lines changed: 13 additions & 1 deletion

File tree

src/adapter/etl-adapter-parquet/src/Flow/ETL/Adapter/Parquet/functions.php

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -93,3 +93,15 @@ function empty_generator() : \Generator
9393
{
9494
yield from [];
9595
}
96+
97+
#[DocumentationDSL(module: Module::PARQUET, type: DSLType::HELPER)]
98+
function schema_to_parquet(Schema $schema) : \Flow\Parquet\ParquetFile\Schema
99+
{
100+
return (new SchemaConverter())->toParquet($schema);
101+
}
102+
103+
#[DocumentationDSL(module: Module::PARQUET, type: DSLType::HELPER)]
104+
function schema_from_parquet(\Flow\Parquet\ParquetFile\Schema $schema) : Schema
105+
{
106+
return (new SchemaConverter())->toFlow($schema);
107+
}

web/landing/resources/dsl.json

Lines changed: 1 addition & 1 deletion
Large diffs are not rendered by default.

0 commit comments

Comments
 (0)