Skip to content

Options

advanceMillisPerBatch

default: 1000

numPartitions

default: SparkSession.active.sparkContext.defaultParallelism

rowsPerBatch

default: 0

startTimestamp

default: 0