Hierarchy For All Packages

Package Hierarchies:

• io.krabka.streams,
• io.krabka.streams.columnar,
• io.krabka.streams.columnar.barrier,
• io.krabka.streams.columnar.schema,
• io.krabka.streams.coordination,
• io.krabka.streams.schema,
• io.krabka.streams.test

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.schema.AvroArrowSchemas
  • io.krabka.streams.columnar.schema.AvroBatchCodec (implements io.krabka.streams.columnar.BatchCodec)
  • io.krabka.streams.columnar.schema.AvroRowBridge<T> (implements io.krabka.streams.columnar.RowBridge<T>)
  • io.krabka.streams.schema.AvroSerde<T>
  • io.krabka.streams.columnar.barrier.BarrierCutDecoder
  • io.krabka.streams.columnar.barrier.BarrierCutReader
  • 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.test.ColumnarTestDriver
  • io.krabka.streams.columnar.ColumnarTopology
  • io.krabka.streams.schema.ConfluentWireFormat
  • io.krabka.streams.coordination.CoordinationClient (implements java.lang.AutoCloseable)
  • io.krabka.streams.coordination.CoordinationCodec
  • io.krabka.streams.coordination.FencingToken (implements java.lang.Comparable<T>)
  • 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.schema.JsonSchemaSerde<T>
  • io.krabka.streams.coordination.KafkaCoordinationTransport (implements io.krabka.streams.coordination.CoordinationTransport)
  • io.krabka.streams.schema.KrabkaSchemaRegistryClient
  • io.krabka.streams.KrabkaStreamsConfig
  • io.krabka.streams.coordination.Leadership (implements java.lang.AutoCloseable)
  • io.krabka.streams.coordination.LeaseConfig
  • io.krabka.streams.coordination.LeaseTiming
  • io.krabka.streams.schema.LocalSchemaCompatibility
  • io.krabka.streams.coordination.ManualClock (implements io.krabka.streams.coordination.Clock)
  • io.krabka.streams.coordination.MemberId (implements java.lang.Comparable<T>)
  • io.krabka.streams.columnar.schema.ProtobufArrowSchemas
  • io.krabka.streams.columnar.schema.ProtobufBatchCodec (implements io.krabka.streams.columnar.BatchCodec)
  • io.krabka.streams.columnar.schema.ProtobufRowBridge<T> (implements io.krabka.streams.columnar.RowBridge<T>)
  • io.krabka.streams.schema.ProtobufSerde<T>
  • io.krabka.streams.coordination.Role (implements java.lang.Comparable<T>)
  • io.krabka.streams.coordination.RolePartitioner
  • io.krabka.streams.coordination.RoleState
  • io.krabka.streams.coordination.RoleStateBuilder
  • io.krabka.streams.columnar.RowCodec<T> (implements io.krabka.streams.columnar.BatchCodec)
  • io.krabka.streams.schema.SchemaCache
  • io.krabka.streams.test.SchemaRegistryStub (implements java.lang.AutoCloseable)
  • io.krabka.streams.coordination.Succession
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • io.krabka.streams.columnar.ColumnarException
        • io.krabka.streams.coordination.CoordinationException
          • io.krabka.streams.coordination.FencedException
        • org.apache.kafka.common.KafkaException
          • org.apache.kafka.common.errors.ApiException
            • org.apache.kafka.common.errors.RetriableException
              • io.krabka.streams.schema.SchemaFetchPendingException
        • io.krabka.streams.schema.SchemaRegistryException
  • io.krabka.streams.schema.TopicNameStrategy (implements io.krabka.streams.schema.SubjectNameStrategy)

Interface Hierarchy

• java.lang.AutoCloseable
  • io.krabka.streams.columnar.ColumnarStateStore.EpochLease
  • io.krabka.streams.coordination.CoordinationTransport
• io.krabka.streams.columnar.barrier.BarrierListener
• io.krabka.streams.columnar.BatchCodec
• io.krabka.streams.coordination.Clock
• io.krabka.streams.columnar.ColumnarProcessor
  • io.krabka.streams.columnar.StatefulColumnarProcessor
• io.krabka.streams.columnar.ColumnarStateStore
• io.krabka.streams.coordination.CoordinationValue
• io.krabka.streams.columnar.RowBridge<T>
• io.krabka.streams.columnar.RowPredicate
• io.krabka.streams.columnar.RowValue
• io.krabka.streams.schema.SubjectNameStrategy

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.barrier.BarrierCutStatus
    • io.krabka.streams.columnar.ColumnarErrorPolicy.Action
    • io.krabka.streams.coordination.Decision.Action
    • io.krabka.streams.schema.LocalSchemaCompatibility.Mode
    • io.krabka.streams.coordination.RecordKind
    • io.krabka.streams.schema.RegisterMode
    • io.krabka.streams.schema.Role
    • io.krabka.streams.schema.SchemaKind

Record Class Hierarchy

• java.lang.Object
  • java.lang.Record
    • io.krabka.streams.columnar.Aggregation
    • io.krabka.streams.columnar.barrier.BarrierAlignment
    • io.krabka.streams.columnar.barrier.BarrierCut
    • io.krabka.streams.columnar.ColumnarErrorPolicy
    • io.krabka.streams.columnar.ColumnarJoin
    • io.krabka.streams.columnar.ColumnarMetrics.Snapshot
    • io.krabka.streams.schema.ConfluentWireFormat.Frame
    • io.krabka.streams.schema.ConfluentWireFormat.ProtobufFrame
    • io.krabka.streams.columnar.ConsumedRecord
    • io.krabka.streams.coordination.CoordinationEntry
    • io.krabka.streams.coordination.CoordinationKey
    • io.krabka.streams.coordination.Decision
    • io.krabka.streams.columnar.DerivedColumn
    • io.krabka.streams.schema.KrabkaSchemaRegistryClient.FetchedSchema
    • io.krabka.streams.schema.KrabkaSchemaRegistryClient.RegisteredSchema
    • io.krabka.streams.schema.KrabkaSchemaRegistryClient.ResolvedSchema
    • io.krabka.streams.schema.KrabkaSchemaRegistryClient.SchemaReference
    • io.krabka.streams.coordination.LeadershipStatus
    • io.krabka.streams.coordination.Lease (implements io.krabka.streams.coordination.CoordinationValue)
    • io.krabka.streams.schema.LocalSchemaCompatibility.Result
    • io.krabka.streams.columnar.ProducedToTopic
    • io.krabka.streams.columnar.ProduceRecord
    • io.krabka.streams.columnar.RecordHeader
    • io.krabka.streams.coordination.Registration (implements io.krabka.streams.coordination.CoordinationValue)
    • io.krabka.streams.coordination.RosterEntry
    • io.krabka.streams.schema.SchemaCache.PrewarmReport