Options¶

advanceMillisPerBatch¶

default: 1000

Must be non-negative

numPartitions¶

default: SparkContext.defaultParallelism

Must be non-zero and positive

rowsPerBatch¶

default: 0

Must be non-zero and positive

startTimestamp¶

default: 0

Must be non-negative