Flow PHP

ParquetEngine

Methods

closeWrite() : void
openForWrite() : void
readValues() : Generator<int, array<string, mixed>>
writeBatch() : void
writeRow() : void
writeRows() : void

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, string> $columns = [] ][, int|null $limit = null ][, int|null $offset = null ]) : Generator<int, array<string, 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, mixed>>

writeBatch()


    public
                    writeBatch(iterable<string|int, array<string, mixed>> $rows) : void

Parameters

$rows : iterable<string|int, array<string, mixed>>

writeRow()


    public
                    writeRow(array<string, mixed> $row) : void

Parameters

$row : array<string, mixed>

writeRows()


    public
                    writeRows(DestinationStream $stream, Schema $schema, Compressions $compression, Options $options, iterable<string|int, array<string, mixed>> $rows) : void

Parameters

$stream : DestinationStream
$schema : Schema
$compression : Compressions
$options : Options
$rows : iterable<string|int, array<string, mixed>>