Choose specific columns from your data, discarding the rest. Transformations like select help keep pipelines readable and explicit about which data is being processed.
Examples
Columns
Description
Documentation
Column operations rewrite the schema, and the rows follow it.
Code
<?php
declare(strict_types=1);
use function Flow\ETL\DSL\{data_frame, from_array, select, to_output};
require __DIR__ . '/vendor/autoload.php';
data_frame()
->read(
from_array([
['id' => 1, 'first_name' => 'John', 'last_name' => 'Doe'],
['id' => 2, 'first_name' => 'Jane', 'last_name' => 'Smith'],
['id' => 3, 'first_name' => 'Bob', 'last_name' => 'Johnson'],
['id' => 4, 'first_name' => 'Alice', 'last_name' => 'Williams'],
])
)
->with(select('id'))
->collect()
->write(to_output(truncate: false))
->run();