Flow PHP

Writer

FinalYes

Methods

__construct() : mixed
__destruct() : mixed
arrow() : self
close() : void
isOpen() : bool
open() : void
openForStream() : void
php() : self
write() : void
writeBatch() : void
writeRow() : void
writeStream() : void

__construct()


    public
                    __construct([Compressions $compression = Compressions::SNAPPY ][, Options $options = new Options() ][, ParquetEngine $engine = new AdaptiveParquetEngine() ]) : mixed

Parameters

$compression : Compressions = Compressions::SNAPPY
$options : Options = new Options()
$engine : ParquetEngine = new AdaptiveParquetEngine()

__destruct()


    public
                    __destruct() : mixed

arrow()


    public
            static        arrow([Compressions $compression = Compressions::SNAPPY ][, Options $options = new Options() ]) : self

Parameters

$compression : Compressions = Compressions::SNAPPY
$options : Options = new Options()

Return values

self

close()


    public
                    close() : void

isOpen()


    public
                    isOpen() : bool

Return values

bool

open()


    public
                    open(string $path, Schema $schema) : void

Parameters

$path : string
$schema : Schema

openForStream()


    public
                    openForStream(DestinationStream $stream, Schema $schema) : void

Parameters

$stream : DestinationStream
$schema : Schema

php()


    public
            static        php([Compressions $compression = Compressions::SNAPPY ][, Options $options = new Options() ]) : self

Parameters

$compression : Compressions = Compressions::SNAPPY
$options : Options = new Options()

Return values

self

write()


    public
                    write(string $path, Schema $schema, iterable<string|int, array<string, mixed>> $rows) : void

Parameters

$path : string
$schema : Schema
$rows : iterable<string|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>

writeStream()


    public
                    writeStream(DestinationStream $stream, Schema $schema, iterable<string|int, array<string, mixed>> $rows) : void

Parameters

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