org.apache.beam.runners.spark.util

Classes

• ByteArray
• GlobalWatermarkHolder
• GlobalWatermarkHolder.SparkWatermarks
• GlobalWatermarkHolder.WatermarksListener
• SideInputBroadcast
• SinglePrimitiveOutputPTransform
• SparkSideInputReader