FloeLoader implements Closure, FileLoader, Loader
FinalYes
Interfaces
- Closure
- Loaders implementing this adapter will be additionally notified by the pipeline about the last set of Rows processed by the pipeline.
- FileLoader
- Loader
Methods
- __construct() : mixed
- closure() : void
- destination() : Path
- load() : void
- withSchema() : self
Methods
__construct()
public
__construct(Path $path[, Metadata|null $metadata = null ][, Options $options = new Options() ][, FloeEngine $engine = FloeEngine::adaptive ]) : mixed
Parameters
- $path : Path
- $metadata : Metadata|null = null
- $options : Options = new Options()
- $engine : FloeEngine = FloeEngine::adaptive
closure()
public
closure(FlowContext $context) : void
Parameters
- $context : FlowContext
destination()
public
destination() : Path
Return values
Pathload()
public
load(Rows $rows, FlowContext $context) : void
Parameters
- $rows : Rows
- $context : FlowContext
withSchema()
public
withSchema(Schema $schema) : self
Parameters
- $schema : Schema