ParquetSourceFile implements SelfDescribingFile
Read onlyYes
FinalYes
Interfaces
- SelfDescribingFile
Properties
- $file : ParquetFile<string|int, ParquetFileReader>
Methods
- __construct() : mixed
- close() : void
- forSource() : self|null
- This file when it is $source, else it closes itself and answers null.
- open() : ParquetOpenSource
- schema() : Schema
- Pruning belongs to the describer, not the fold: it is applied per file, before the merge. Only the projected columns are converted, so a column outside the projection never has to have a Flow type.
- source() : SourceFile
- statistics() : Statistics
- Uncompressed row-group bytes, as the format reports them.
- units() : array<string|int, mixed>
- One unit per row group: from its first page to the end of its compressed column chunks.
Properties
$file
public
ParquetFile<string|int, ParquetFileReader>
$file
Methods
__construct()
public
__construct(ParquetFile<string|int, ParquetFileReader> $file, SourceFile $source, SchemaConverter $converter, array<int, string> $columns[, FlowPhpExtension|null $extension = null ]) : mixed
Parameters
- $file : ParquetFile<string|int, ParquetFileReader>
- $source : SourceFile
- $converter : SchemaConverter
- $columns : array<int, string>
- $extension : FlowPhpExtension|null = null
close()
public
close() : void
forSource()
This file when it is $source, else it closes itself and answers null.
public
forSource(SourceFile $source) : self|null
Parameters
- $source : SourceFile
Return values
self|nullopen()
public
open() : ParquetOpenSource
Return values
ParquetOpenSourceschema()
Pruning belongs to the describer, not the fold: it is applied per file, before the merge. Only the projected columns are converted, so a column outside the projection never has to have a Flow type.
public
schema() : Schema
Return values
Schemasource()
public
source() : SourceFile
Return values
SourceFilestatistics()
Uncompressed row-group bytes, as the format reports them.
public
statistics() : Statistics
Return values
Statisticsunits()
One unit per row group: from its first page to the end of its compressed column chunks.
public
units() : array<string|int, mixed>