DataWritingSparkTask

DataWritingSparkTask is…​FIXME

run Method

run(
  writeTask: DataWriterFactory[InternalRow],
  context: TaskContext,
  iter: Iterator[InternalRow]): WriterCommitMessage

run…​FIXME

Note
run is used when…​FIXME

runContinuous Method

runContinuous(
  writeTask: DataWriterFactory[InternalRow],
  context: TaskContext,
  iter: Iterator[InternalRow]): WriterCommitMessage

runContinuous…​FIXME

Note
runContinuous is used when…​FIXME

results matching ""

    No results matching ""