Skip to content

Commit

Permalink
Fixed to_parquet example
Browse files Browse the repository at this point in the history
  • Loading branch information
norberttech committed Sep 14, 2024
1 parent f61cd06 commit cade0ac
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion examples/topics/data_sink/parquet/code.php
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
declare(strict_types=1);

use function Flow\ETL\Adapter\Parquet\to_parquet;
use function Flow\ETL\DSL\{data_frame, from_array};
use function Flow\ETL\DSL\{data_frame, from_array, overwrite};

require __DIR__ . '/../../../autoload.php';

Expand All @@ -16,5 +16,6 @@
['id' => 5],
]))
->collect()
->saveMode(overwrite())
->write(to_parquet(__DIR__ . '/output.parquet'))
->run();

0 comments on commit cade0ac

Please sign in to comment.