Definition
data_frame(Config|ConfigBuilder|null $config) : Flow
Extracts
Read from various data sources.
Transforms
Shape and optimize for your needs.
Loads
Store and secure in one of many available data sinks.
DSL
Usage Examples
Example: Data frame - Data frame
<?php
declare(strict_types=1);
use function Flow\ETL\DSL\{
data_frame,
from_array,
to_stream};
data_frame()
->read(
from_array(
[
['id' => 1, 'array' => ['a' => 1, 'b' => 2, 'c' => 3]],
['id' => 2, 'array' => ['a' => 4, 'b' => 5, 'c' => 6]],
['id' => 3, 'array' => ['a' => 7, 'b' => 8, 'c' => 9]],
],
)
)
->collect()
->write(to_stream(__DIR__ . '/output.txt', truncate: false))
->run();
Example: Data frame - Overwrite
<?php
declare(strict_types=1);
use function Flow\ETL\Adapter\CSV\{from_csv, to_csv};
use function Flow\ETL\DSL\{data_frame, overwrite, to_stream};
require __DIR__ . '/../../../autoload.php';
data_frame()
->read(from_csv(__DIR__ . '/input/file.csv'))
->saveMode(overwrite())
->write(to_csv(__DIR__ . '/output/file.csv'))
->collect()
->write(to_stream(__DIR__ . '/output.txt', truncate: false))
->run();
data_frame()
->read(from_csv(__DIR__ . '/output/file.csv'))
->saveMode(overwrite())
->drop('name')
->write(to_csv(__DIR__ . '/output/file.csv'))
->collect()
->write(to_stream(__DIR__ . '/output.txt', truncate: false))
->run();
Examples
Contributors
Join us on GitHub
