Flow PHP

ParquetEngine

Methods

fromArray()  : ParquetEngine
normalize()  : null|array<string, mixed>
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

fromArray()

public static fromArray(array<string|int, mixed> $configuration) : ParquetEngine
Parameters
$configuration : array<string|int, mixed>

untrusted: decoded from another process, validated here

Tags
throws
InvalidArgumentException

on a configuration this class cannot rebuild from

Return values
ParquetEngine

normalize()

public normalize() : null|array<string, mixed>
Return values
null|array<string, mixed> —

null when this instance holds live state and cannot be rebuilt

openForRead()

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
ParquetFileReader

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>>
On this page

Search results