DSL References
DSL stands for Domain Specific Language. In Flow, the DSL is a set of small functions that wrap object construction so pipelines read top-to-bottom. See the examples for usage in context.
EXTRACTOR
/**
* @param Path|string $path
* @param array<string> $columns - list of columns to read from parquet file - @deprecated use `withColumns` method instead
* @param Options $options - @deprecated use `withOptions` method instead
* @param ByteOrder $byte_order - @deprecated use `withByteOrder` method instead
* @param null|int $offset - @deprecated use `withOffset` method instead
*/
from_parquet(Path|string $path, array $columns, Options $options, ByteOrder $byte_order, ?int $offset) : ParquetExtractor HELPER
/**
* @template T
*
* @param array<T> $data
*
* @return \Generator<T>
*/
array_to_generator(array $data) : Generator empty_generator() : Generator schema_from_parquet(Schema $schema) : Schema schema_to_parquet(Schema $schema) : Schema LOADER
/**
* @param Path|string $path
* @param null|Options $options - @deprecated use `withOptions` method instead
* @param Compressions $compressions - @deprecated use `withCompressions` method instead
* @param null|Schema $schema - @deprecated use `withSchema` method instead
*/
to_parquet(Path|string $path, ?Options $options, Compressions $compressions, ?Schema $schema) : ParquetLoader