/**
* @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 DSL References
DSL stands for Domain Specific Language. In the case of Flow, the DSL is used to define simple functions that can be used to transform data. Most of those functions are initializing a new instance of a class under the hood since Flow is fully object-oriented. Please look at the examples below to get a better understanding of how to use the DSL functions.
EXTRACTOR
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