ParquetFileWriterFactory implements FileWriterFactory
FinalYes
Interfaces
- FileWriterFactory
Methods
- __construct() : mixed
- writer() : FileWriter
- The writer of one stream under the run's Parquet schema, which the first call fixes: the declared one, or $schema made nullable.
Methods
__construct()
public
__construct(null|Schema $declared, SchemaConverter $converter, Compressions $compressions, Options $options, ParquetEngine|null $engine[, FlowPhpExtension|null $extension = null ]) : mixed
Parameters
- $declared : null|Schema
-
the schema every file is written under, partition columns removed; null to take the first opened stream's schema, made nullable
- $converter : SchemaConverter
- $compressions : Compressions
- $options : Options
- $engine : ParquetEngine|null
- $extension : FlowPhpExtension|null = null
writer()
The writer of one stream under the run's Parquet schema, which the first call fixes: the declared one, or $schema made nullable.
public
writer(DestinationStream $stream, Schema $schema, Backend $backend) : FileWriter
Parameters
- $stream : DestinationStream
- $schema : Schema
- $backend : Backend