ParquetExtractor implements BatchableExtractor, Extractor, FileExtractor, LimitPushDown, MetadataColumnsExtractor, RewindableExtractor uses Batches, PushesLimit, FileReading
FinalYes
Interfaces
- BatchableExtractor
- Extractor
- FileExtractor
- LimitPushDown
- MetadataColumnsExtractor
- RewindableExtractor
Methods
- __construct() : mixed
- extract() : Generator<Signal|null, void>
- isRepeatable() : bool
- schema() : Schema
- source() : Path
- unionByName() : self
- Reconcile every listed file's schema instead of trusting the first one.
- withByteOrder() : self
- withColumns() : self
- withEngine() : self
- withOffset() : self
- withOptions() : self
- withSchema() : static
Methods
__construct()
public
__construct(Path $path[, Filesystem $filesystem = new NativeLocalFilesystem() ]) : mixed
Parameters
- $path : Path
- $filesystem : Filesystem = new NativeLocalFilesystem()
extract()
public
extract(FlowContext $context) : Generator<Signal|null, void>
Parameters
- $context : FlowContext
Return values
Generator<Signal|null, void>isRepeatable()
public
isRepeatable() : bool
Return values
boolschema()
public
schema() : Schema
Return values
Schemasource()
public
source() : Path
Return values
PathunionByName()
Reconcile every listed file's schema instead of trusting the first one.
public
unionByName([bool $union = true ]) : self
Parameters
- $union : bool = true
Return values
selfwithByteOrder()
public
withByteOrder(ByteOrder $byteOrder) : self
Parameters
- $byteOrder : ByteOrder
Return values
selfwithColumns()
public
withColumns(array<string|int, string> $columns) : self
Parameters
- $columns : array<string|int, string>
Return values
selfwithEngine()
public
withEngine(ParquetEngine|null $engine) : self
Parameters
- $engine : ParquetEngine|null
Return values
selfwithOffset()
public
withOffset(int $offset) : self
Parameters
- $offset : int
Return values
selfwithOptions()
public
withOptions(Options $options) : self
Parameters
- $options : Options
Return values
selfwithSchema()
public
withSchema(Schema $schema) : static
Parameters
- $schema : Schema