Packages

package streaming

Type Members

  1. trait AcceptsLatestSeenOffset extends SparkDataStream
  2. final class CompositeReadLimit extends ReadLimit
    Annotations
    @Evolving()
  3. trait ContinuousPartitionReader[T] extends PartitionReader[T]
    Annotations
    @Evolving()
  4. trait ContinuousPartitionReaderFactory extends PartitionReaderFactory
    Annotations
    @Evolving()
  5. trait ContinuousStream extends SparkDataStream
    Annotations
    @Evolving()
  6. trait MicroBatchStream extends SparkDataStream
    Annotations
    @Evolving()
  7. abstract class Offset extends AnyRef
    Annotations
    @Evolving()
  8. trait PartitionOffset extends Serializable
    Annotations
    @Evolving()
  9. final class ReadAllAvailable extends ReadLimit
    Annotations
    @Evolving()
  10. trait ReadLimit extends AnyRef
    Annotations
    @Evolving()
  11. class ReadMaxFiles extends ReadLimit
    Annotations
    @Evolving()
  12. final class ReadMaxRows extends ReadLimit
    Annotations
    @Evolving()
  13. final class ReadMinRows extends ReadLimit
    Annotations
    @Evolving()
  14. trait ReportsSinkMetrics extends AnyRef
    Annotations
    @Evolving()
  15. trait ReportsSourceMetrics extends SparkDataStream
    Annotations
    @Evolving()
  16. trait SparkDataStream extends AnyRef
    Annotations
    @Evolving()
  17. trait SupportsAdmissionControl extends SparkDataStream
    Annotations
    @Evolving()
  18. trait SupportsTriggerAvailableNow extends SupportsAdmissionControl
    Annotations
    @Evolving()

Ungrouped