Flow PHP

functions.php

Functions

from_parquet()

from_parquet(Path|string $path[, array<string|int, string> $columns = [] ][, Options $options = new Options() ][, ByteOrder $byte_order = ByteOrder::LITTLE_ENDIAN ][, null|int $offset = null ][, ParquetEngine|null $engine = null ][, Filesystem $filesystem = new NativeLocalFilesystem() ]) : ParquetExtractor
Parameters
$path : Path|string
$columns : array<string|int, string> = []
  • list of columns to read from parquet file - @deprecated use withColumns method instead
$options : Options = new Options()
  • @deprecated use withOptions method instead
$byte_order : ByteOrder = ByteOrder::LITTLE_ENDIAN
  • @deprecated use withByteOrder method instead
$offset : null|int = null
  • @deprecated use withOffset method instead
$engine : ParquetEngine|null = null
$filesystem : Filesystem = new NativeLocalFilesystem()
Return values
ParquetExtractor

to_parquet()

to_parquet(Path|string $path[, null|Options $options = null ][, Compressions $compressions = Compressions::SNAPPY ][, null|Schema $schema = null ][, ParquetEngine|null $engine = null ][, Filesystem $filesystem = new NativeLocalFilesystem() ]) : ParquetLoader
Parameters
$path : Path|string
$options : null|Options = null
  • @deprecated use withOptions method instead
$compressions : Compressions = Compressions::SNAPPY
  • @deprecated use withCompressions method instead
$schema : null|Schema = null
  • @deprecated use withSchema method instead
$engine : ParquetEngine|null = null
$filesystem : Filesystem = new NativeLocalFilesystem()
Return values
ParquetLoader

array_to_generator()

array_to_generator(array<string|int, T> $data) : Generator<string|int, T>
Parameters
$data : array<string|int, T>
Tags
template
Return values
Generator<string|int, T>

empty_generator()

use Flow\Parquet\empty_generator() instead

empty_generator() : Generator
Return values
Generator

schema_to_parquet()

schema_to_parquet(Schema $schema) : Schema
Parameters
$schema : Schema
Return values
Schema

schema_from_parquet()

schema_from_parquet(Schema $schema) : Schema
Parameters
$schema : Schema
Return values
Schema
On this page

Search results