Simple example of reading from rows and writing to stdout.
Extracts
Read from various data sources.
Transforms
Shape and optimize for your needs.
Loads
Store and secure in one of many available data sinks.
Examples:
Description
Code
<?php
declare(strict_types=1);
use function Flow\ETL\DSL\{array_entry, array_expand, data_frame, from_rows, int_entry, ref, row, rows, to_stream};
data_frame()
->read(
from_rows(
rows(
row(int_entry('id', 1), array_entry('array', ['a' => 1, 'b' => 2, 'c' => 3])),
)
)
)
->withEntry('expanded', array_expand(ref('array')))
->write(to_stream(__DIR__ . '/output.txt', truncate: false))
->run();
Output
+----+---------------------+----------+
| id | array | expanded |
+----+---------------------+----------+
| 1 | {"a":1,"b":2,"c":3} | 1 |
| 1 | {"a":1,"b":2,"c":3} | 2 |
| 1 | {"a":1,"b":2,"c":3} | 3 |
+----+---------------------+----------+
3 rows
Contributors
Join us on GitHub
