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

Transforms for reading and writing from streaming CDAP plugins.

See: Description

Interface Summary

Interface	Description
HasOffset	Interface for any Spark Receiver that supports reading from and to some offset.

Class Summary

Class	Description
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.

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

Transforms for reading and writing from streaming CDAP plugins.