Hierarchy For Package io.krabka.streams.columnar

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • io.krabka.streams.columnar.ArrowIpcSerde (implements org.apache.kafka.common.serialization.Serde<T>)
  • io.krabka.streams.columnar.ArrowValues
  • io.krabka.streams.columnar.BlobCodec (implements io.krabka.streams.columnar.BatchCodec)
  • io.krabka.streams.columnar.BuiltColumnarTopology (implements java.lang.AutoCloseable)
  • io.krabka.streams.columnar.BuiltinOp (implements io.krabka.streams.columnar.StatefulColumnarProcessor)
  • io.krabka.streams.columnar.ColumnarContext
  • io.krabka.streams.columnar.ColumnarMetrics
  • io.krabka.streams.columnar.ColumnarNode
  • io.krabka.streams.columnar.ColumnarRunner
  • io.krabka.streams.columnar.ColumnarRunner.GroupRunner (implements java.lang.AutoCloseable, org.apache.kafka.clients.consumer.ConsumerRebalanceListener)
  • io.krabka.streams.columnar.ColumnarTopology
  • io.krabka.streams.columnar.FileColumnarStateStore (implements io.krabka.streams.columnar.ColumnarStateStore)
  • io.krabka.streams.columnar.GzipBatchCodec (implements io.krabka.streams.columnar.BatchCodec)
  • io.krabka.streams.columnar.JsonRowBridge<T> (implements io.krabka.streams.columnar.RowBridge<T>)
  • io.krabka.streams.columnar.RowCodec<T> (implements io.krabka.streams.columnar.BatchCodec)
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • io.krabka.streams.columnar.ColumnarException

Interface Hierarchy

• java.lang.AutoCloseable
  • io.krabka.streams.columnar.ColumnarStateStore.EpochLease
• io.krabka.streams.columnar.BatchCodec
• io.krabka.streams.columnar.ColumnarProcessor
  • io.krabka.streams.columnar.StatefulColumnarProcessor
• io.krabka.streams.columnar.ColumnarStateStore
• io.krabka.streams.columnar.RowBridge<T>
• io.krabka.streams.columnar.RowPredicate
• io.krabka.streams.columnar.RowValue

Enum Class Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
    • io.krabka.streams.columnar.AggregateFunction
    • io.krabka.streams.columnar.ColumnarErrorPolicy.Action

Record Class Hierarchy

• java.lang.Object
  • java.lang.Record
    • io.krabka.streams.columnar.Aggregation
    • io.krabka.streams.columnar.ColumnarErrorPolicy
    • io.krabka.streams.columnar.ColumnarJoin
    • io.krabka.streams.columnar.ColumnarMetrics.Snapshot
    • io.krabka.streams.columnar.ConsumedRecord
    • io.krabka.streams.columnar.DerivedColumn
    • io.krabka.streams.columnar.ProducedToTopic
    • io.krabka.streams.columnar.ProduceRecord
    • io.krabka.streams.columnar.RecordHeader