public class DatasetSourceBatch
extends java.lang.Object
implements org.apache.spark.sql.sources.v2.DataSourceV2, org.apache.spark.sql.sources.v2.ReadSupport
DataSourceV2
implementation that wraps an BoundedSource
.As Continuous streaming is tagged experimental in spark (no aggregation support +
no exactly once guaranty), this class does no implement ContinuousReadSupport
.Constructor and Description |
---|
DatasetSourceBatch() |
Modifier and Type | Method and Description |
---|---|
org.apache.spark.sql.sources.v2.reader.DataSourceReader |
createReader(org.apache.spark.sql.sources.v2.DataSourceOptions options) |