PhpParquetEngine implements ParquetEngine
FinalYes
Interfaces
Methods
- __construct() : mixed
- closeWrite() : void
- openForWrite() : void
- readValues() : Generator<int, array<string, mixed>>
- writeBatch() : void
- writeRow() : void
- writeRows() : void
Methods
__construct()
public
__construct([ByteOrder $byteOrder = ByteOrder::LITTLE_ENDIAN ][, Options $options = new Options() ]) : mixed
Parameters
- $byteOrder : ByteOrder = ByteOrder::LITTLE_ENDIAN
- $options : Options = new Options()
closeWrite()
public
closeWrite() : void
openForWrite()
public
openForWrite(DestinationStream $stream, Schema $schema, Compressions $compression, Options $options) : void
Parameters
- $stream : DestinationStream
- $schema : Schema
- $compression : Compressions
- $options : Options
readValues()
public
readValues(SourceStream $stream, Schema $schema[, array<string|int, mixed> $columns = [] ][, int|null $limit = null ][, int|null $offset = null ]) : Generator<int, array<string, mixed>>
Parameters
- $stream : SourceStream
- $schema : Schema
- $columns : array<string|int, mixed> = []
- $limit : int|null = null
- $offset : int|null = null
Return values
Generator<int, array<string, mixed>>writeBatch()
public
writeBatch(iterable<string|int, mixed> $rows) : void
Parameters
- $rows : iterable<string|int, mixed>
writeRow()
public
writeRow(array<string|int, mixed> $row) : void
Parameters
- $row : array<string|int, mixed>
writeRows()
public
writeRows(DestinationStream $stream, Schema $schema, Compressions $compression, Options $options, iterable<string|int, mixed> $rows) : void
Parameters
- $stream : DestinationStream
- $schema : Schema
- $compression : Compressions
- $options : Options
- $rows : iterable<string|int, mixed>