ParquetEngine
Methods
-
openForWrite()
: ParquetFileWriter
-
readValues()
: Generator<int, array<string|int, mixed>>
-
writeRows()
: void
openForWrite()
public
openForWrite(DestinationStream $stream, Schema $schema, Compressions $compression, Options $options) : ParquetFileWriter
Parameters
-
$stream
: DestinationStream
-
-
$schema
: Schema
-
-
$compression
: Compressions
-
-
$options
: Options
-
readValues()
public
readValues(SourceStream $stream, Schema $schema[, array<string|int, string> $columns = [] ][, int|null $limit = null ][, int|null $offset = null ]) : Generator<int, array<string|int, mixed>>
Parameters
-
$stream
: SourceStream
-
-
$schema
: Schema
-
-
$columns
: array<string|int, string>
= []
-
-
$limit
: int|null
= null
-
-
$offset
: int|null
= null
-
Return values
Generator<int, array<string|int, mixed>>
writeRows()
public
writeRows(DestinationStream $stream, Schema $schema, Compressions $compression, Options $options, iterable<string|int, array<string|int, mixed>> $rows) : void
Parameters
-
$stream
: DestinationStream
-
-
$schema
: Schema
-
-
$compression
: Compressions
-
-
$options
: Options
-
-
$rows
: iterable<string|int, array<string|int, mixed>>
-