org.apache.beam.runners.spark.io

Classes

• ConsoleIO
• ConsoleIO.Write
• ConsoleIO.Write.Unbound
• CreateStream
• EmptyCheckpointMark
• MicrobatchSource
• SourceRDD
• SourceRDD.Bounded
• SourceRDD.Unbounded
• SparkUnboundedSource
• SparkUnboundedSource.Metadata