package streaming
Type Members
- trait AcceptsLatestSeenOffset extends SparkDataStream
-
final
class
CompositeReadLimit extends ReadLimit
- Annotations
- @Evolving()
-
trait
ContinuousPartitionReader[T] extends PartitionReader[T]
- Annotations
- @Evolving()
-
trait
ContinuousPartitionReaderFactory extends PartitionReaderFactory
- Annotations
- @Evolving()
-
trait
ContinuousStream extends SparkDataStream
- Annotations
- @Evolving()
-
trait
MicroBatchStream extends SparkDataStream
- Annotations
- @Evolving()
-
abstract
class
Offset extends AnyRef
- Annotations
- @Evolving()
-
trait
PartitionOffset extends Serializable
- Annotations
- @Evolving()
-
final
class
ReadAllAvailable extends ReadLimit
- Annotations
- @Evolving()
-
trait
ReadLimit extends AnyRef
- Annotations
- @Evolving()
-
class
ReadMaxFiles extends ReadLimit
- Annotations
- @Evolving()
-
final
class
ReadMaxRows extends ReadLimit
- Annotations
- @Evolving()
-
final
class
ReadMinRows extends ReadLimit
- Annotations
- @Evolving()
-
trait
ReportsSinkMetrics extends AnyRef
- Annotations
- @Evolving()
-
trait
ReportsSourceMetrics extends SparkDataStream
- Annotations
- @Evolving()
-
trait
SparkDataStream extends AnyRef
- Annotations
- @Evolving()
-
trait
SupportsAdmissionControl extends SparkDataStream
- Annotations
- @Evolving()
-
trait
SupportsTriggerAvailableNow extends SupportsAdmissionControl
- Annotations
- @Evolving()