Hierarchy For Package com.linkedin.venice.beam.consumer

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • com.linkedin.venice.beam.consumer.CheckPointProperties
  • 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>
        • com.linkedin.venice.beam.consumer.VeniceCheckpointMark.Coder
      • com.linkedin.venice.beam.consumer.PubSubMessageCoder<K,V>
      • com.linkedin.venice.beam.consumer.VeniceMessageCoder<K,V>
  • com.linkedin.venice.beam.consumer.LocalVeniceChangelogConsumerProvider<K,V> (implements com.linkedin.venice.beam.consumer.VeniceChangelogConsumerProvider<K,V>)
  • org.apache.beam.sdk.transforms.PTransform<InputT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
    • com.linkedin.venice.beam.consumer.VeniceChangelogConsumerIO.Read<K,V>
  • com.linkedin.venice.beam.consumer.VeniceChangelogConsumerIO
  • com.linkedin.venice.beam.consumer.VeniceCheckpointMark (implements org.apache.beam.sdk.io.UnboundedSource.CheckpointMark)

Interface Hierarchy

• java.io.Serializable
  • com.linkedin.venice.beam.consumer.VeniceChangelogConsumerProvider<K,V>

Enum Class Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
    • com.linkedin.venice.beam.consumer.VeniceChangelogConsumerIO.Read.SeekWhence (implements java.util.function.BiFunction<T,U,R>)