AdaptiveParquetEngine implements ParquetEngine
Read onlyYes
FinalYes
Tags
Interfaces
Methods
- __construct() : mixed
- fromArray() : static
- normalize() : EngineConfiguration
- openForRead() : ParquetFileReader
- The file on $stream, its footer read by the returned reader, which owns the stream from here on.
- openForWrite() : ParquetFileWriter
- writeRows() : void
Methods
__construct()
public
__construct([ByteOrder $byteOrder = ByteOrder::LITTLE_ENDIAN ][, Options $options = new Options() ][, ArrowExtension|null $extension = null ]) : mixed
Parameters
- $byteOrder : ByteOrder = ByteOrder::LITTLE_ENDIAN
- $options : Options = new Options()
- $extension : ArrowExtension|null = null
fromArray()
public
static fromArray(array<string|int, mixed> $configuration) : static
Parameters
- $configuration : array<string|int, mixed>
-
untrusted: decoded from another process, validated here
Return values
staticnormalize()
public
normalize() : EngineConfiguration
Return values
EngineConfigurationopenForRead()
The file on $stream, its footer read by the returned reader, which owns the stream from here on.
public
openForRead(SourceStream $stream) : ParquetFileReader
Parameters
- $stream : SourceStream
Return values
ParquetFileReaderopenForWrite()
public
openForWrite(DestinationStream $stream, Schema $schema, Compressions $compression, Options $options) : ParquetFileWriter
Parameters
- $stream : DestinationStream
- $schema : Schema
- $compression : Compressions
- $options : Options
Return values
ParquetFileWriterwriteRows()
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>