Package org.apache.beam.runners.spark.io
package org.apache.beam.runners.spark.io
Spark-specific transforms for I/O.
-
ClassesClassDescriptionPrint to console.Write to console.
PTransform
writingPCollection
to the console.CreateStream<T>Create an input stream from Queue.Passing null values to Spark's Java API may cause problems because of Guava preconditions.MicrobatchSource<T,CheckpointMarkT extends UnboundedSource.CheckpointMark> ASource
that accommodates Spark's micro-batch oriented nature and wraps anUnboundedSource
.Classes implementing BeamSource
RDD
s.SourceRDD.Unbounded<T,CheckpointMarkT extends UnboundedSource.CheckpointMark> ASourceRDD.Unbounded
is the implementation of a micro-batch in aSourceDStream
.A "composite" InputDStream implementation forUnboundedSource
s.A metadata holder for an input stream partition.