Hierarchy For Package cz.o2.proxima.direct.io.kafka

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • cz.o2.proxima.core.storage.AbstractStorage
    • cz.o2.proxima.direct.core.AbstractAttributeWriter (implements cz.o2.proxima.direct.core.AttributeWriterBase)
      • cz.o2.proxima.direct.core.AbstractOnlineAttributeWriter (implements cz.o2.proxima.direct.core.OnlineAttributeWriter)
        • cz.o2.proxima.direct.io.kafka.KafkaWriter<K,V>
    • cz.o2.proxima.core.storage.AbstractStorage.SerializableAbstractStorage (implements java.io.Serializable)
      • cz.o2.proxima.direct.io.kafka.KafkaAccessor (implements cz.o2.proxima.direct.core.DataAccessor)
    • cz.o2.proxima.direct.io.kafka.KafkaLogReader (implements cz.o2.proxima.direct.core.commitlog.CommitLogReader)
  • cz.o2.proxima.direct.io.kafka.KafkaConsumerFactory<K,V>
  • cz.o2.proxima.direct.io.kafka.KafkaStorage (implements cz.o2.proxima.direct.core.DataAccessorFactory)
  • cz.o2.proxima.direct.io.kafka.KafkaStreamElement.KafkaStreamElementSerializer (implements cz.o2.proxima.direct.io.kafka.ElementSerializer<K,V>)
  • cz.o2.proxima.direct.io.kafka.OffsetCommitter<ID>
  • cz.o2.proxima.core.storage.StreamElement (implements java.io.Serializable)
    • cz.o2.proxima.direct.io.kafka.KafkaStreamElement
  • cz.o2.proxima.direct.core.time.WatermarkConfiguration (implements java.io.Serializable)
    • cz.o2.proxima.direct.io.kafka.KafkaWatermarkConfiguration

Interface Hierarchy

• cz.o2.proxima.direct.io.kafka.OffsetCommitter.Callback
• java.io.Serializable
  • cz.o2.proxima.direct.io.kafka.ElementSerializer<K,V>