package streaming
Type Members
- trait ContinuousPartitionReader[T] extends PartitionReader[T]
- trait ContinuousPartitionReaderFactory extends PartitionReaderFactory
- trait ContinuousStream extends SparkDataStream
- trait MicroBatchStream extends SparkDataStream
- abstract class Offset extends AnyRef
- trait PartitionOffset extends Serializable
- trait SparkDataStream extends AnyRef