Hierarchy For Package org.apache.beam.sdk.io

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • 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.CustomCoder<T> (implements java.io.Serializable)
      • org.apache.beam.sdk.io.CountingSource.CounterMarkCoder
    • 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.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.transforms.DoFn<InputT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
    • org.apache.beam.sdk.io.ReadAllViaFileBasedSourceTransform.AbstractReadFileRangesFn<InT,T>
    • org.apache.beam.sdk.io.ReadAllViaFileBasedSourceTransform.SplitIntoRangesFn
  • 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.FileBasedSink.DynamicDestinations<UserT,DestinationT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
  • 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.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.ReadAllViaFileBasedSourceTransform<InT,T>
      • org.apache.beam.sdk.io.ReadAllViaFileBasedSource<T>
      • org.apache.beam.sdk.io.ReadAllViaFileBasedSourceWithFilename<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.CompressedSource<T>
          • org.apache.beam.sdk.io.TextSource
    • org.apache.beam.sdk.io.UnboundedSource<OutputT,CheckpointMarkT>
  • 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.CompressedSource.CompressedReader<T>
    • org.apache.beam.sdk.io.UnboundedSource.UnboundedReader<OutputT>
  • 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
  • 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.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.FileBasedSource.Mode
    • org.apache.beam.sdk.io.FileSystem.LineageLevel
    • org.apache.beam.sdk.io.FileBasedSink.CompressionType (implements org.apache.beam.sdk.io.FileBasedSink.WritableByteChannelFactory)
    • org.apache.beam.sdk.io.TextIO.CompressionType
    • org.apache.beam.sdk.io.FileIO.ReadMatches.DirectoryTreatment
    • org.apache.beam.sdk.io.Compression
    • org.apache.beam.sdk.io.TFRecordIO.CompressionType