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

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.beam.sdk.coders.Coder<T> (implements java.io.Serializable)
    • org.apache.beam.sdk.coders.StructuredCoder<T>
      • org.apache.beam.sdk.io.kafka.KafkaRecordCoder<K,V>
      • org.apache.beam.sdk.io.kafka.ProducerRecordCoder<K,V>
      • org.apache.beam.sdk.io.kafka.TopicPartitionCoder
  • org.apache.beam.sdk.io.kafka.ConfluentSchemaRegistryDeserializerProvider<T> (implements org.apache.beam.sdk.io.kafka.DeserializerProvider<T>)
  • org.apache.beam.sdk.io.kafka.KafkaCheckpointMark (implements org.apache.beam.sdk.io.UnboundedSource.CheckpointMark)
  • org.apache.beam.sdk.io.kafka.KafkaCheckpointMark.PartitionMark (implements java.io.Serializable)
  • org.apache.beam.sdk.io.kafka.KafkaIO
  • org.apache.beam.sdk.io.kafka.KafkaIO.Read.External (implements org.apache.beam.sdk.expansion.ExternalTransformRegistrar)
  • org.apache.beam.sdk.io.kafka.KafkaIO.Read.External.Configuration
  • org.apache.beam.sdk.io.kafka.KafkaIO.Write.External (implements org.apache.beam.sdk.expansion.ExternalTransformRegistrar)
  • org.apache.beam.sdk.io.kafka.KafkaIO.Write.External.Configuration
  • org.apache.beam.sdk.io.kafka.KafkaRecord<K,V>
  • org.apache.beam.sdk.io.kafka.KafkaSourceDescriptor (implements java.io.Serializable)
  • org.apache.beam.sdk.transforms.PTransform<InputT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
    • org.apache.beam.sdk.io.kafka.KafkaCommitOffset<K,V>
    • org.apache.beam.sdk.io.kafka.KafkaIO.Read<K,V>
    • org.apache.beam.sdk.io.kafka.KafkaIO.ReadSourceDescriptors<K,V>
    • org.apache.beam.sdk.io.kafka.KafkaIO.TypedWithoutMetadata<K,V>
    • org.apache.beam.sdk.io.kafka.KafkaIO.Write<K,V>
    • org.apache.beam.sdk.io.kafka.KafkaIO.WriteRecords<K,V>
  • org.apache.beam.sdk.io.kafka.TimestampPolicy<K,V>
    • org.apache.beam.sdk.io.kafka.CustomTimestampPolicyWithLimitedDelay<K,V>
    • org.apache.beam.sdk.io.kafka.TimestampPolicyFactory.LogAppendTimePolicy<K,V>
    • org.apache.beam.sdk.io.kafka.TimestampPolicyFactory.ProcessingTimePolicy<K,V>
    • org.apache.beam.sdk.io.kafka.TimestampPolicyFactory.TimestampFnPolicy<K,V>
  • org.apache.beam.sdk.io.kafka.TimestampPolicy.PartitionContext

Interface Hierarchy

• java.io.Serializable
  • org.apache.beam.sdk.io.kafka.DeserializerProvider<T>
  • org.apache.beam.sdk.io.kafka.KafkaPublishTimestampFunction<T>
  • org.apache.beam.sdk.io.kafka.TimestampPolicyFactory<KeyT,ValueT>

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.beam.sdk.io.kafka.KafkaTimestampType