Hierarchy For Package org.apache.beam.runners.spark.structuredstreaming.io.streaming
Class Hierarchy
- java.lang.Object
- org.apache.beam.runners.spark.structuredstreaming.io.streaming.BeamReaderCache
- org.apache.beam.runners.spark.structuredstreaming.io.streaming.BeamReaderCache.CachedReader<T> (implements java.io.Closeable)
- org.apache.beam.runners.spark.structuredstreaming.io.streaming.BeamSourceCheckpoint
- org.apache.beam.runners.spark.structuredstreaming.io.streaming.UnboundedSourceDataset