Flow PHP

ArrowParquetEngine implements ParquetEngine

FinalYes

Interfaces

ParquetEngine

Methods

__construct() : mixed
mapCompression() : string
openForWrite() : ParquetFileWriter
readValues() : Generator<int, array<string|int, mixed>>
writeRows() : void

__construct()


    public
                    __construct([Options $options = new Options() ]) : mixed

Parameters

$options : Options = new Options()

mapCompression()


    public
            static        mapCompression(Compressions $compression) : string

Parameters

$compression : Compressions

Return values

string

openForWrite()


    public
                    openForWrite(DestinationStream $stream, Schema $schema, Compressions $compression, Options $options) : ParquetFileWriter

Parameters

$stream : DestinationStream
$schema : Schema
$compression : Compressions
$options : Options

Return values

ParquetFileWriter

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, mixed> $rows) : void

Parameters

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