DataWritingSparkTask is…FIXME
run Method
|
|
run( writeTask: DataWriterFactory[InternalRow], context: TaskContext, iter: Iterator[InternalRow]): WriterCommitMessage |
|
Note
|
run is used when…FIXME
|
runContinuous Method
|
|
runContinuous( writeTask: DataWriterFactory[InternalRow], context: TaskContext, iter: Iterator[InternalRow]): WriterCommitMessage |
|
Note
|
runContinuous is used when…FIXME
|
spark技术分享
