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

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.beam.sdk.extensions.avro.io.AvroDatumFactory<T> (implements org.apache.beam.sdk.extensions.avro.io.AvroSink.DatumWriterFactory<T>, org.apache.beam.sdk.extensions.avro.io.AvroSource.DatumReaderFactory<T>)
    • org.apache.beam.sdk.extensions.avro.io.AvroDatumFactory.GenericDatumFactory
    • org.apache.beam.sdk.extensions.avro.io.AvroDatumFactory.ReflectDatumFactory<T>
    • org.apache.beam.sdk.extensions.avro.io.AvroDatumFactory.SpecificDatumFactory<T>
  • org.apache.beam.sdk.extensions.avro.io.AvroIO
  • org.apache.beam.sdk.extensions.avro.io.AvroIO.Sink<ElementT> (implements org.apache.beam.sdk.io.FileIO.Sink<ElementT>)
  • org.apache.beam.sdk.extensions.avro.io.AvroSchemaIOProvider (implements org.apache.beam.sdk.schemas.io.SchemaIOProvider)
  • org.apache.beam.sdk.io.FileBasedSink<UserT,DestinationT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
    • org.apache.beam.sdk.extensions.avro.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.extensions.avro.io.DynamicAvroDestinations<UserT,DestinationT,OutputT>
  • org.apache.beam.sdk.transforms.PTransform<InputT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
    • org.apache.beam.sdk.extensions.avro.io.AvroIO.Parse<T>
    • org.apache.beam.sdk.extensions.avro.io.AvroIO.ParseAll<T>
    • org.apache.beam.sdk.extensions.avro.io.AvroIO.ParseFiles<T>
    • org.apache.beam.sdk.extensions.avro.io.AvroIO.Read<T>
    • org.apache.beam.sdk.extensions.avro.io.AvroIO.ReadAll<T>
    • org.apache.beam.sdk.extensions.avro.io.AvroIO.ReadFiles<T>
    • org.apache.beam.sdk.extensions.avro.io.AvroIO.TypedWrite<UserT,DestinationT,OutputT>
    • org.apache.beam.sdk.extensions.avro.io.AvroIO.Write<T>
  • 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.extensions.avro.io.AvroSource<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.extensions.avro.io.AvroSource.AvroReader<T>

Interface Hierarchy

• java.io.Serializable
  • org.apache.beam.sdk.extensions.avro.io.AvroIO.RecordFormatter<ElementT>
  • org.apache.beam.sdk.extensions.avro.io.AvroSink.DatumWriterFactory<T>
  • org.apache.beam.sdk.extensions.avro.io.AvroSource.DatumReaderFactory<T>