FloeExtractor implements Extractor, FileExtractor, LimitableExtractor uses Limitable, PathFiltering
FinalYes
Interfaces
- Extractor
- FileExtractor
- LimitableExtractor
- Limitable extractor is one that can be limited to extract only given number of rows.
Methods
- __construct() : mixed
- changeLimit() : void
- extract() : Generator<Signal|null, void>
- filter() : Filter
- incrementReturnedRows() : void
- isLimited() : bool
- limit() : int|null
- reachedLimit() : bool
- resetLimit() : void
- schema() : Schema
- Footer-only source schema (two ranged reads per file, no row scan).
- source() : Path
- withOffset() : self
- withPathFilter() : static
Methods
__construct()
public
__construct(Path $path[, Codec $codec = new NoopCodec() ][, int $chunkSize = 65536 ][, FloeEngine $engine = FloeEngine::adaptive ]) : mixed
Parameters
- $path : Path
- $codec : Codec = new NoopCodec()
- $chunkSize : int = 65536
- $engine : FloeEngine = FloeEngine::adaptive
changeLimit()
public
changeLimit(int $limit) : void
Parameters
- $limit : int
extract()
public
extract(FlowContext $context) : Generator<Signal|null, void>
Parameters
- $context : FlowContext
Return values
Generator<Signal|null, void>filter()
public
filter() : Filter
Return values
FilterincrementReturnedRows()
public
incrementReturnedRows() : void
isLimited()
public
isLimited() : bool
Return values
boollimit()
public
limit() : int|null
Return values
int|nullreachedLimit()
public
reachedLimit() : bool
Return values
boolresetLimit()
public
resetLimit() : void
schema()
Footer-only source schema (two ranged reads per file, no row scan).
public
schema(FlowContext $context) : Schema
Parameters
- $context : FlowContext
Return values
Schemasource()
public
source() : Path
Return values
PathwithOffset()
public
withOffset(int $offset) : self
Parameters
- $offset : int
Return values
selfwithPathFilter()
public
withPathFilter(Filter $filter) : static
Parameters
- $filter : Filter