Package org.apache.beam.sdk.io.sparkreceiver

package org.apache.beam.sdk.io.sparkreceiver
Transforms for reading and writing from streaming CDAP plugins.
  • Class
    Description
    HasOffset
    Interface for any Spark Receiver that supports reading from and to some offset.
    ReceiverBuilder<X,T extends org.apache.spark.streaming.receiver.Receiver<X>>
    Class for building an instance for Receiver that uses Apache Beam mechanisms instead of Spark environment.
    SparkReceiverIO
    Streaming sources for Spark Receiver.
    SparkReceiverIO.Read<V>
    A PTransform to read from Spark Receiver.
    WrappedSupervisor
    Wrapper class for ReceiverSupervisor that doesn't use Spark Environment.