Skip to content
Search

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

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
Contributors

Built in the open.

Join us on GitHub
scroll back to top