FileLoader extends Loader
Methods
- commit() : FileCommit|null
- The job commit of this write as $tasks tasks of run $run; null when the save mode does not admit the destination.
- describe() : null|Description
- destination() : Path
- fromDescription() : static
- inTask() : static
- A new loader, every setting copied, writing as task $task of a job that commits it; this instance is untouched.
- load() : void
- partitionBy() : static
- partitioning() : Partitioning
- What partitionBy() set; Partitioning::none() by default.
- saveMode() : static
Methods
commit()
The job commit of this write as $tasks tasks of run $run; null when the save mode does not admit the destination.
public
commit(non-empty-string $run, int<1, max> $tasks) : FileCommit|null
Parameters
- $run : non-empty-string
- $tasks : int<1, max>
Tags
Return values
FileCommit|nulldescribe()
public
describe() : null|Description
Return values
null|Description —null when this instance cannot cross a process boundary (a live client, a custom collaborator)
destination()
public
destination() : Path
Return values
PathfromDescription()
public
static fromDescription(array<string|int, mixed> $data, Rebuild $rebuild) : static
Parameters
- $data : array<string|int, mixed>
- $rebuild : Rebuild
Return values
staticinTask()
A new loader, every setting copied, writing as task $task of a job that commits it; this instance is untouched.
public
inTask(Part $task) : static
Parameters
- $task : Part
Return values
staticload()
public
load(Rows $rows, Backend $backend) : void
Parameters
partitionBy()
public
partitionBy(Partitioning $partitioning) : static
Parameters
- $partitioning : Partitioning
Return values
staticpartitioning()
What partitionBy() set; Partitioning::none() by default.
public
partitioning() : Partitioning
Return values
PartitioningsaveMode()
public
saveMode(SaveMode $mode) : static
Parameters
- $mode : SaveMode