FloeLoader implements Closure, Discardable, FileLoader, Loader, PartitioningLoader
FinalYes
Interfaces
- Closure
- Loaders implementing this adapter will be additionally notified by the pipeline about the last set of Rows processed by the pipeline.
- Discardable
- Loaders implementing this adapter will be notified by the pipeline when a run ends without reaching its last set of Rows - it threw, or the caller walked away from the generator - and when their own closure() threw.
- FileLoader
- Loader
- PartitioningLoader
Methods
- __construct() : mixed
- closure() : void
- destination() : Path
- discard() : void
- load() : void
- partitionBy() : static
- saveMode() : static
- withSchema() : static
Methods
__construct()
public
__construct(Path $path[, Metadata|null $metadata = null ][, Options $options = new Options() ][, FloeEngine $engine = FloeEngine::adaptive ][, Filesystem $filesystem = new NativeLocalFilesystem() ]) : mixed
Parameters
- $path : Path
- $metadata : Metadata|null = null
- $options : Options = new Options()
- $engine : FloeEngine = FloeEngine::adaptive
- $filesystem : Filesystem = new NativeLocalFilesystem()
closure()
public
closure(FlowContext $context) : void
Parameters
- $context : FlowContext
destination()
public
destination() : Path
Return values
Pathdiscard()
public
discard(FlowContext $context) : void
Parameters
- $context : FlowContext
load()
public
load(Rows $rows, FlowContext $context) : void
Parameters
- $rows : Rows
- $context : FlowContext
partitionBy()
public
partitionBy(Partitioning $partitioning) : static
Parameters
- $partitioning : Partitioning
Return values
staticsaveMode()
public
saveMode(SaveMode $mode) : static
Parameters
- $mode : SaveMode
Return values
staticwithSchema()
public
withSchema(Schema $schema) : static
Parameters
- $schema : Schema