CSVLoader implements Closure, Discardable, FileLoader, FileWriterFactory, Loader
FinalYes
Interfaces
- Closure
- Discardable
- FileLoader
- FileWriterFactory
- Loader
Methods
- __construct() : mixed
- closure() : void
- commit() : FileCommit|null
- describe() : Description|null
- destination() : Path
- discard() : void
- fromDescription() : static
- inTask() : static
- load() : void
- partitionBy() : static
- partitioning() : Partitioning
- saveMode() : static
- withDateFormat() : self
- withDateTimeFormat() : self
- withEnclosure() : self
- withEscape() : self
- withHeader() : self
- withNewLineSeparator() : self
- withSeparator() : self
- writer() : FileWriter
Methods
__construct()
public
__construct(Path $path[, Filesystem $filesystem = new NativeLocalFilesystem() ][, FlowPhpExtension|null $extension = null ]) : mixed
Parameters
- $path : Path
- $filesystem : Filesystem = new NativeLocalFilesystem()
- $extension : FlowPhpExtension|null = null
closure()
public
closure() : void
commit()
public
commit(string $run, int $tasks) : FileCommit|null
Parameters
- $run : string
- $tasks : int
Return values
FileCommit|nulldescribe()
public
describe() : Description|null
Return values
Description|nulldestination()
public
destination() : Path
Return values
Pathdiscard()
public
discard() : void
fromDescription()
public
static fromDescription(array<string|int, mixed> $data, Rebuild $rebuild) : static
Parameters
- $data : array<string|int, mixed>
- $rebuild : Rebuild
Return values
staticinTask()
public
inTask(Part $task) : static
Parameters
- $task : Part
Return values
staticload()
public
load(Rows $rows, Backend $backend) : void
Parameters
- $rows : Rows
- $backend : Backend
partitionBy()
public
partitionBy(Partitioning $partitioning) : static
Parameters
- $partitioning : Partitioning
Return values
staticpartitioning()
public
partitioning() : Partitioning
Return values
PartitioningsaveMode()
public
saveMode(SaveMode $mode) : static
Parameters
- $mode : SaveMode
Return values
staticwithDateFormat()
public
withDateFormat(string $dateFormat) : self
Parameters
- $dateFormat : string
Return values
selfwithDateTimeFormat()
public
withDateTimeFormat(string $dateTimeFormat) : self
Parameters
- $dateTimeFormat : string
Return values
selfwithEnclosure()
public
withEnclosure(string $enclosure) : self
Parameters
- $enclosure : string
Return values
selfwithEscape()
public
withEscape(string $escape) : self
Parameters
- $escape : string
Return values
selfwithHeader()
public
withHeader(bool $header) : self
Parameters
- $header : bool
Return values
selfwithNewLineSeparator()
public
withNewLineSeparator(string $newLineSeparator) : self
Parameters
- $newLineSeparator : string
Return values
selfwithSeparator()
public
withSeparator(string $separator) : self
Parameters
- $separator : string
Return values
selfwriter()
public
writer(DestinationStream $stream, Schema $schema, Backend $backend) : FileWriter
Parameters
- $stream : DestinationStream
- $schema : Schema
- $backend : Backend