Class Hierarchy
- java.lang.Object
- org.apache.beam.sdk.io.AvroIO
- org.apache.beam.sdk.io.AvroIO.Sink<ElementT> (implements org.apache.beam.sdk.io.FileIO.Sink<ElementT>)
- org.apache.beam.sdk.io.AvroSchemaIOProvider (implements org.apache.beam.sdk.schemas.io.SchemaIOProvider)
- org.apache.beam.sdk.io.BlockBasedSource.Block<T>
- org.apache.beam.sdk.io.ClassLoaderFileSystem.ClassLoaderFileSystemRegistrar (implements org.apache.beam.sdk.io.FileSystemRegistrar)
- org.apache.beam.sdk.io.ClassLoaderFileSystem.ClassLoaderResourceId (implements org.apache.beam.sdk.io.fs.ResourceId)
- org.apache.beam.sdk.coders.Coder<T> (implements java.io.Serializable)
- org.apache.beam.sdk.coders.StructuredCoder<T>
- org.apache.beam.sdk.coders.AtomicCoder<T>
- org.apache.beam.sdk.io.DefaultFilenamePolicy.ParamsCoder
- org.apache.beam.sdk.io.FileBasedSink.FileResultCoder<DestinationT>
- org.apache.beam.sdk.io.ReadableFileCoder
- org.apache.beam.sdk.coders.AtomicCoder<T>
- org.apache.beam.sdk.coders.StructuredCoder<T>
- org.apache.beam.sdk.io.CountingSource
- org.apache.beam.sdk.io.CountingSource.CounterMark (implements org.apache.beam.sdk.io.UnboundedSource.CheckpointMark)
- org.apache.beam.sdk.io.DefaultFilenamePolicy.Params (implements java.io.Serializable)
- org.apache.beam.sdk.io.DynamicFileDestinations
- org.apache.beam.sdk.io.FileBasedSink<UserT,DestinationT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
- org.apache.beam.sdk.io.AvroSink<UserT,DestinationT,OutputT>
- org.apache.beam.sdk.io.FileBasedSink.DynamicDestinations<UserT,DestinationT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
- org.apache.beam.sdk.io.DynamicAvroDestinations<UserT,DestinationT,OutputT>
- org.apache.beam.sdk.io.FileBasedSink.FilenamePolicy (implements java.io.Serializable)
- org.apache.beam.sdk.io.DefaultFilenamePolicy
- org.apache.beam.sdk.io.FileBasedSink.FileResult<DestinationT>
- org.apache.beam.sdk.io.FileBasedSink.WriteOperation<DestinationT,OutputT> (implements java.io.Serializable)
- org.apache.beam.sdk.io.FileBasedSink.Writer<DestinationT,OutputT>
- org.apache.beam.sdk.io.FileIO
- org.apache.beam.sdk.io.FileIO.MatchConfiguration (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
- org.apache.beam.sdk.io.FileIO.ReadableFile
- org.apache.beam.sdk.io.FileSystem<ResourceIdT>
- org.apache.beam.sdk.io.ClassLoaderFileSystem
- org.apache.beam.sdk.io.FileSystems
- org.apache.beam.sdk.io.FileSystemUtils
- org.apache.beam.sdk.io.GenerateSequence.External (implements org.apache.beam.sdk.expansion.ExternalTransformRegistrar)
- org.apache.beam.sdk.io.GenerateSequence.External.ExternalConfiguration
- org.apache.beam.sdk.io.LocalFileSystemRegistrar (implements org.apache.beam.sdk.io.FileSystemRegistrar)
- org.apache.beam.sdk.io.LocalResources
- org.apache.beam.sdk.transforms.PTransform<InputT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
- org.apache.beam.sdk.io.AvroIO.Parse<T>
- org.apache.beam.sdk.io.AvroIO.ParseAll<T>
- org.apache.beam.sdk.io.AvroIO.ParseFiles<T>
- org.apache.beam.sdk.io.AvroIO.Read<T>
- org.apache.beam.sdk.io.AvroIO.ReadAll<T>
- org.apache.beam.sdk.io.AvroIO.ReadFiles<T>
- org.apache.beam.sdk.io.AvroIO.TypedWrite<UserT,DestinationT,OutputT>
- org.apache.beam.sdk.io.AvroIO.Write<T>
- org.apache.beam.sdk.io.BoundedReadFromUnboundedSource<T>
- org.apache.beam.sdk.io.FileIO.Match
- org.apache.beam.sdk.io.FileIO.MatchAll
- org.apache.beam.sdk.io.FileIO.ReadMatches
- org.apache.beam.sdk.io.FileIO.Write<DestinationT,UserT>
- org.apache.beam.sdk.io.GenerateSequence
- org.apache.beam.sdk.io.Read.Bounded<T>
- org.apache.beam.sdk.io.Read.Unbounded<T>
- org.apache.beam.sdk.io.ReadAllViaFileBasedSource<T>
- org.apache.beam.sdk.io.TextIO.Read
- org.apache.beam.sdk.io.TextIO.ReadAll
- org.apache.beam.sdk.io.TextIO.ReadFiles
- org.apache.beam.sdk.io.TextIO.TypedWrite<UserT,DestinationT>
- org.apache.beam.sdk.io.TextIO.Write
- org.apache.beam.sdk.io.TFRecordIO.Read
- org.apache.beam.sdk.io.TFRecordIO.ReadFiles
- org.apache.beam.sdk.io.TFRecordIO.Write
- org.apache.beam.sdk.io.WriteFiles<UserT,DestinationT,OutputT>
- org.apache.beam.sdk.io.Read
- org.apache.beam.sdk.io.Read.Builder
- org.apache.beam.sdk.io.ReadAllViaFileBasedSource.ReadFileRangesFnExceptionHandler (implements java.io.Serializable)
- org.apache.beam.sdk.io.ShardNameTemplate
- org.apache.beam.sdk.io.Source<T> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
- org.apache.beam.sdk.io.BoundedSource<T>
- org.apache.beam.sdk.io.OffsetBasedSource<T>
- org.apache.beam.sdk.io.FileBasedSource<T>
- org.apache.beam.sdk.io.BlockBasedSource<T>
- org.apache.beam.sdk.io.AvroSource<T>
- org.apache.beam.sdk.io.CompressedSource<T>
- org.apache.beam.sdk.io.BlockBasedSource<T>
- org.apache.beam.sdk.io.FileBasedSource<T>
- org.apache.beam.sdk.io.OffsetBasedSource<T>
- org.apache.beam.sdk.io.UnboundedSource<OutputT,CheckpointMarkT>
- org.apache.beam.sdk.io.BoundedSource<T>
- org.apache.beam.sdk.io.Source.Reader<T> (implements java.lang.AutoCloseable)
- org.apache.beam.sdk.io.BoundedSource.BoundedReader<T>
- org.apache.beam.sdk.io.OffsetBasedSource.OffsetBasedReader<T>
- org.apache.beam.sdk.io.FileBasedSource.FileBasedReader<T>
- org.apache.beam.sdk.io.BlockBasedSource.BlockBasedReader<T>
- org.apache.beam.sdk.io.AvroSource.AvroReader<T>
- org.apache.beam.sdk.io.CompressedSource.CompressedReader<T>
- org.apache.beam.sdk.io.BlockBasedSource.BlockBasedReader<T>
- org.apache.beam.sdk.io.FileBasedSource.FileBasedReader<T>
- org.apache.beam.sdk.io.OffsetBasedSource.OffsetBasedReader<T>
- org.apache.beam.sdk.io.UnboundedSource.UnboundedReader<OutputT>
- org.apache.beam.sdk.io.BoundedSource.BoundedReader<T>
- org.apache.beam.sdk.io.TextIO
- org.apache.beam.sdk.io.TextIO.Sink (implements org.apache.beam.sdk.io.FileIO.Sink<ElementT>)
- org.apache.beam.sdk.io.TextRowCountEstimator
- org.apache.beam.sdk.io.TextRowCountEstimator.Builder
- org.apache.beam.sdk.io.TextRowCountEstimator.LimitNumberOfFiles (implements org.apache.beam.sdk.io.TextRowCountEstimator.SamplingStrategy)
- org.apache.beam.sdk.io.TextRowCountEstimator.LimitNumberOfTotalBytes (implements org.apache.beam.sdk.io.TextRowCountEstimator.SamplingStrategy)
- org.apache.beam.sdk.io.TextRowCountEstimator.SampleAllFiles (implements org.apache.beam.sdk.io.TextRowCountEstimator.SamplingStrategy)
- org.apache.beam.sdk.io.TFRecordIO
- org.apache.beam.sdk.io.TFRecordIO.Sink (implements org.apache.beam.sdk.io.FileIO.Sink<ElementT>)
- java.lang.Throwable (implements java.io.Serializable)
- java.lang.Exception
- org.apache.beam.sdk.io.TextRowCountEstimator.NoEstimationException
- java.lang.Exception
- org.apache.beam.sdk.io.UnboundedSource.CheckpointMark.NoopCheckpointMark (implements org.apache.beam.sdk.io.UnboundedSource.CheckpointMark)
- org.apache.beam.sdk.io.WriteFilesResult<DestinationT> (implements org.apache.beam.sdk.values.POutput)
Interface Hierarchy
- org.apache.beam.sdk.io.FileSystemRegistrar
- java.io.Serializable
- org.apache.beam.sdk.io.AvroIO.RecordFormatter<ElementT>
- org.apache.beam.sdk.io.AvroSink.DatumWriterFactory<T>
- org.apache.beam.sdk.io.AvroSource.DatumReaderFactory<T>
- org.apache.beam.sdk.io.CompressedSource.DecompressingChannelFactory
- org.apache.beam.sdk.io.FileBasedSink.OutputFileHints
- org.apache.beam.sdk.io.FileBasedSink.WritableByteChannelFactory
- org.apache.beam.sdk.io.FileIO.Sink<ElementT>
- org.apache.beam.sdk.io.FileIO.Write.FileNaming
- org.apache.beam.sdk.io.ShardingFunction<UserT,DestinationT>
- org.apache.beam.sdk.io.TextRowCountEstimator.SamplingStrategy
- org.apache.beam.sdk.io.UnboundedSource.CheckpointMark
Enum Hierarchy
- java.lang.Object
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
- org.apache.beam.sdk.io.CompressedSource.CompressionMode (implements org.apache.beam.sdk.io.CompressedSource.DecompressingChannelFactory)
- org.apache.beam.sdk.io.Compression
- org.apache.beam.sdk.io.FileBasedSink.CompressionType (implements org.apache.beam.sdk.io.FileBasedSink.WritableByteChannelFactory)
- org.apache.beam.sdk.io.FileBasedSource.Mode
- org.apache.beam.sdk.io.FileIO.ReadMatches.DirectoryTreatment
- org.apache.beam.sdk.io.TextIO.CompressionType
- org.apache.beam.sdk.io.TFRecordIO.CompressionType
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)