org.apache.beam.runners.spark.util

Classes

• ByteArray
• CachedSideInputReader
• GlobalWatermarkHolder
• GlobalWatermarkHolder.SparkWatermarks
• GlobalWatermarkHolder.WatermarkAdvancingStreamingListener
• SideInputBroadcast
• SparkCompat
• SparkSideInputReader
• TimerUtils