Index (krabka streams for Java 1.4.2 API)

A B C D E F G H I J K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

acquire(Role, MemberId, Duration) - Method in class io.krabka.streams.coordination.CoordinationClient: Competes for one role until this member wins it or the deadline passes.
acquireEpoch(Role) - Method in interface io.krabka.streams.coordination.CoordinationTransport: Mints a new epoch for a role and fences the member that held it.
acquireEpoch(Role) - Method in class io.krabka.streams.coordination.KafkaCoordinationTransport: Mints a new epoch for a role and fences the member that held it.
action() - Method in record class io.krabka.streams.columnar.ColumnarErrorPolicy: Returns the value of the action record component.
action() - Method in record class io.krabka.streams.coordination.Decision: Returns the value of the action record component.
addJoin(String, ColumnarJoin, ColumnarNode, ColumnarNode) - Method in class io.krabka.streams.columnar.ColumnarTopology: Joins two co-partitioned branches by key within an event-time window.
addMerge(String, Collection) - Method in class io.krabka.streams.columnar.ColumnarTopology: Merges batches from two or more upstream branches with the same Arrow schema.
addOperator(String, BuiltinOp, ColumnarNode) - Method in class io.krabka.streams.columnar.ColumnarTopology: Adds a built-in operator node.
addOperator(String, Supplier, ColumnarNode) - Method in class io.krabka.streams.columnar.ColumnarTopology: Adds a custom operator node.
addPassThroughSink(String, String, ColumnarNode) - Method in class io.krabka.streams.columnar.ColumnarTopology: Copies source records byte-for-byte to a topic without decoding and re-encoding the sink.
addSink(String, String, BatchCodec, ColumnarNode) - Method in class io.krabka.streams.columnar.ColumnarTopology: Adds a sink that encodes its parent's batches to a topic.
addSource(String, Collection, BatchCodec) - Method in class io.krabka.streams.columnar.ColumnarTopology: Adds a source that decodes records from one or more topics.
advance(Duration) - Method in class io.krabka.streams.coordination.ManualClock: Moves the clock forward by one extent.
A fence is the loss of the role - Section in class io.krabka.streams.coordination.KafkaCoordinationTransport
AggregateFunction - Enum Class in io.krabka.streams.columnar: Built-in within-batch aggregate functions.
Aggregation - Record Class in io.krabka.streams.columnar: Defines one aggregation, with an optional explicit output type.
Aggregation(String, String, AggregateFunction) - Constructor for record class io.krabka.streams.columnar.Aggregation: Creates an aggregation with the function's default output type.
Aggregation(String, String, AggregateFunction, ArrowType) - Constructor for record class io.krabka.streams.columnar.Aggregation: Validates that everything but the output type is present.
All records of one role go to one partition - Section in class io.krabka.streams.coordination.KafkaCoordinationTransport
apply(CoordinationEntry) - Method in class io.krabka.streams.coordination.RoleStateBuilder: Applies one record of the coordination partition.
ArrowIpcSerde - Class in io.krabka.streams.columnar: A Kafka serde for Arrow IPC stream batches.
ArrowIpcSerde(BufferAllocator) - Constructor for class io.krabka.streams.columnar.ArrowIpcSerde: Creates a serde whose deserialized batches are owned by an allocator.
arrowSchema() - Method in class io.krabka.streams.columnar.schema.AvroBatchCodec: Returns the payload Arrow schema of decoded batches, without the reserved metadata columns.
arrowSchema() - Method in class io.krabka.streams.columnar.schema.AvroRowBridge: Returns the Arrow schema every batch of this bridge uses.
arrowSchema() - Method in class io.krabka.streams.columnar.schema.ProtobufBatchCodec: Returns the payload Arrow schema of decoded batches, without the reserved metadata columns.
arrowSchema() - Method in class io.krabka.streams.columnar.schema.ProtobufRowBridge: Returns the Arrow schema every batch of this bridge uses.
ArrowValues - Class in io.krabka.streams.columnar: Type-coercing Arrow batch helpers for RowBridge and ColumnarProcessor implementations.
AUTO_REGISTER - Enum constant in enum class io.krabka.streams.schema.RegisterMode: Registers the local schema, creating a new subject version when the schema is unknown to the registry.
avro(String, String, LocalSchemaCompatibility.Mode) - Static method in class io.krabka.streams.schema.LocalSchemaCompatibility: Checks two Avro schemas for compatibility.
AVRO - Enum constant in enum class io.krabka.streams.schema.SchemaKind: An Apache Avro schema, the registry default format.
AvroArrowSchemas - Class in io.krabka.streams.columnar.schema: Translates Avro schemas into Arrow schemas.
AvroBatchCodec - Class in io.krabka.streams.columnar.schema: Decodes registry-framed Avro topics into Arrow batches and encodes them back.
AvroRowBridge<T> - Class in io.krabka.streams.columnar.schema: Converts Avro records to and from Arrow batches with schema-derived columns.
AvroSerde<T> - Class in io.krabka.streams.schema: A Kafka serde for Confluent-framed Avro values.

B

BACKWARD - Enum constant in enum class io.krabka.streams.schema.LocalSchemaCompatibility.Mode: New readers must read data written with the previous schema.
BarrierAlignment - Record Class in io.krabka.streams.columnar.barrier: Tells a group runner which barrier group to align on.
BarrierAlignment(String, BarrierCutReader, BarrierListener) - Constructor for record class io.krabka.streams.columnar.barrier.BarrierAlignment: Rejects null components.
BarrierCut - Record Class in io.krabka.streams.columnar.barrier: One epoch's cut across every partition of a barrier group.
BarrierCut(String, long, long, long, BarrierCutStatus, Map, Set) - Constructor for record class io.krabka.streams.columnar.barrier.BarrierCut: Copies the mutable components so the cut is immutable.
BarrierCutDecoder - Class in io.krabka.streams.columnar.barrier: Decodes the cut records of the internal __barrier_state topic.
BarrierCutReader - Class in io.krabka.streams.columnar.barrier: Reads published cuts from the internal __barrier_state topic.
BarrierCutReader(Consumer) - Constructor for class io.krabka.streams.columnar.barrier.BarrierCutReader: Creates a reader over a consumer, with the default poll timeout.
BarrierCutReader(Consumer, Duration) - Constructor for class io.krabka.streams.columnar.barrier.BarrierCutReader: Creates a reader over a consumer.
BarrierCutStatus - Enum Class in io.krabka.streams.columnar.barrier: Whether a barrier coordinator reached every partition of a cut.
BarrierListener - Interface in io.krabka.streams.columnar.barrier: Receives a cut when a runner reaches the barrier.
BatchCodec - Interface in io.krabka.streams.columnar: Converts one partition batch between Kafka records and Arrow vectors.
batches() - Method in record class io.krabka.streams.columnar.ColumnarMetrics.Snapshot: Returns the value of the batches record component.
batchToRows(VectorSchemaRoot) - Method in class io.krabka.streams.columnar.JsonRowBridge: Converts an Arrow payload batch back into one value per row.
batchToRows(VectorSchemaRoot) - Method in interface io.krabka.streams.columnar.RowBridge: Converts an Arrow payload batch back into one value per row.
batchToRows(VectorSchemaRoot) - Method in class io.krabka.streams.columnar.schema.AvroRowBridge: Converts an Arrow payload batch back into one record per row.
batchToRows(VectorSchemaRoot) - Method in class io.krabka.streams.columnar.schema.ProtobufRowBridge: Converts an Arrow payload batch back into one message per row.
BlobCodec - Class in io.krabka.streams.columnar: Converts records whose values are Arrow IPC batches.
BlobCodec(BufferAllocator) - Constructor for class io.krabka.streams.columnar.BlobCodec: Creates a codec with the 921600-byte record cap.
BlobCodec(BufferAllocator, int) - Constructor for class io.krabka.streams.columnar.BlobCodec: Creates a codec with an explicit record size cap.
body() - Method in record class io.krabka.streams.schema.ConfluentWireFormat.Frame: Returns a copy of the record body.
body() - Method in record class io.krabka.streams.schema.ConfluentWireFormat.ProtobufFrame: Returns a copy of the serialized Protobuf message.
Buffer ownership - Section in interface io.krabka.streams.columnar.ColumnarProcessor
build() - Method in class io.krabka.streams.columnar.ColumnarTopology: Validates the graph and creates its executable form.
build() - Method in class io.krabka.streams.coordination.RoleStateBuilder: Builds the role state, with the roster in offset order.
BuiltColumnarTopology - Class in io.krabka.streams.columnar: A validated and reusable columnar topology.
BuiltinOp - Class in io.krabka.streams.columnar: Creates the built-in Arrow batch operators.
bytes() - Method in class io.krabka.streams.coordination.Role: Returns the UTF-8 bytes of the role name.

C

cache() - Method in class io.krabka.streams.schema.AvroSerde: Returns the schema cache this serde resolves subjects and writer schemas with.
cache() - Method in class io.krabka.streams.schema.JsonSchemaSerde: Returns the schema cache this serde resolves subjects and writer schemas with.
cache() - Method in class io.krabka.streams.schema.ProtobufSerde: Returns the schema cache this serde resolves subjects and writer schemas with.
challenge() - Static method in record class io.krabka.streams.coordination.Decision: Returns the decision to call InitProducerId now.
CHALLENGE - Enum constant in enum class io.krabka.streams.coordination.Decision.Action: This member calls InitProducerId now.
challengeAtMillis(int) - Method in class io.krabka.streams.coordination.LeaseTiming: Returns the instant at which a challenger of one rank challenges.
challengeDelayMillis(int) - Method in class io.krabka.streams.coordination.LeaseConfig: Returns the extra delay that a challenger of one rank takes.
challengeStagger() - Method in class io.krabka.streams.coordination.LeaseConfig: Returns the extra delay that one rank of succession adds.
clearLease(Role, FencingToken) - Method in interface io.krabka.streams.coordination.CoordinationTransport: Clears the lease of a role with a tombstone, in a transaction under one token.
clearLease(Role, FencingToken) - Method in class io.krabka.streams.coordination.KafkaCoordinationTransport: Clears the lease of a role with a tombstone, in a transaction under one token.
Clock - Interface in io.krabka.streams.coordination: A source of the current time.
Clock assumptions - Section in package io.krabka.streams.coordination
close() - Method in class io.krabka.streams.columnar.BuiltColumnarTopology: Releases every partition's processor state.
close() - Method in class io.krabka.streams.columnar.ColumnarRunner.GroupRunner: Saves every still-owned partition's state and closes the built topology.
close() - Method in interface io.krabka.streams.columnar.ColumnarStateStore.EpochLease
close() - Method in class io.krabka.streams.coordination.CoordinationClient: Closes the transport this client drives.
close() - Method in interface io.krabka.streams.coordination.CoordinationTransport: Releases the resources this transport created.
close() - Method in class io.krabka.streams.coordination.KafkaCoordinationTransport: Closes the transactional producers this transport built.
close() - Method in class io.krabka.streams.coordination.Leadership: Resigns when this member still holds the role.
close() - Method in class io.krabka.streams.test.SchemaRegistryStub: Stops the HTTP server and discards all registered schemas.
code() - Method in enum class io.krabka.streams.columnar.barrier.BarrierCutStatus: Returns the wire code the coordinator writes for this status.
code() - Method in enum class io.krabka.streams.coordination.RecordKind: Returns the wire code a writer puts in the key.
ColumnarContext - Class in io.krabka.streams.columnar: Collects batches that a columnar processor forwards.
ColumnarContext() - Constructor for class io.krabka.streams.columnar.ColumnarContext: Creates an empty context.
ColumnarErrorPolicy - Record Class in io.krabka.streams.columnar: Selects how a group runner handles a failed logical partition batch.
ColumnarErrorPolicy(ColumnarErrorPolicy.Action, String) - Constructor for record class io.krabka.streams.columnar.ColumnarErrorPolicy: Validates the action and dead-letter topic combination.
ColumnarErrorPolicy.Action - Enum Class in io.krabka.streams.columnar: The reaction to a failed partition batch.
ColumnarException - Exception Class in io.krabka.streams.columnar: Reports an Arrow codec, topology, or operator failure.
ColumnarException(String) - Constructor for exception class io.krabka.streams.columnar.ColumnarException: Creates an exception with a message.
ColumnarException(String, Throwable) - Constructor for exception class io.krabka.streams.columnar.ColumnarException: Creates an exception with a message and cause.
ColumnarJoin - Record Class in io.krabka.streams.columnar: Configuration for an inner, event-time, equi-join.
ColumnarJoin(String, String, Duration) - Constructor for record class io.krabka.streams.columnar.ColumnarJoin: Creates a join with the default left_ and right_ prefixes.
ColumnarJoin(String, String, Duration, String, String) - Constructor for record class io.krabka.streams.columnar.ColumnarJoin: Validates the configuration.
ColumnarMetrics - Class in io.krabka.streams.columnar: Lock-free counters for a columnar runner.
ColumnarMetrics() - Constructor for class io.krabka.streams.columnar.ColumnarMetrics: Creates a metrics object with all counters at zero.
ColumnarMetrics.Snapshot - Record Class in io.krabka.streams.columnar: One point-in-time view of the counters.
ColumnarNode - Class in io.krabka.streams.columnar: An opaque handle to a columnar topology node.
ColumnarProcessor - Interface in io.krabka.streams.columnar: Processes one Arrow batch and forwards zero or more output batches.
ColumnarRunner - Class in io.krabka.streams.columnar: Runs fetch, process, asynchronously produce, and commit cycles.
ColumnarRunner.GroupRunner - Class in io.krabka.streams.columnar: A consumer-group runner that manages rebalances and persistent operator state.
ColumnarStateStore - Interface in io.krabka.streams.columnar: Persists operator snapshots for one logical Kafka partition and one epoch.
ColumnarStateStore.EpochLease - Interface in io.krabka.streams.columnar: A closeable snapshot-retention lease without checked exceptions.
ColumnarTestDriver - Class in io.krabka.streams.test: Runs a columnar topology without a broker.
ColumnarTestDriver(BuiltColumnarTopology) - Constructor for class io.krabka.streams.test.ColumnarTestDriver: Creates a driver around a built topology.
ColumnarTopology - Class in io.krabka.streams.columnar: A linear or branching graph whose edges carry Arrow batches.
ColumnarTopology(BufferAllocator) - Constructor for class io.krabka.streams.columnar.ColumnarTopology: Creates an empty topology.
compareTo(FencingToken) - Method in class io.krabka.streams.coordination.FencingToken: Orders two tokens lexicographically.
compareTo(MemberId) - Method in class io.krabka.streams.coordination.MemberId: Orders two member ids by their text.
compareTo(Role) - Method in class io.krabka.streams.coordination.Role: Orders two roles by their names.
compatibility() - Method in class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Reads the registry's global compatibility level.
compatibility(String) - Method in class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Reads a subject's compatibility level.
compatible() - Method in record class io.krabka.streams.schema.LocalSchemaCompatibility.Result: Returns the value of the compatible record component.
complete() - Method in record class io.krabka.streams.columnar.barrier.BarrierCut: Reports whether every partition of the group received the epoch's marker.
COMPLETE - Enum constant in enum class io.krabka.streams.columnar.barrier.BarrierCutStatus: Every partition of the barrier group received the epoch's marker.
completeCutsAfter(String, long) - Method in class io.krabka.streams.columnar.barrier.BarrierCutReader: Returns the complete cuts of a barrier group above an epoch.
completedAt() - Method in record class io.krabka.streams.columnar.barrier.BarrierCut: Returns the value of the completedAt record component.
config() - Method in class io.krabka.streams.coordination.CoordinationClient: Returns the lease timings this client applies.
ConfluentWireFormat - Class in io.krabka.streams.schema: Encodes and decodes Confluent schema registry frames.
ConfluentWireFormat.Frame - Record Class in io.krabka.streams.schema: A decoded frame.
ConfluentWireFormat.ProtobufFrame - Record Class in io.krabka.streams.schema: A decoded Protobuf frame.
ConsumedRecord - Record Class in io.krabka.streams.columnar: One input record in a partition batch.
ConsumedRecord(byte[], byte[], long, int, long) - Constructor for record class io.krabka.streams.columnar.ConsumedRecord: Creates a record without headers.
ConsumedRecord(byte[], byte[], long, int, long, List) - Constructor for record class io.krabka.streams.columnar.ConsumedRecord: Copies the mutable components so the record is immutable.
CoordinationClient - Class in io.krabka.streams.coordination: Elects one leader per role over a CoordinationTransport.
CoordinationClient(CoordinationTransport) - Constructor for class io.krabka.streams.coordination.CoordinationClient: Creates a client with the default lease timings and the clock of the host.
CoordinationClient(CoordinationTransport, LeaseConfig, Clock, Duration) - Constructor for class io.krabka.streams.coordination.CoordinationClient: Creates a client.
CoordinationCodec - Class in io.krabka.streams.coordination: Encodes and decodes the frozen records of the internal __coordination_state topic.
CoordinationEntry - Record Class in io.krabka.streams.coordination: One decoded record of CoordinationCodec.TOPIC, with the offset it sits at.
CoordinationEntry(long, CoordinationKey, Optional) - Constructor for record class io.krabka.streams.coordination.CoordinationEntry: Rejects a null key and a null value holder.
CoordinationException - Exception Class in io.krabka.streams.coordination: Reports a coordination failure.
CoordinationException(String) - Constructor for exception class io.krabka.streams.coordination.CoordinationException: Creates an exception with a message.
CoordinationException(String, Throwable) - Constructor for exception class io.krabka.streams.coordination.CoordinationException: Creates an exception with a message and a cause.
CoordinationKey - Record Class in io.krabka.streams.coordination: The decoded key of one record of CoordinationCodec.TOPIC.
CoordinationKey(RecordKind, Role, Optional) - Constructor for record class io.krabka.streams.coordination.CoordinationKey: Rejects a null component and a key whose member does not match its kind.
CoordinationTransport - Interface in io.krabka.streams.coordination: The seam between the succession rules and the cluster.
CoordinationValue - Interface in io.krabka.streams.coordination: One decoded value of CoordinationCodec.TOPIC.
COUNT - Enum constant in enum class io.krabka.streams.columnar.AggregateFunction: Counts the rows in the group, nulls included.
createRoot(List, int, BufferAllocator) - Static method in class io.krabka.streams.columnar.ArrowValues: Creates a batch with allocated vectors and the given row count.
current() - Method in record class io.krabka.streams.coordination.LeadershipStatus: Reports whether the author of the lease still holds the epoch of the role.

D

DEAD_LETTER - Enum constant in enum class io.krabka.streams.columnar.ColumnarErrorPolicy.Action: Forward the batch's input records to the dead-letter topic, then commit.
deadLetter(String) - Static method in record class io.krabka.streams.columnar.ColumnarErrorPolicy: Returns the policy that forwards failed batches to a dead-letter topic.
deadLetterRecords() - Method in record class io.krabka.streams.columnar.ColumnarMetrics.Snapshot: Returns the value of the deadLetterRecords record component.
deadLetterTopic() - Method in record class io.krabka.streams.columnar.ColumnarErrorPolicy: Returns the value of the deadLetterTopic record component.
deadline() - Method in record class io.krabka.streams.coordination.Lease: Returns the value of the deadline record component.
Decision - Record Class in io.krabka.streams.coordination: What one member does about a role right now.
Decision(Decision.Action, long) - Constructor for record class io.krabka.streams.coordination.Decision: Rejects a null action.
Decision.Action - Enum Class in io.krabka.streams.coordination: The step that one member takes about a role.
decode(byte[]) - Static method in class io.krabka.streams.schema.ConfluentWireFormat: Splits framed record bytes into the schema ID and body.
decode(byte[], byte[]) - Static method in class io.krabka.streams.columnar.barrier.BarrierCutDecoder: Decodes one __barrier_state record into a cut.
decode(String, List) - Method in interface io.krabka.streams.columnar.BatchCodec: Decodes a fetched partition batch with the source topic available to the codec.
decode(String, List) - Method in class io.krabka.streams.columnar.GzipBatchCodec: Decompresses record values, then delegates decoding.
decode(String, List) - Method in class io.krabka.streams.columnar.RowCodec: Decodes records, forwarding the topic to the value serde.
decode(String, List) - Method in class io.krabka.streams.columnar.schema.AvroBatchCodec: Decodes records, resolving writer schemas through the topic's subject.
decode(String, List) - Method in class io.krabka.streams.columnar.schema.ProtobufBatchCodec: Decodes records, resolving the subject through the topic name.
decode(List) - Method in interface io.krabka.streams.columnar.BatchCodec: Decodes a fetched partition batch into one Arrow batch.
decode(List) - Method in class io.krabka.streams.columnar.BlobCodec: Decodes Arrow IPC record values into one batch with metadata columns.
decode(List) - Method in class io.krabka.streams.columnar.GzipBatchCodec: Decompresses record values, then decodes them with an empty topic name.
decode(List) - Method in class io.krabka.streams.columnar.RowCodec: Decodes records with an empty topic name.
decode(List) - Method in class io.krabka.streams.columnar.schema.AvroBatchCodec: Decodes records with an empty topic name.
decode(List) - Method in class io.krabka.streams.columnar.schema.ProtobufBatchCodec: Decodes records with an empty topic name.
decodeKey(byte[]) - Static method in class io.krabka.streams.coordination.CoordinationCodec: Decodes a record key.
decodeProtobuf(byte[]) - Static method in class io.krabka.streams.schema.ConfluentWireFormat: Splits framed Protobuf record bytes into schema ID, message indexes, and body.
decodeValue(RecordKind, byte[]) - Static method in class io.krabka.streams.coordination.CoordinationCodec: Decodes a record value under the kind of its key.
DEFAULT_CHALLENGE_STAGGER - Static variable in class io.krabka.streams.coordination.LeaseConfig: The default extra delay that one rank of succession adds.
DEFAULT_LEASE_DURATION - Static variable in class io.krabka.streams.coordination.LeaseConfig: The default extent of a lease.
DEFAULT_MAX_RECORD_BYTES - Static variable in class io.krabka.streams.columnar.BlobCodec: The default maxRecordBytes: 900 KiB, safely under a 1 MiB broker limit.
DEFAULT_MAX_UNCOMPRESSED_BYTES - Static variable in class io.krabka.streams.columnar.GzipBatchCodec: The default decompression ceiling: 16 MiB per record.
DEFAULT_PARTITIONS - Static variable in class io.krabka.streams.coordination.RolePartitioner: The partition count this module assumes for CoordinationCodec.TOPIC.
DEFAULT_POLL_TIMEOUT - Static variable in class io.krabka.streams.columnar.barrier.BarrierCutReader: The poll timeout a reader uses when the caller names none.
DEFAULT_POLL_TIMEOUT - Static variable in class io.krabka.streams.coordination.KafkaCoordinationTransport: The poll timeout a read uses when the caller names none.
DEFAULT_RENEW_INTERVAL - Static variable in class io.krabka.streams.coordination.LeaseConfig: The default gap between two renewals by the holder.
DEFAULT_RETRY_INTERVAL - Static variable in class io.krabka.streams.coordination.CoordinationClient: The gap between two passes of a blocking acquire, when no decision names one.
defaults() - Static method in class io.krabka.streams.coordination.LeaseConfig: Returns the config of LeaseConfig.DEFAULT_LEASE_DURATION, LeaseConfig.DEFAULT_RENEW_INTERVAL, and LeaseConfig.DEFAULT_CHALLENGE_STAGGER.
deleteSubject(String, boolean) - Method in class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Deletes a subject and all of its versions.
deleteVersion(String, int, boolean) - Method in class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Deletes one version of a subject.
DerivedColumn - Record Class in io.krabka.streams.columnar: Defines a column that a with-columns operator adds or replaces.
DerivedColumn(Field, RowValue) - Constructor for record class io.krabka.streams.columnar.DerivedColumn: Validates that both components are present.
describe(Role) - Method in class io.krabka.streams.coordination.CoordinationClient: Reports what one role looks like to a third party.
describe(Role) - Method in interface io.krabka.streams.coordination.CoordinationTransport: Asks the transaction coordinator which token holds a role now.
describe(Role) - Method in class io.krabka.streams.coordination.KafkaCoordinationTransport: Asks the transaction coordinator which token holds a role now.
deserializeBody(int, byte[]) - Method in class io.krabka.streams.schema.AvroSerde
deserializeBody(int, byte[]) - Method in class io.krabka.streams.schema.JsonSchemaSerde
deserializeBody(int, byte[]) - Method in class io.krabka.streams.schema.ProtobufSerde
deserializer() - Method in class io.krabka.streams.columnar.ArrowIpcSerde: Returns the deserializer half of this serde.
deserializer() - Method in class io.krabka.streams.schema.AvroSerde: Returns the deserializer half of this serde.
deserializer() - Method in class io.krabka.streams.schema.JsonSchemaSerde: Returns the deserializer half of this serde.
deserializer() - Method in class io.krabka.streams.schema.ProtobufSerde: Returns the deserializer half of this serde.
drainOutput(String) - Method in class io.krabka.streams.test.ColumnarTestDriver: Removes and returns all records for a topic.
duration() - Method in class io.krabka.streams.coordination.LeaseConfig: Returns the extent of a lease that a member takes now.

E

empty() - Static method in class io.krabka.streams.coordination.RoleState: Returns the state of a role that has no record.
encode(int, byte[]) - Static method in class io.krabka.streams.schema.ConfluentWireFormat: Frames body bytes with the magic byte and schema ID.
encode(String, VectorSchemaRoot) - Method in interface io.krabka.streams.columnar.BatchCodec: Encodes an Arrow batch with the sink topic available to the codec.
encode(String, VectorSchemaRoot) - Method in class io.krabka.streams.columnar.GzipBatchCodec: Delegates encoding, then compresses each record value.
encode(String, VectorSchemaRoot) - Method in class io.krabka.streams.columnar.RowCodec: Encodes a batch into one record per row, forwarding the topic to the serde.
encode(String, VectorSchemaRoot) - Method in class io.krabka.streams.columnar.schema.AvroBatchCodec: Encodes a batch into one registry-framed record per row.
encode(String, VectorSchemaRoot) - Method in class io.krabka.streams.columnar.schema.ProtobufBatchCodec: Encodes a batch into one registry-framed record per row.
encode(VectorSchemaRoot) - Method in interface io.krabka.streams.columnar.BatchCodec: Encodes an Arrow batch into producible records.
encode(VectorSchemaRoot) - Method in class io.krabka.streams.columnar.BlobCodec: Encodes a batch's payload into size-capped Arrow IPC records.
encode(VectorSchemaRoot) - Method in class io.krabka.streams.columnar.GzipBatchCodec: Encodes with an empty topic name, then compresses each record value.
encode(VectorSchemaRoot) - Method in class io.krabka.streams.columnar.RowCodec: Encodes a batch with an empty topic name.
encode(VectorSchemaRoot) - Method in class io.krabka.streams.columnar.schema.AvroBatchCodec: Encodes a batch with an empty topic name.
encode(VectorSchemaRoot) - Method in class io.krabka.streams.columnar.schema.ProtobufBatchCodec: Encodes a batch with an empty topic name.
encodeKey(CoordinationKey) - Static method in class io.krabka.streams.coordination.CoordinationCodec: Encodes a record key.
encodeProtobuf(int, List, byte[]) - Static method in class io.krabka.streams.schema.ConfluentWireFormat: Frames Protobuf body bytes, including the message-index list.
encodeValue(CoordinationValue) - Static method in class io.krabka.streams.coordination.CoordinationCodec: Encodes a record value.
entry(MemberId) - Method in class io.krabka.streams.coordination.RoleState: Returns the roster entry of one member.
epoch() - Method in record class io.krabka.streams.columnar.barrier.BarrierCut: Returns the value of the epoch record component.
equals(Object) - Method in record class io.krabka.streams.columnar.Aggregation: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.columnar.barrier.BarrierAlignment: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.columnar.barrier.BarrierCut: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.columnar.ColumnarErrorPolicy: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.columnar.ColumnarJoin: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.columnar.ColumnarMetrics.Snapshot: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.columnar.ConsumedRecord: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.columnar.DerivedColumn: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.columnar.ProducedToTopic: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.columnar.ProduceRecord: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.columnar.RecordHeader: Compares headers by key and value content.
equals(Object) - Method in record class io.krabka.streams.coordination.CoordinationEntry: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.coordination.CoordinationKey: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.coordination.Decision: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in class io.krabka.streams.coordination.FencingToken: Reports whether another object is a token with the same pair.
equals(Object) - Method in record class io.krabka.streams.coordination.LeadershipStatus: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.coordination.Lease: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in class io.krabka.streams.coordination.LeaseConfig: Reports whether another object is a config with the same three extents.
equals(Object) - Method in class io.krabka.streams.coordination.MemberId: Reports whether another object is a member id with the same text.
equals(Object) - Method in record class io.krabka.streams.coordination.Registration: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in class io.krabka.streams.coordination.Role: Reports whether another object is a role with the same name.
equals(Object) - Method in class io.krabka.streams.coordination.RoleState: Reports whether another object is a state with the same roster and lease.
equals(Object) - Method in record class io.krabka.streams.coordination.RosterEntry: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.schema.ConfluentWireFormat.Frame: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.schema.ConfluentWireFormat.ProtobufFrame: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.FetchedSchema: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.RegisteredSchema: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.ResolvedSchema: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.SchemaReference: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.schema.LocalSchemaCompatibility.Result: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.krabka.streams.schema.SchemaCache.PrewarmReport: Indicates whether some other object is "equal to" this one.
evaluate(RoleState, MemberId, long, LeaseConfig) - Static method in class io.krabka.streams.coordination.Succession: Decides what one member does about a role at one instant.
Example - Section in class io.krabka.streams.KrabkaStreamsConfig
Example - Section in class io.krabka.streams.columnar.ArrowIpcSerde
Example - Section in class io.krabka.streams.columnar.ArrowValues
Example - Section in class io.krabka.streams.columnar.BlobCodec
Example - Section in class io.krabka.streams.columnar.BuiltColumnarTopology
Example - Section in class io.krabka.streams.columnar.BuiltinOp
Example - Section in class io.krabka.streams.columnar.ColumnarContext
Example - Section in class io.krabka.streams.columnar.ColumnarMetrics
Example - Section in class io.krabka.streams.columnar.ColumnarNode
Example - Section in class io.krabka.streams.columnar.ColumnarRunner
Example - Section in class io.krabka.streams.columnar.ColumnarTopology
Example - Section in class io.krabka.streams.columnar.FileColumnarStateStore
Example - Section in class io.krabka.streams.columnar.GzipBatchCodec
Example - Section in class io.krabka.streams.columnar.JsonRowBridge
Example - Section in class io.krabka.streams.columnar.RowCodec
Example - Section in class io.krabka.streams.columnar.barrier.BarrierCutDecoder
Example - Section in class io.krabka.streams.columnar.barrier.BarrierCutReader
Example - Section in class io.krabka.streams.columnar.schema.AvroArrowSchemas
Example - Section in class io.krabka.streams.columnar.schema.AvroBatchCodec
Example - Section in class io.krabka.streams.columnar.schema.AvroRowBridge
Example - Section in class io.krabka.streams.columnar.schema.ProtobufArrowSchemas
Example - Section in class io.krabka.streams.columnar.schema.ProtobufBatchCodec
Example - Section in class io.krabka.streams.columnar.schema.ProtobufRowBridge
Example - Section in class io.krabka.streams.coordination.CoordinationClient
Example - Section in class io.krabka.streams.coordination.CoordinationCodec
Example - Section in class io.krabka.streams.coordination.FencingToken
Example - Section in class io.krabka.streams.coordination.KafkaCoordinationTransport
Example - Section in class io.krabka.streams.coordination.Leadership
Example - Section in class io.krabka.streams.coordination.LeaseConfig
Example - Section in class io.krabka.streams.coordination.LeaseTiming
Example - Section in class io.krabka.streams.coordination.ManualClock
Example - Section in class io.krabka.streams.coordination.MemberId
Example - Section in class io.krabka.streams.coordination.Role
Example - Section in class io.krabka.streams.coordination.RolePartitioner
Example - Section in class io.krabka.streams.coordination.RoleState
Example - Section in class io.krabka.streams.coordination.RoleStateBuilder
Example - Section in class io.krabka.streams.coordination.Succession
Example - Section in class io.krabka.streams.schema.AvroSerde
Example - Section in class io.krabka.streams.schema.ConfluentWireFormat
Example - Section in class io.krabka.streams.schema.JsonSchemaSerde
Example - Section in class io.krabka.streams.schema.KrabkaSchemaRegistryClient
Example - Section in class io.krabka.streams.schema.LocalSchemaCompatibility
Example - Section in class io.krabka.streams.schema.ProtobufSerde
Example - Section in class io.krabka.streams.schema.SchemaCache
Example - Section in class io.krabka.streams.schema.TopicNameStrategy
Example - Section in class io.krabka.streams.test.ColumnarTestDriver
Example - Section in class io.krabka.streams.test.SchemaRegistryStub
Example - Section in enum class io.krabka.streams.columnar.AggregateFunction
Example - Section in enum class io.krabka.streams.columnar.barrier.BarrierCutStatus
Example - Section in enum class io.krabka.streams.coordination.Decision.Action
Example - Section in enum class io.krabka.streams.coordination.RecordKind
Example - Section in enum class io.krabka.streams.schema.RegisterMode
Example - Section in enum class io.krabka.streams.schema.Role
Example - Section in enum class io.krabka.streams.schema.SchemaKind
Example - Section in exception class io.krabka.streams.columnar.ColumnarException
Example - Section in exception class io.krabka.streams.coordination.CoordinationException
Example - Section in exception class io.krabka.streams.coordination.FencedException
Example - Section in exception class io.krabka.streams.schema.SchemaFetchPendingException
Example - Section in exception class io.krabka.streams.schema.SchemaRegistryException
Example - Section in interface io.krabka.streams.columnar.BatchCodec
Example - Section in interface io.krabka.streams.columnar.ColumnarProcessor
Example - Section in interface io.krabka.streams.columnar.ColumnarStateStore
Example - Section in interface io.krabka.streams.columnar.RowBridge
Example - Section in interface io.krabka.streams.columnar.RowPredicate
Example - Section in interface io.krabka.streams.columnar.RowValue
Example - Section in interface io.krabka.streams.columnar.StatefulColumnarProcessor
Example - Section in interface io.krabka.streams.columnar.barrier.BarrierListener
Example - Section in interface io.krabka.streams.coordination.Clock
Example - Section in interface io.krabka.streams.coordination.CoordinationTransport
Example - Section in interface io.krabka.streams.coordination.CoordinationValue
Example - Section in interface io.krabka.streams.schema.SubjectNameStrategy
Example - Section in package io.krabka.streams
Example - Section in package io.krabka.streams.columnar
Example - Section in package io.krabka.streams.columnar.barrier
Example - Section in package io.krabka.streams.coordination
Example - Section in package io.krabka.streams.schema
Example - Section in package io.krabka.streams.test
Example - Section in record class io.krabka.streams.columnar.Aggregation
Example - Section in record class io.krabka.streams.columnar.ColumnarErrorPolicy
Example - Section in record class io.krabka.streams.columnar.ColumnarJoin
Example - Section in record class io.krabka.streams.columnar.ConsumedRecord
Example - Section in record class io.krabka.streams.columnar.DerivedColumn
Example - Section in record class io.krabka.streams.columnar.ProduceRecord
Example - Section in record class io.krabka.streams.columnar.ProducedToTopic
Example - Section in record class io.krabka.streams.columnar.RecordHeader
Example - Section in record class io.krabka.streams.columnar.barrier.BarrierAlignment
Example - Section in record class io.krabka.streams.columnar.barrier.BarrierCut
Example - Section in record class io.krabka.streams.coordination.CoordinationEntry
Example - Section in record class io.krabka.streams.coordination.CoordinationKey
Example - Section in record class io.krabka.streams.coordination.Decision
Example - Section in record class io.krabka.streams.coordination.LeadershipStatus
Example - Section in record class io.krabka.streams.coordination.Lease
Example - Section in record class io.krabka.streams.coordination.Registration
Example - Section in record class io.krabka.streams.coordination.RosterEntry
expiresAtMillis() - Method in class io.krabka.streams.coordination.LeaseTiming: Returns the instant the lease expires.

F

fail() - Static method in record class io.krabka.streams.columnar.ColumnarErrorPolicy: Returns the policy that rethrows failures.
FAIL - Enum constant in enum class io.krabka.streams.columnar.ColumnarErrorPolicy.Action: Rethrow the failure; nothing is produced or committed.
failNext(RuntimeException) - Method in class io.krabka.streams.test.ColumnarTestDriver: Throws the supplied fault before the next batch evaluation, once.
failures() - Method in record class io.krabka.streams.columnar.ColumnarMetrics.Snapshot: Returns the value of the failures record component.
failures() - Method in record class io.krabka.streams.schema.SchemaCache.PrewarmReport: Returns the value of the failures record component.
FencedException - Exception Class in io.krabka.streams.coordination: Reports that the broker refused a write, because another member holds the role now.
FencedException(Role, Throwable) - Constructor for exception class io.krabka.streams.coordination.FencedException: Creates an exception for the role that this member no longer holds.
FencingToken - Class in io.krabka.streams.coordination: The quorum-minted proof that one member holds a role.
FetchedSchema(String, String) - Constructor for record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.FetchedSchema: Creates a fetched schema without references.
FetchedSchema(String, String, List) - Constructor for record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.FetchedSchema: Copies the reference list so the record is immutable.
field() - Method in record class io.krabka.streams.columnar.DerivedColumn: Returns the value of the field record component.
FileColumnarStateStore - Class in io.krabka.streams.columnar: Stores each partition snapshot in one atomically replaced local file.
FileColumnarStateStore(Path) - Constructor for class io.krabka.streams.columnar.FileColumnarStateStore: Creates a store rooted at a directory.
FileColumnarStateStore(Path, int) - Constructor for class io.krabka.streams.columnar.FileColumnarStateStore: Creates a store that keeps the newest retainedEpochs barrier snapshots per partition.
FileColumnarStateStore(Path, Duration) - Constructor for class io.krabka.streams.columnar.FileColumnarStateStore: Creates a store that keeps barrier snapshots newer than retainedFor.
filter(BufferAllocator, RowPredicate) - Static method in class io.krabka.streams.columnar.BuiltinOp: Creates an operator that keeps the rows a predicate accepts.
finish(VectorSchemaRoot) - Static method in class io.krabka.streams.columnar.ArrowValues: Sets every vector's value count to the batch's row count.
forKey(Class, SchemaCache) - Static method in class io.krabka.streams.schema.AvroSerde: Creates a key serde for a generated Avro class.
forKey(Class, SchemaCache, SubjectNameStrategy) - Static method in class io.krabka.streams.schema.AvroSerde: Creates a key serde for a generated Avro class with a custom subject strategy.
forKey(Class, String, SchemaCache, boolean) - Static method in class io.krabka.streams.schema.JsonSchemaSerde: Creates a key serde with a default Jackson mapper.
forKey(Class, String, SchemaCache, boolean, SpecificationVersion, SubjectNameStrategy, ObjectMapper) - Static method in class io.krabka.streams.schema.JsonSchemaSerde: Creates a fully configured key serde.
forKey(T, SchemaCache) - Static method in class io.krabka.streams.schema.ProtobufSerde: Creates a key serde for a generated Protobuf message.
forKey(T, SchemaCache, SubjectNameStrategy) - Static method in class io.krabka.streams.schema.ProtobufSerde: Creates a key serde with a custom subject strategy.
forSpecific(Class) - Static method in class io.krabka.streams.columnar.schema.AvroRowBridge: Creates a bridge for a generated Avro class.
forValue(Class, SchemaCache) - Static method in class io.krabka.streams.schema.AvroSerde: Creates a value serde for a generated Avro class.
forValue(Class, SchemaCache, SubjectNameStrategy) - Static method in class io.krabka.streams.schema.AvroSerde: Creates a value serde for a generated Avro class with a custom subject strategy.
forValue(Class, SchemaCache, BufferAllocator) - Static method in class io.krabka.streams.columnar.schema.AvroBatchCodec: Creates a codec for a generated Avro class.
forValue(Class, String, SchemaCache, boolean) - Static method in class io.krabka.streams.schema.JsonSchemaSerde: Creates a value serde with a default Jackson mapper.
forValue(Class, String, SchemaCache, boolean, ObjectMapper) - Static method in class io.krabka.streams.schema.JsonSchemaSerde: Creates a value serde with a caller-supplied Jackson mapper.
forValue(Class, String, SchemaCache, boolean, SpecificationVersion, SubjectNameStrategy, ObjectMapper) - Static method in class io.krabka.streams.schema.JsonSchemaSerde: Creates a fully configured value serde.
forValue(T, SchemaCache) - Static method in class io.krabka.streams.schema.ProtobufSerde: Creates a value serde for a generated Protobuf message.
forValue(T, SchemaCache, SubjectNameStrategy) - Static method in class io.krabka.streams.schema.ProtobufSerde: Creates a value serde with a custom subject strategy.
forward(VectorSchemaRoot) - Method in class io.krabka.streams.columnar.ColumnarContext: Forwards one batch to every downstream node.
FORWARD - Enum constant in enum class io.krabka.streams.schema.LocalSchemaCompatibility.Mode: Old readers must read data written with the candidate schema.
frame(int, byte[]) - Method in class io.krabka.streams.schema.AvroSerde: Wraps body bytes in the Confluent wire format.
frame(int, byte[]) - Method in class io.krabka.streams.schema.JsonSchemaSerde: Wraps body bytes in the Confluent wire format.
frame(int, byte[]) - Method in class io.krabka.streams.schema.ProtobufSerde
Frame(int, byte[]) - Constructor for record class io.krabka.streams.schema.ConfluentWireFormat.Frame: Copies the body so later mutation of the input array cannot change the frame.
fromCode(int) - Static method in enum class io.krabka.streams.columnar.barrier.BarrierCutStatus: Maps a wire code onto a status.
fromCode(short) - Static method in enum class io.krabka.streams.coordination.RecordKind: Maps a wire code onto a record kind.
fromJsonSchema(Class, String) - Static method in class io.krabka.streams.columnar.JsonRowBridge: Creates a bridge whose Arrow fields come from a JSON Schema instead of sample rows.
fromJsonSchema(Class, String, ObjectMapper) - Static method in class io.krabka.streams.columnar.JsonRowBridge: Creates a JSON Schema driven bridge with a caller-supplied Jackson mapper.
fromRecords(Role, Iterable) - Static method in class io.krabka.streams.coordination.RoleState: Folds the records of one role into a role state.
FULL - Enum constant in enum class io.krabka.streams.schema.LocalSchemaCompatibility.Mode: Both LocalSchemaCompatibility.Mode.BACKWARD and LocalSchemaCompatibility.Mode.FORWARD must hold.
function() - Method in record class io.krabka.streams.columnar.Aggregation: Returns the value of the function record component.

G

generic(Schema) - Static method in class io.krabka.streams.columnar.schema.AvroRowBridge: Creates a bridge for schema-driven GenericRecord values.
generic(Schema, SchemaCache, Role) - Static method in class io.krabka.streams.schema.AvroSerde: Creates a serde for schema-driven GenericRecord values.
generic(Schema, SchemaCache, Role, SubjectNameStrategy) - Static method in class io.krabka.streams.schema.AvroSerde: Creates a GenericRecord serde with a custom subject strategy.
generic(Schema, SchemaCache, BufferAllocator) - Static method in class io.krabka.streams.columnar.schema.AvroBatchCodec: Creates a codec for schema-driven GenericRecord values.
get(FieldVector, int) - Static method in class io.krabka.streams.columnar.ArrowValues: Reads one value from a vector as its natural Java representation.
grant(MemberId, FencingToken, long) - Method in class io.krabka.streams.coordination.LeaseConfig: Builds the lease record that a member writes after it mints a token.
grantedAt() - Method in record class io.krabka.streams.coordination.Lease: Returns the value of the grantedAt record component.
group() - Method in record class io.krabka.streams.columnar.barrier.BarrierAlignment: Returns the value of the group record component.
group() - Method in record class io.krabka.streams.columnar.barrier.BarrierCut: Returns the value of the group record component.
group(ColumnarTopology, Consumer, Producer) - Static method in class io.krabka.streams.columnar.ColumnarRunner: Creates an ephemeral, fail-fast group runner.
group(ColumnarTopology, Consumer, Producer, ColumnarErrorPolicy, ColumnarStateStore, ColumnarMetrics) - Static method in class io.krabka.streams.columnar.ColumnarRunner: Creates a group runner with explicit failure, snapshot, and metric handling.
group(ColumnarTopology, Consumer, Producer, ColumnarErrorPolicy, ColumnarStateStore, ColumnarMetrics, BarrierAlignment) - Static method in class io.krabka.streams.columnar.ColumnarRunner: Creates a group runner that aligns its work on a barrier group's cuts.
GROUP_PROTOCOL_CONFIG - Static variable in class io.krabka.streams.KrabkaStreamsConfig: The Kafka client configuration key that selects the group protocol.
groupBy(BufferAllocator, Collection, Aggregation...) - Static method in class io.krabka.streams.columnar.BuiltinOp: Creates a cumulative group-by operator.
GzipBatchCodec - Class in io.krabka.streams.columnar: Adds per-record GZIP compression to any batch codec.
GzipBatchCodec(BatchCodec) - Constructor for class io.krabka.streams.columnar.GzipBatchCodec: Wraps a codec with the 16777216-byte ceiling.
GzipBatchCodec(BatchCodec, int) - Constructor for class io.krabka.streams.columnar.GzipBatchCodec: Wraps a codec with an explicit decompression ceiling.

H

hashCode() - Method in record class io.krabka.streams.columnar.Aggregation: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.columnar.barrier.BarrierAlignment: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.columnar.barrier.BarrierCut: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.columnar.ColumnarErrorPolicy: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.columnar.ColumnarJoin: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.columnar.ColumnarMetrics.Snapshot: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.columnar.ConsumedRecord: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.columnar.DerivedColumn: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.columnar.ProducedToTopic: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.columnar.ProduceRecord: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.columnar.RecordHeader: Hashes the key and value content consistently with RecordHeader.equals(Object).
hashCode() - Method in record class io.krabka.streams.coordination.CoordinationEntry: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.coordination.CoordinationKey: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.coordination.Decision: Returns a hash code value for this object.
hashCode() - Method in class io.krabka.streams.coordination.FencingToken: Returns a hash of the pair.
hashCode() - Method in record class io.krabka.streams.coordination.LeadershipStatus: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.coordination.Lease: Returns a hash code value for this object.
hashCode() - Method in class io.krabka.streams.coordination.LeaseConfig: Returns a hash of the three extents.
hashCode() - Method in class io.krabka.streams.coordination.MemberId: Returns a hash of the member id.
hashCode() - Method in record class io.krabka.streams.coordination.Registration: Returns a hash code value for this object.
hashCode() - Method in class io.krabka.streams.coordination.Role: Returns a hash of the role name.
hashCode() - Method in class io.krabka.streams.coordination.RoleState: Returns a hash of the roster and the lease.
hashCode() - Method in record class io.krabka.streams.coordination.RosterEntry: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.schema.ConfluentWireFormat.Frame: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.schema.ConfluentWireFormat.ProtobufFrame: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.FetchedSchema: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.RegisteredSchema: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.ResolvedSchema: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.SchemaReference: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.schema.LocalSchemaCompatibility.Result: Returns a hash code value for this object.
hashCode() - Method in record class io.krabka.streams.schema.SchemaCache.PrewarmReport: Returns a hash code value for this object.
headers() - Method in record class io.krabka.streams.columnar.ConsumedRecord: Returns the value of the headers record component.
headers() - Method in record class io.krabka.streams.columnar.ProduceRecord: Returns the value of the headers record component.
HEADERS_COLUMN - Static variable in class io.krabka.streams.columnar.BlobCodec: The reserved column holding each row's encoded Kafka headers, __headers.
held() - Method in class io.krabka.streams.coordination.Leadership: Reports whether this handle still believes it holds the role.
held() - Method in record class io.krabka.streams.coordination.LeadershipStatus: Reports whether any member has ever taken the role.
hold() - Static method in record class io.krabka.streams.coordination.Decision: Returns the decision to keep the role.
HOLD - Enum constant in enum class io.krabka.streams.coordination.Decision.Action: This member holds the role and its lease is live.
holder() - Method in record class io.krabka.streams.coordination.LeadershipStatus: Returns the member the last lease record names.
holder() - Method in class io.krabka.streams.coordination.RoleState: Returns the member the lease names.

I

id() - Method in class io.krabka.streams.coordination.MemberId: Returns the member id.
id() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.RegisteredSchema: Returns the value of the id record component.
idForSubject(String) - Method in class io.krabka.streams.schema.SchemaCache: Returns the resolved schema ID for a subject, if prewarming has resolved it.
incompatibilities() - Method in record class io.krabka.streams.schema.LocalSchemaCompatibility.Result: Returns the value of the incompatibilities record component.
inputColumn() - Method in record class io.krabka.streams.columnar.Aggregation: Returns the value of the inputColumn record component.
inputRecords() - Method in record class io.krabka.streams.columnar.ColumnarMetrics.Snapshot: Returns the value of the inputRecords record component.
intern(String, SchemaKind, String, String) - Method in class io.krabka.streams.schema.SchemaCache: Adds a local schema to the next prewarm operation.
io.krabka.streams - package io.krabka.streams: Defaults and entry points for Apache Kafka Streams applications.
io.krabka.streams.columnar - package io.krabka.streams.columnar: Apache Arrow batch codecs, topology operators, runners, and state handling.
io.krabka.streams.columnar.barrier - package io.krabka.streams.columnar.barrier: Barrier-aligned, epoch-keyed state snapshots for columnar runners.
io.krabka.streams.columnar.schema - package io.krabka.streams.columnar.schema: Avro and Protobuf bridges into the Arrow columnar runtime.
io.krabka.streams.coordination - package io.krabka.streams.coordination: Leader election, leases, and fencing tokens for one role.
io.krabka.streams.schema - package io.krabka.streams.schema: Confluent-wire-compatible Avro, Protobuf, and JSON Schema serdes.
io.krabka.streams.test - package io.krabka.streams.test: In-memory columnar and schema-registry test helpers.
isOutputEmpty(String) - Method in class io.krabka.streams.test.ColumnarTestDriver: Returns whether a topic has no unread output.
isTombstone(byte[]) - Static method in class io.krabka.streams.coordination.CoordinationCodec: Reports whether a record value is a tombstone.

J

json(String, String, LocalSchemaCompatibility.Mode) - Static method in class io.krabka.streams.schema.LocalSchemaCompatibility: Checks two JSON Schemas for compatibility.
JSON - Enum constant in enum class io.krabka.streams.schema.SchemaKind: A JSON Schema document.
JsonRowBridge<T> - Class in io.krabka.streams.columnar: Converts JSON-compatible Java records to flat Arrow columns.
JsonRowBridge(Class) - Constructor for class io.krabka.streams.columnar.JsonRowBridge: Creates a bridge that infers its Arrow schema from the first non-empty batch.
JsonRowBridge(Class, ObjectMapper) - Constructor for class io.krabka.streams.columnar.JsonRowBridge: Creates a schema-inferring bridge with a caller-supplied Jackson mapper.
JsonRowBridge(Class, ObjectMapper, Schema) - Constructor for class io.krabka.streams.columnar.JsonRowBridge: Creates a bridge with an explicit Arrow schema and Jackson mapper.
JsonRowBridge(Class, Schema) - Constructor for class io.krabka.streams.columnar.JsonRowBridge: Creates a bridge with an explicit Arrow schema.
JsonSchemaSerde<T> - Class in io.krabka.streams.schema: A Kafka serde for Confluent-framed JSON Schema values.

K

KafkaCoordinationTransport - Class in io.krabka.streams.coordination: The CoordinationTransport that talks to a Kafka cluster.
KafkaCoordinationTransport(Admin, Producer, Function, Consumer) - Constructor for class io.krabka.streams.coordination.KafkaCoordinationTransport: Creates a transport with the default poll timeout.
KafkaCoordinationTransport(Admin, Producer, Function, Consumer, Duration) - Constructor for class io.krabka.streams.coordination.KafkaCoordinationTransport: Creates a transport.
key() - Method in record class io.krabka.streams.columnar.ConsumedRecord: Returns a copy of the record key.
key() - Method in record class io.krabka.streams.columnar.ProduceRecord: Returns a copy of the record key.
key() - Method in record class io.krabka.streams.columnar.RecordHeader: Returns the value of the key record component.
key() - Method in record class io.krabka.streams.coordination.CoordinationEntry: Returns the value of the key record component.
KEY - Enum constant in enum class io.krabka.streams.schema.Role: The schema describes the record key.
KEY_COLUMN - Static variable in class io.krabka.streams.columnar.BlobCodec: The reserved column holding each row's record key, __key.
kind() - Method in record class io.krabka.streams.coordination.CoordinationKey: Returns the value of the kind record component.
kind() - Method in interface io.krabka.streams.coordination.CoordinationValue: Returns the record kind whose key this value belongs under.
kind() - Method in record class io.krabka.streams.coordination.Lease: Returns the kind of the key that a lease sits under.
kind() - Method in record class io.krabka.streams.coordination.Registration: Returns the kind of the key that a registration sits under.
KrabkaSchemaRegistryClient - Class in io.krabka.streams.schema: A nonblocking client for the Confluent Schema Registry REST API.
KrabkaSchemaRegistryClient(URI) - Constructor for class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Creates a client with a default HTTP client, default mapper, and two retries.
KrabkaSchemaRegistryClient(URI, String, String) - Constructor for class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Creates a client that sends HTTP basic authentication with every request.
KrabkaSchemaRegistryClient(URI, HttpClient, ObjectMapper) - Constructor for class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Creates a client with caller-supplied HTTP client and mapper and two retries.
KrabkaSchemaRegistryClient(URI, HttpClient, ObjectMapper, int) - Constructor for class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Creates a client with an explicit retry budget.
KrabkaSchemaRegistryClient.FetchedSchema - Record Class in io.krabka.streams.schema: A schema fetched by ID, with unresolved references.
KrabkaSchemaRegistryClient.RegisteredSchema - Record Class in io.krabka.streams.schema: One registered version of a subject.
KrabkaSchemaRegistryClient.ResolvedSchema - Record Class in io.krabka.streams.schema: A schema fetched by ID with every transitive reference resolved to its text.
KrabkaSchemaRegistryClient.SchemaReference - Record Class in io.krabka.streams.schema: A reference from one schema to a version of another subject.
KrabkaStreamsConfig - Class in io.krabka.streams: Applies the client settings that a krabka streams group needs.

L

latest(String) - Method in class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Fetches the latest registered version of a subject.
latestCompleteCut(String) - Method in class io.krabka.streams.columnar.barrier.BarrierCutReader: Returns the newest complete cut of a barrier group.
latestId(String) - Method in class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Fetches the schema ID of a subject's latest version.
Leadership - Class in io.krabka.streams.coordination: The live leadership of one role by one member.
LeadershipStatus - Record Class in io.krabka.streams.coordination: What one role looks like to a third party right now.
LeadershipStatus(Role, FencingToken, RoleState) - Constructor for record class io.krabka.streams.coordination.LeadershipStatus: Rejects a null component.
lease() - Method in class io.krabka.streams.coordination.Leadership: Returns the last lease record this member wrote.
lease() - Method in record class io.krabka.streams.coordination.LeadershipStatus: Returns the last lease record of the role.
lease() - Method in class io.krabka.streams.coordination.LeaseTiming: Returns the lease record behind this clock.
lease() - Method in class io.krabka.streams.coordination.RoleState: Returns the lease of the role.
lease(Role) - Static method in record class io.krabka.streams.coordination.CoordinationKey: Builds the key of the lease of a role.
Lease - Record Class in io.krabka.streams.coordination: The member that holds a role now, and the time its claim ends.
Lease(MemberId, FencingToken, long, long) - Constructor for record class io.krabka.streams.coordination.Lease: Rejects a null member and a null token.
LEASE - Enum constant in enum class io.krabka.streams.coordination.RecordKind: One role names the member that holds it now.
LeaseConfig - Class in io.krabka.streams.coordination: The lease timings of one role.
LeaseTiming - Class in io.krabka.streams.coordination: The lease clock of one lease record under one policy.
LeaseTiming(Lease, LeaseConfig) - Constructor for class io.krabka.streams.coordination.LeaseTiming: Binds a lease record to a policy.
leftKey() - Method in record class io.krabka.streams.columnar.ColumnarJoin: Returns the value of the leftKey record component.
leftPrefix() - Method in record class io.krabka.streams.columnar.ColumnarJoin: Returns the value of the leftPrefix record component.
listener() - Method in record class io.krabka.streams.columnar.barrier.BarrierAlignment: Returns the value of the listener record component.
LIVE_EPOCH - Static variable in interface io.krabka.streams.columnar.ColumnarStateStore: The epoch of the running state, which no barrier cut owns.
liveAt(long) - Method in class io.krabka.streams.coordination.LeaseTiming: Reports whether the lease is live at one instant.
load(int, long) - Method in interface io.krabka.streams.columnar.ColumnarStateStore: Loads the stored snapshots for a partition and epoch.
load(int, long) - Method in class io.krabka.streams.columnar.FileColumnarStateStore: Loads a partition's snapshot file for an epoch.
LocalSchemaCompatibility - Class in io.krabka.streams.schema: Pairwise, network-free schema compatibility checks.
LocalSchemaCompatibility.Mode - Enum Class in io.krabka.streams.schema: The direction of a compatibility check, mirroring registry compatibility levels.
LocalSchemaCompatibility.Result - Record Class in io.krabka.streams.schema: The outcome of one compatibility check.
lookup(String, SchemaKind, String, String) - Method in class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Looks up the ID of an already registered schema without references.
lookup(String, SchemaKind, String, String, List) - Method in class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Looks up the ID of an already registered schema with schema references.
LOOKUP_ONLY - Enum constant in enum class io.krabka.streams.schema.RegisterMode: Looks the local schema up under the subject and fails prewarming when the registry does not already know it.

M

MAGIC - Static variable in class io.krabka.streams.schema.ConfluentWireFormat: The first byte of every Confluent-framed record.
ManualClock - Class in io.krabka.streams.coordination: A clock that a caller moves by hand.
ManualClock(long) - Constructor for class io.krabka.streams.coordination.ManualClock: Creates a clock that reads one instant.
MAX - Enum constant in enum class io.krabka.streams.columnar.AggregateFunction: Keeps the largest non-null input value, compared with Comparable.
MAX_LENGTH - Static variable in class io.krabka.streams.coordination.MemberId: The maximum length of a member id, in bytes.
MAX_LENGTH - Static variable in class io.krabka.streams.coordination.Role: The maximum length of a role name, in bytes.
member() - Method in record class io.krabka.streams.coordination.CoordinationKey: Returns the value of the member record component.
member() - Method in interface io.krabka.streams.coordination.CoordinationValue: Returns the member the value names.
member() - Method in class io.krabka.streams.coordination.Leadership: Returns the member that holds the role.
member() - Method in record class io.krabka.streams.coordination.Lease: Returns the value of the member record component.
member() - Method in record class io.krabka.streams.coordination.Registration: Returns the value of the member record component.
member() - Method in record class io.krabka.streams.coordination.RosterEntry: Returns the value of the member record component.
MemberId - Class in io.krabka.streams.coordination: The validated identity of one member that competes for a role.
messageIndexes() - Method in record class io.krabka.streams.schema.ConfluentWireFormat.ProtobufFrame: Returns the value of the messageIndexes record component.
messageType() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.FetchedSchema: Returns the value of the messageType record component.
messageType() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.RegisteredSchema: Returns the value of the messageType record component.
messageType() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.ResolvedSchema: Returns the value of the messageType record component.
metrics() - Method in class io.krabka.streams.columnar.ColumnarRunner.GroupRunner: Returns the counters this runner records observations to.
MIN - Enum constant in enum class io.krabka.streams.columnar.AggregateFunction: Keeps the smallest non-null input value, compared with Comparable.
minted() - Method in class io.krabka.streams.coordination.FencingToken: Reports whether this token names a minted leadership.
missing() - Method in record class io.krabka.streams.columnar.barrier.BarrierCut: Returns the value of the missing record component.

N

name() - Method in class io.krabka.streams.coordination.Role: Returns the role name.
name() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.SchemaReference: Returns the value of the name record component.
NO_EPOCH - Static variable in class io.krabka.streams.coordination.FencingToken: The token of a role that no member has ever taken.
none() - Static method in interface io.krabka.streams.columnar.barrier.BarrierListener: Returns a listener that does nothing.
none() - Static method in interface io.krabka.streams.columnar.ColumnarStateStore: Returns a store that keeps nothing.
NOT_REGISTERED - Enum constant in enum class io.krabka.streams.coordination.Decision.Action: This member is not in the roster of the role, so it has no rank.
notRegistered() - Static method in record class io.krabka.streams.coordination.Decision: Returns the decision to register first.
nowMillis() - Method in interface io.krabka.streams.coordination.Clock: Returns the current time.
nowMillis() - Method in class io.krabka.streams.coordination.ManualClock: Returns the instant the clock reads now.

O

of(long, short) - Static method in class io.krabka.streams.coordination.FencingToken: Builds a token from a minted producer id and producer epoch.
of(String) - Static method in class io.krabka.streams.coordination.MemberId: Parses a member id.
of(String) - Static method in class io.krabka.streams.coordination.Role: Parses a role name.
of(Duration, Duration, Duration) - Static method in class io.krabka.streams.coordination.LeaseConfig: Builds a lease policy from three extents.
of(T) - Static method in class io.krabka.streams.columnar.schema.ProtobufRowBridge: Creates a bridge for one message type.
of(T, SchemaCache, BufferAllocator) - Static method in class io.krabka.streams.columnar.schema.ProtobufBatchCodec: Creates a codec for one message type.
offset() - Method in record class io.krabka.streams.columnar.ConsumedRecord: Returns the value of the offset record component.
offset() - Method in record class io.krabka.streams.coordination.CoordinationEntry: Returns the value of the offset record component.
offset() - Method in record class io.krabka.streams.coordination.RosterEntry: Returns the value of the offset record component.
offset(TopicPartition) - Method in record class io.krabka.streams.columnar.barrier.BarrierCut: Returns a partition's marker offset.
OFFSET_COLUMN - Static variable in class io.krabka.streams.columnar.BlobCodec: The reserved column holding each row's source offset, __offset.
offsets() - Method in record class io.krabka.streams.columnar.barrier.BarrierCut: Returns the value of the offsets record component.
on(String, BarrierCutReader) - Static method in record class io.krabka.streams.columnar.barrier.BarrierAlignment: Creates an alignment with no listener.
onBarrier(BarrierCut) - Method in interface io.krabka.streams.columnar.barrier.BarrierListener: Reports that every assigned partition reached the cut.
One role uses two producers - Section in class io.krabka.streams.coordination.KafkaCoordinationTransport
onPartitionsAssigned(Collection) - Method in class io.krabka.streams.columnar.ColumnarRunner.GroupRunner: Restores newly assigned logical partitions from the state store.
onPartitionsLost(Collection) - Method in class io.krabka.streams.columnar.ColumnarRunner.GroupRunner: Releases lost logical partitions without saving their state.
onPartitionsRevoked(Collection) - Method in class io.krabka.streams.columnar.ColumnarRunner.GroupRunner: Saves and releases logical partitions the consumer is giving up.
outputColumn() - Method in record class io.krabka.streams.columnar.Aggregation: Returns the value of the outputColumn record component.
outputRecords() - Method in record class io.krabka.streams.columnar.ColumnarMetrics.Snapshot: Returns the value of the outputRecords record component.
outputSize(String) - Method in class io.krabka.streams.test.ColumnarTestDriver: Returns the number of unread records for a topic.
outputType() - Method in record class io.krabka.streams.columnar.Aggregation: Returns the value of the outputType record component.

P

parse(String) - Static method in class io.krabka.streams.coordination.FencingToken: Parses the producer_id:producer_epoch form that FencingToken.toString() writes.
PARTIAL - Enum constant in enum class io.krabka.streams.columnar.barrier.BarrierCutStatus: One or more partitions never received the epoch's marker.
partition() - Method in record class io.krabka.streams.columnar.ConsumedRecord: Returns the value of the partition record component.
PARTITION_COLUMN - Static variable in class io.krabka.streams.columnar.BlobCodec: The reserved column holding each row's source partition, __partition.
partitionFor(Role, int) - Static method in class io.krabka.streams.coordination.RolePartitioner: Returns the partition that holds every record of a role.
payloadColumn(String) - Static method in class io.krabka.streams.columnar.BlobCodec: Returns the in-batch name used when a payload column collides with metadata.
pendingCut() - Method in class io.krabka.streams.columnar.ColumnarRunner.GroupRunner: Returns the cut this runner is waiting for.
pipeBatch(String, List) - Method in class io.krabka.streams.test.ColumnarTestDriver: Runs one fetched partition batch through the topology.
pipeInput(String, int, byte[], byte[], long) - Method in class io.krabka.streams.test.ColumnarTestDriver: Runs one record through the topology.
pipeInput(String, int, byte[], byte[], long, List) - Method in class io.krabka.streams.test.ColumnarTestDriver: Runs one record, including immutable Kafka headers, through the topology.
prewarm() - Method in class io.krabka.streams.schema.SchemaCache: Resolves all interned subject IDs with the configured registration mode.
prewarmReport() - Method in class io.krabka.streams.schema.SchemaCache: Resolves every interned subject and reports successes and failures independently.
PrewarmReport(Map, Map) - Constructor for record class io.krabka.streams.schema.SchemaCache.PrewarmReport: Copies both maps so the report is immutable.
process(ColumnarContext, VectorSchemaRoot) - Method in class io.krabka.streams.columnar.BuiltinOp: Applies the operator and forwards exactly one output batch.
process(ColumnarContext, VectorSchemaRoot) - Method in interface io.krabka.streams.columnar.ColumnarProcessor: Processes one input batch.
processingNanos() - Method in record class io.krabka.streams.columnar.ColumnarMetrics.Snapshot: Returns the value of the processingNanos record component.
ProducedToTopic - Record Class in io.krabka.streams.columnar: Binds one produced record to its sink topic.
ProducedToTopic(String, ProduceRecord) - Constructor for record class io.krabka.streams.columnar.ProducedToTopic: Validates that both components are present.
ProduceRecord - Record Class in io.krabka.streams.columnar: One output record from a columnar sink.
ProduceRecord(byte[], byte[], long) - Constructor for record class io.krabka.streams.columnar.ProduceRecord: Creates a record without headers.
ProduceRecord(byte[], byte[], long, List) - Constructor for record class io.krabka.streams.columnar.ProduceRecord: Copies the mutable components so the record is immutable.
producerEpoch() - Method in class io.krabka.streams.coordination.FencingToken: Returns the producer epoch the transaction coordinator minted.
producerId() - Method in class io.krabka.streams.coordination.FencingToken: Returns the producer id the transaction coordinator minted.
protobuf(Descriptors.FileDescriptor, Descriptors.FileDescriptor, LocalSchemaCompatibility.Mode) - Static method in class io.krabka.streams.schema.LocalSchemaCompatibility: Checks two Protobuf file descriptors for compatibility.
PROTOBUF - Enum constant in enum class io.krabka.streams.schema.SchemaKind: A Protocol Buffers file descriptor rendered as .proto text.
ProtobufArrowSchemas - Class in io.krabka.streams.columnar.schema: Translates Protobuf message descriptors into Arrow schemas.
ProtobufBatchCodec - Class in io.krabka.streams.columnar.schema: Decodes registry-framed Protobuf topics into Arrow batches and encodes them back.
ProtobufFrame(int, List, byte[]) - Constructor for record class io.krabka.streams.schema.ConfluentWireFormat.ProtobufFrame: Copies the mutable components so the frame is immutable.
ProtobufRowBridge<T> - Class in io.krabka.streams.columnar.schema: Converts Protobuf messages to and from Arrow batches with descriptor-derived columns.
ProtobufSerde<T> - Class in io.krabka.streams.schema: A Kafka serde for Confluent-framed Protobuf messages.

R

Rank comes from the log - Section in package io.krabka.streams.coordination
Rank comes from the log, not from configuration - Section in class io.krabka.streams.coordination.Succession
rankOf(MemberId) - Method in class io.krabka.streams.coordination.RoleState: Returns the challenge rank of one member.
reached(TopicPartition, long) - Method in record class io.krabka.streams.columnar.barrier.BarrierCut: Reports whether a partition delivered everything below the cut.
reader() - Method in record class io.krabka.streams.columnar.barrier.BarrierAlignment: Returns the value of the reader record component.
readOutput(String) - Method in class io.krabka.streams.test.ColumnarTestDriver: Reads the next record or throws if the topic has no output.
readRoleRecords(Role) - Method in interface io.krabka.streams.coordination.CoordinationTransport: Reads the whole partition of a role and returns the records in offset order.
readRoleRecords(Role) - Method in class io.krabka.streams.coordination.KafkaCoordinationTransport: Reads the whole partition of a role and returns the records in offset order.
readState(Role) - Method in class io.krabka.streams.coordination.CoordinationClient: Reads and folds the coordination topic for one role.
record() - Method in record class io.krabka.streams.columnar.ProducedToTopic: Returns the value of the record record component.
RecordHeader - Record Class in io.krabka.streams.columnar: One immutable Kafka record header.
RecordHeader(String, byte[]) - Constructor for record class io.krabka.streams.columnar.RecordHeader: Copies the value so later mutation of the input array cannot change the header.
RecordKind - Enum Class in io.krabka.streams.coordination: Which record of CoordinationCodec.TOPIC a key names.
recordsBefore(TopicPartition, List) - Method in record class io.krabka.streams.columnar.barrier.BarrierCut: Returns the records of a partition that fall before the cut.
references() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.FetchedSchema: Returns the value of the references record component.
references() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.RegisteredSchema: Returns the value of the references record component.
references() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.ResolvedSchema: Returns the value of the references record component.
reflect(Class, SchemaCache, Role) - Static method in class io.krabka.streams.schema.AvroSerde: Creates a serde backed by Avro reflection for ordinary Java classes.
reflect(Class, SchemaCache, Role, SubjectNameStrategy) - Static method in class io.krabka.streams.schema.AvroSerde: Creates a reflection-based serde with a custom subject strategy.
register(Role, MemberId, long) - Method in interface io.krabka.streams.coordination.CoordinationTransport: Appends the registration of one member to the partition of a role.
register(Role, MemberId, long) - Method in class io.krabka.streams.coordination.KafkaCoordinationTransport: Appends the registration of one member to the partition of a role.
register(String, SchemaKind, String, String) - Method in class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Registers a schema under a subject without references.
register(String, SchemaKind, String, String, List) - Method in class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Registers a schema under a subject with schema references.
registeredAt() - Method in record class io.krabka.streams.coordination.Registration: Returns the value of the registeredAt record component.
registeredAt() - Method in record class io.krabka.streams.coordination.RosterEntry: Returns the value of the registeredAt record component.
RegisteredSchema(int, int, String, String, String) - Constructor for record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.RegisteredSchema: Creates a version without references.
RegisteredSchema(int, int, String, String, String, List) - Constructor for record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.RegisteredSchema: Copies the reference list so the record is immutable.
RegisterMode - Enum Class in io.krabka.streams.schema: Defines how prewarming resolves a schema ID.
registerSubject(String) - Method in class io.krabka.streams.columnar.schema.AvroBatchCodec: Interns the reader schema for a topic's value subject in the shared cache.
registerSubject(String) - Method in class io.krabka.streams.columnar.schema.ProtobufBatchCodec: Interns the message schema for a topic's value subject in the shared cache.
registerSubject(String) - Method in class io.krabka.streams.schema.AvroSerde: Adds this serde's subject to the cache prewarm set.
registerSubject(String) - Method in class io.krabka.streams.schema.JsonSchemaSerde: Adds this serde's subject to the cache prewarm set.
registerSubject(String) - Method in class io.krabka.streams.schema.ProtobufSerde: Adds this serde's subject to the cache prewarm set.
registration(Role, MemberId) - Static method in record class io.krabka.streams.coordination.CoordinationKey: Builds the key of the registration of one member of a role.
Registration - Record Class in io.krabka.streams.coordination: One member of a role announces that it is available.
Registration(MemberId, long) - Constructor for record class io.krabka.streams.coordination.Registration: Rejects a null member.
REGISTRATION - Enum constant in enum class io.krabka.streams.coordination.RecordKind: One member of a role announces that it is available.
releasePartition(int) - Method in class io.krabka.streams.columnar.BuiltColumnarTopology: Drops all processor state owned by a logical partition.
remainingAt(long) - Method in class io.krabka.streams.coordination.LeaseTiming: Returns the extent that is left before the deadline.
renew() - Method in class io.krabka.streams.coordination.Leadership: Writes a fresh lease record under the same token.
renewAtMillis() - Method in class io.krabka.streams.coordination.LeaseTiming: Returns the instant at which the holder writes its next renewal.
renewDue() - Method in class io.krabka.streams.coordination.Leadership: Reports whether the holder writes a renewal now.
renewDueAt(long) - Method in class io.krabka.streams.coordination.LeaseTiming: Reports whether the holder writes a renewal at one instant.
renewInterval() - Method in class io.krabka.streams.coordination.LeaseConfig: Returns the gap between two renewals by the holder.
renewsWithMargin() - Method in class io.krabka.streams.coordination.LeaseConfig: Reports whether the renew interval leaves the holder two spare attempts.
requestCount(String, String) - Method in class io.krabka.streams.test.SchemaRegistryStub: Returns how many requests the stub has served for a method and path.
resign() - Method in class io.krabka.streams.coordination.Leadership: Gives up the role and clears the lease record.
resolved() - Method in record class io.krabka.streams.schema.SchemaCache.PrewarmReport: Returns the value of the resolved record component.
ResolvedSchema(String, String, Map) - Constructor for record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.ResolvedSchema: Copies the reference map so the record is immutable.
resolvedSchemaById(int) - Method in class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Fetches a schema by ID and recursively resolves its references.
restore(byte[]) - Method in class io.krabka.streams.columnar.BuiltinOp: Replaces the operator's state with a previously taken snapshot.
restore(byte[]) - Method in interface io.krabka.streams.columnar.StatefulColumnarProcessor: Replaces the processor's state with a previously taken snapshot.
restorePartition(int, Map) - Method in class io.krabka.streams.columnar.BuiltColumnarTopology: Restores snapshots before processing the partition.
restoreToEpoch(long) - Method in class io.krabka.streams.columnar.ColumnarRunner.GroupRunner: Restores every owned partition to a barrier epoch and seeks the inputs to the cut.
restoreToLatestCut() - Method in class io.krabka.streams.columnar.ColumnarRunner.GroupRunner: Restores every owned partition to the newest complete cut of the group.
Result(boolean, List) - Constructor for record class io.krabka.streams.schema.LocalSchemaCompatibility.Result: Copies the message list so the result is immutable.
retain(long) - Method in interface io.krabka.streams.columnar.ColumnarStateStore: Prevents an epoch from being reclaimed while a restore is reading it.
retain(long) - Method in class io.krabka.streams.columnar.FileColumnarStateStore
retainedEpochs(int) - Method in interface io.krabka.streams.columnar.ColumnarStateStore: Lists the barrier epochs currently available for a partition.
retainedEpochs(int) - Method in class io.krabka.streams.columnar.FileColumnarStateStore
rightKey() - Method in record class io.krabka.streams.columnar.ColumnarJoin: Returns the value of the rightKey record component.
rightPrefix() - Method in record class io.krabka.streams.columnar.ColumnarJoin: Returns the value of the rightPrefix record component.
role() - Method in record class io.krabka.streams.coordination.CoordinationKey: Returns the value of the role record component.
role() - Method in exception class io.krabka.streams.coordination.FencedException: Returns the role that this member no longer holds.
role() - Method in class io.krabka.streams.coordination.Leadership: Returns the role this member holds.
role() - Method in record class io.krabka.streams.coordination.LeadershipStatus: Returns the value of the role record component.
role() - Method in class io.krabka.streams.coordination.RoleStateBuilder: Returns the role that this fold collects.
Role - Class in io.krabka.streams.coordination: The validated name of one coordination role, such as the name of an active controller.
Role - Enum Class in io.krabka.streams.schema: Identifies whether a schema belongs to a record key or value.
RolePartitioner - Class in io.krabka.streams.coordination: Computes the partition of CoordinationCodec.TOPIC that holds every record of one role.
RoleState - Class in io.krabka.streams.coordination: The state that a reader folds out of the records of one role.
RoleStateBuilder - Class in io.krabka.streams.coordination: Folds the records of one role into a RoleState.
RoleStateBuilder(Role) - Constructor for class io.krabka.streams.coordination.RoleStateBuilder: Creates an empty fold for one role.
roster() - Method in class io.krabka.streams.coordination.RoleState: Returns the candidates of the role, in registration order.
RosterEntry - Record Class in io.krabka.streams.coordination: One member of the roster of a role.
RosterEntry(MemberId, long, long) - Constructor for record class io.krabka.streams.coordination.RosterEntry: Rejects a null member.
RowBridge<T> - Interface in io.krabka.streams.columnar: Converts typed rows to and from an Arrow payload batch.
RowCodec<T> - Class in io.krabka.streams.columnar: Converts ordinary Kafka value records through a typed row bridge.
RowCodec(Serde, RowBridge, BufferAllocator) - Constructor for class io.krabka.streams.columnar.RowCodec: Creates a codec from a value serde and a row bridge.
RowPredicate - Interface in io.krabka.streams.columnar: Tests one row in an Arrow batch.
rowsToBatch(List, BufferAllocator) - Method in class io.krabka.streams.columnar.JsonRowBridge: Builds one Arrow batch with one row per value.
rowsToBatch(List, BufferAllocator) - Method in interface io.krabka.streams.columnar.RowBridge: Builds one Arrow batch with one row per value.
rowsToBatch(List, BufferAllocator) - Method in class io.krabka.streams.columnar.schema.AvroRowBridge: Builds one Arrow batch with one row per record.
rowsToBatch(List, BufferAllocator) - Method in class io.krabka.streams.columnar.schema.ProtobufRowBridge: Builds one Arrow batch with one row per message.
RowValue - Interface in io.krabka.streams.columnar: Computes one derived Arrow column value.
runBatch(String, List) - Method in class io.krabka.streams.columnar.BuiltColumnarTopology: Runs one source topic's records through the graph.
runBatches(Map) - Method in class io.krabka.streams.columnar.BuiltColumnarTopology: Runs records from multiple source topics as one graph evaluation, enabling fan-in.
runGroupOnce(BuiltColumnarTopology, Consumer, Producer, Duration) - Static method in class io.krabka.streams.columnar.ColumnarRunner: Polls and processes every partition assigned by the consumer group, then commits their offsets.
runGroupOnce(BuiltColumnarTopology, Consumer, Producer, Duration, ColumnarErrorPolicy, ColumnarMetrics) - Static method in class io.krabka.streams.columnar.ColumnarRunner: Polls and processes every assigned partition with explicit failure handling and metrics.
runGroupOnceTransactional(BuiltColumnarTopology, Consumer, Producer, Duration) - Static method in class io.krabka.streams.columnar.ColumnarRunner: Atomically produces a group poll and commits its consumed offsets in the producer transaction.
runGroupOnceTransactional(BuiltColumnarTopology, Consumer, Producer, Duration, ColumnarErrorPolicy, ColumnarMetrics) - Static method in class io.krabka.streams.columnar.ColumnarRunner: Runs one exactly-once cycle: output records and consumed offsets commit in one producer transaction.
runOnce(Duration) - Method in class io.krabka.streams.columnar.ColumnarRunner.GroupRunner: Runs one fetch, process, produce, and commit cycle.
runOnceTransactional(Duration) - Method in class io.krabka.streams.columnar.ColumnarRunner.GroupRunner: Runs one exactly-once cycle in a producer transaction.
runPartitionBatches(int, Map) - Method in class io.krabka.streams.columnar.BuiltColumnarTopology: Evaluates one co-partitioned set of source batches against isolated processor state.
runPartitionOnce(BuiltColumnarTopology, Consumer, Producer, String, int, long, Duration) - Static method in class io.krabka.streams.columnar.ColumnarRunner: Runs one fetch, process, produce, and commit cycle for one manually assigned partition.
runPartitionOnce(ColumnarTopology, Consumer, Producer, String, int, long, Duration) - Static method in class io.krabka.streams.columnar.ColumnarRunner: Builds the topology, runs one cycle for one partition, and discards the state.

S

save(int, long, Map) - Method in interface io.krabka.streams.columnar.ColumnarStateStore: Stores the snapshots for a partition and epoch, replacing what was stored before.
save(int, long, Map) - Method in class io.krabka.streams.columnar.FileColumnarStateStore: Saves a partition's snapshots for an epoch, replacing the previous file atomically.
schema() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.FetchedSchema: Returns the value of the schema record component.
schema() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.RegisteredSchema: Returns the value of the schema record component.
schema() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.ResolvedSchema: Returns the value of the schema record component.
schemaById(int) - Method in class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Fetches a schema by its global ID.
SchemaCache - Class in io.krabka.streams.schema: Stores schema IDs and writer schemas for synchronous serde operations.
SchemaCache(KrabkaSchemaRegistryClient) - Constructor for class io.krabka.streams.schema.SchemaCache: Creates a cache that auto-registers schemas and uses the topic naming rule.
SchemaCache(KrabkaSchemaRegistryClient, RegisterMode, SubjectNameStrategy) - Constructor for class io.krabka.streams.schema.SchemaCache: Creates a fully configured cache.
SchemaCache.PrewarmReport - Record Class in io.krabka.streams.schema: The per-subject outcome of SchemaCache.prewarmReport().
SchemaFetchPendingException - Exception Class in io.krabka.streams.schema: Signals that a background writer-schema fetch has not completed.
SchemaFetchPendingException(int) - Constructor for exception class io.krabka.streams.schema.SchemaFetchPendingException: Creates the exception for one pending schema ID.
schemaId() - Method in record class io.krabka.streams.schema.ConfluentWireFormat.Frame: Returns the value of the schemaId record component.
schemaId() - Method in record class io.krabka.streams.schema.ConfluentWireFormat.ProtobufFrame: Returns the value of the schemaId record component.
schemaId() - Method in exception class io.krabka.streams.schema.SchemaFetchPendingException: Returns the schema ID whose writer schema is being fetched.
SchemaKind - Enum Class in io.krabka.streams.schema: Schema formats supported by the registry client.
SchemaReference(String, String, int) - Constructor for record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.SchemaReference: Creates an instance of a SchemaReference record class.
SchemaRegistryException - Exception Class in io.krabka.streams.schema: Reports a schema registry transport, status, or response error.
SchemaRegistryException(int, String) - Constructor for exception class io.krabka.streams.schema.SchemaRegistryException: Creates an exception for a non-2xx registry response.
SchemaRegistryException(String) - Constructor for exception class io.krabka.streams.schema.SchemaRegistryException: Creates an exception for a malformed request or response.
SchemaRegistryException(String, Throwable) - Constructor for exception class io.krabka.streams.schema.SchemaRegistryException: Creates an exception for a transport or encoding failure.
SchemaRegistryStub - Class in io.krabka.streams.test: A small, stateful Confluent Schema Registry test server.
SchemaRegistryStub() - Constructor for class io.krabka.streams.test.SchemaRegistryStub: Starts the stub on an ephemeral loopback port.
schemaType() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.RegisteredSchema: Returns the value of the schemaType record component.
seedSubjectId(String, int) - Method in class io.krabka.streams.schema.SchemaCache: Adds a subject ID directly.
seedWriterMessageType(int, String) - Method in class io.krabka.streams.schema.SchemaCache: Adds Protobuf message metadata directly.
seedWriterReferences(int, Map) - Method in class io.krabka.streams.schema.SchemaCache: Adds referenced writer schemas directly.
seedWriterSchema(int, String) - Method in class io.krabka.streams.schema.SchemaCache: Adds a writer schema directly.
select(BufferAllocator, String...) - Static method in class io.krabka.streams.columnar.BuiltinOp: Creates an operator that projects the named payload columns.
sendAsync(List, Producer) - Static method in class io.krabka.streams.columnar.ColumnarRunner: Sends all records concurrently and completes when every broker acknowledgement arrives.
serializeBody(T) - Method in class io.krabka.streams.schema.AvroSerde
serializeBody(T) - Method in class io.krabka.streams.schema.JsonSchemaSerde
serializeBody(T) - Method in class io.krabka.streams.schema.ProtobufSerde
serializer() - Method in class io.krabka.streams.columnar.ArrowIpcSerde: Returns the serializer half of this serde.
serializer() - Method in class io.krabka.streams.schema.AvroSerde: Returns the serializer half of this serde.
serializer() - Method in class io.krabka.streams.schema.JsonSchemaSerde: Returns the serializer half of this serde.
serializer() - Method in class io.krabka.streams.schema.ProtobufSerde: Returns the serializer half of this serde.
set(long) - Method in class io.krabka.streams.coordination.ManualClock: Moves the clock to one instant.
set(FieldVector, int, Object) - Static method in class io.krabka.streams.columnar.ArrowValues: Writes one value into a vector, coercing it to the vector's Arrow type.
setCompatibility(String) - Method in class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Sets the registry's global compatibility level.
setCompatibility(String, String) - Method in class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Sets a subject's compatibility level.
skip() - Static method in record class io.krabka.streams.columnar.ColumnarErrorPolicy: Returns the policy that skips failed batches.
SKIP - Enum constant in enum class io.krabka.streams.columnar.ColumnarErrorPolicy.Action: Drop the batch's output and commit past it.
snapshot() - Method in class io.krabka.streams.columnar.BuiltinOp: Serializes the operator's state.
snapshot() - Method in class io.krabka.streams.columnar.ColumnarMetrics: Reads all counters into one immutable snapshot.
snapshot() - Method in interface io.krabka.streams.columnar.StatefulColumnarProcessor: Serializes the processor's current state.
Snapshot(long, long, long, long, long, long) - Constructor for record class io.krabka.streams.columnar.ColumnarMetrics.Snapshot: Creates an instance of a Snapshot record class.
snapshotPartition(int) - Method in class io.krabka.streams.columnar.BuiltColumnarTopology: Returns snapshots keyed by operator name for one logical partition.
sourceTopics() - Method in class io.krabka.streams.columnar.ColumnarTopology: Returns every topic consumed by the topology's sources.
state() - Method in record class io.krabka.streams.coordination.LeadershipStatus: Returns the value of the state record component.
StatefulColumnarProcessor - Interface in io.krabka.streams.columnar: A processor whose partition-local state can be snapshotted and restored.
status() - Method in record class io.krabka.streams.columnar.barrier.BarrierCut: Returns the value of the status record component.
statusCode() - Method in exception class io.krabka.streams.schema.SchemaRegistryException: Returns the HTTP status, or -1 for a transport or parsing error.
STREAMS_GROUP_PROTOCOL - Static variable in class io.krabka.streams.KrabkaStreamsConfig: The group.protocol value that enables the streams group protocol.
subject() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.SchemaReference: Returns the value of the subject record component.
subject(String, Role) - Method in class io.krabka.streams.schema.SchemaCache: Maps a topic and role to a subject with the cache's default strategy.
subject(String, Role) - Method in interface io.krabka.streams.schema.SubjectNameStrategy: Returns the registry subject for a topic and role.
subject(String, Role) - Method in class io.krabka.streams.schema.TopicNameStrategy: Returns <topic>-key or <topic>-value depending on the role.
subject(String, Role, SubjectNameStrategy) - Method in class io.krabka.streams.schema.SchemaCache: Maps a topic and role to a subject with an explicit strategy.
SubjectNameStrategy - Interface in io.krabka.streams.schema: Maps a topic and record role to a schema registry subject.
subjects() - Method in class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Lists all subject names.
subscribe(ColumnarTopology, Consumer) - Static method in class io.krabka.streams.columnar.ColumnarRunner: Subscribes a group-managed consumer to every source topic in the topology.
successful() - Method in record class io.krabka.streams.schema.SchemaCache.PrewarmReport: Returns whether every subject resolved.
Succession - Class in io.krabka.streams.coordination: The succession rules of one role: ordered candidates, and no failback.
SUM - Enum constant in enum class io.krabka.streams.columnar.AggregateFunction: Sums the non-null input values.
supersedes(FencingToken) - Method in class io.krabka.streams.coordination.FencingToken: Reports whether this token ranks above another one.
system() - Static method in interface io.krabka.streams.coordination.Clock: Returns the clock of the host.

T

test(VectorSchemaRoot, int) - Method in interface io.krabka.streams.columnar.RowPredicate: Decides whether a row is kept.
The epoch is the safety mechanism - Section in class io.krabka.streams.coordination.Succession
The epoch is the safety mechanism and the lease is not - Section in package io.krabka.streams.coordination
The fencing token is a pair - Section in package io.krabka.streams.coordination
The layers - Section in package io.krabka.streams.coordination
The read is committed - Section in class io.krabka.streams.coordination.KafkaCoordinationTransport
The stagger is an optimisation - Section in class io.krabka.streams.coordination.Succession
The transactional producer is the epoch - Section in class io.krabka.streams.coordination.KafkaCoordinationTransport
timestamp() - Method in record class io.krabka.streams.columnar.ConsumedRecord: Returns the value of the timestamp record component.
timestamp() - Method in record class io.krabka.streams.columnar.ProduceRecord: Returns the value of the timestamp record component.
TIMESTAMP_COLUMN - Static variable in class io.krabka.streams.columnar.BlobCodec: The reserved column holding each row's record timestamp, __timestamp.
timing() - Method in class io.krabka.streams.coordination.Leadership: Returns the lease clock of the current lease.
timing(Lease) - Method in class io.krabka.streams.coordination.LeaseConfig: Binds a lease record to this policy and answers the clock questions about it.
toArrowField(Descriptors.FieldDescriptor) - Static method in class io.krabka.streams.columnar.schema.ProtobufArrowSchemas: Translates one message field into one Arrow field.
toArrowField(String, Schema) - Static method in class io.krabka.streams.columnar.schema.AvroArrowSchemas: Translates one Avro schema into one Arrow field.
toArrowSchema(Descriptors.Descriptor) - Static method in class io.krabka.streams.columnar.schema.ProtobufArrowSchemas: Translates a message descriptor into the Arrow schema its batches use.
toArrowSchema(Schema) - Static method in class io.krabka.streams.columnar.schema.AvroArrowSchemas: Translates an Avro schema into the Arrow schema its batches use.
token() - Method in class io.krabka.streams.coordination.Leadership: Returns the quorum-minted proof of this leadership.
token() - Method in record class io.krabka.streams.coordination.LeadershipStatus: Returns the value of the token record component.
token() - Method in record class io.krabka.streams.coordination.Lease: Returns the value of the token record component.
topic() - Method in record class io.krabka.streams.columnar.ProducedToTopic: Returns the value of the topic record component.
TOPIC - Static variable in class io.krabka.streams.columnar.barrier.BarrierCutDecoder: The internal topic the coordinator publishes barrier state to.
TOPIC - Static variable in class io.krabka.streams.coordination.CoordinationCodec: The compacted internal topic that holds the coordination state of a cluster.
TopicNameStrategy - Class in io.krabka.streams.schema: Uses the Confluent topic naming rule.
TopicNameStrategy() - Constructor for class io.krabka.streams.schema.TopicNameStrategy: Creates the strategy; it is stateless and reusable.
toString() - Method in record class io.krabka.streams.columnar.Aggregation: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.columnar.barrier.BarrierAlignment: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.columnar.barrier.BarrierCut: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.columnar.ColumnarErrorPolicy: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.columnar.ColumnarJoin: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.columnar.ColumnarMetrics.Snapshot: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.columnar.ConsumedRecord: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.columnar.DerivedColumn: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.columnar.ProducedToTopic: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.columnar.ProduceRecord: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.columnar.RecordHeader: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.coordination.CoordinationEntry: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.coordination.CoordinationKey: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.coordination.Decision: Returns a string representation of this record class.
toString() - Method in class io.krabka.streams.coordination.FencingToken: Returns the producer_id:producer_epoch form.
toString() - Method in record class io.krabka.streams.coordination.LeadershipStatus: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.coordination.Lease: Returns a string representation of this record class.
toString() - Method in class io.krabka.streams.coordination.LeaseConfig: Returns the three extents in milliseconds.
toString() - Method in class io.krabka.streams.coordination.MemberId: Returns the member id.
toString() - Method in record class io.krabka.streams.coordination.Registration: Returns a string representation of this record class.
toString() - Method in class io.krabka.streams.coordination.Role: Returns the role name.
toString() - Method in class io.krabka.streams.coordination.RoleState: Returns the roster and the lease.
toString() - Method in record class io.krabka.streams.coordination.RosterEntry: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.schema.ConfluentWireFormat.Frame: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.schema.ConfluentWireFormat.ProtobufFrame: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.FetchedSchema: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.RegisteredSchema: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.ResolvedSchema: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.SchemaReference: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.schema.LocalSchemaCompatibility.Result: Returns a string representation of this record class.
toString() - Method in record class io.krabka.streams.schema.SchemaCache.PrewarmReport: Returns a string representation of this record class.
triggeredAt() - Method in record class io.krabka.streams.columnar.barrier.BarrierCut: Returns the value of the triggeredAt record component.
tryAcquire(Role, MemberId) - Method in class io.krabka.streams.coordination.CoordinationClient: Runs one election pass for one member.

U

unframe(byte[]) - Method in class io.krabka.streams.schema.AvroSerde: Splits framed record bytes into the schema ID and body.
unframe(byte[]) - Method in class io.krabka.streams.schema.JsonSchemaSerde: Splits framed record bytes into the schema ID and body.
unframe(byte[]) - Method in class io.krabka.streams.schema.ProtobufSerde
uri() - Method in class io.krabka.streams.test.SchemaRegistryStub: Returns the base URI clients should connect to.
USE_LATEST - Enum constant in enum class io.krabka.streams.schema.RegisterMode: Uses the latest registered version of the subject regardless of the local schema text.

V

validate() - Method in class io.krabka.streams.columnar.ColumnarTopology: Checks the graph without building it.
value() - Method in record class io.krabka.streams.columnar.ConsumedRecord: Returns a copy of the record value.
value() - Method in record class io.krabka.streams.columnar.DerivedColumn: Returns the value of the value record component.
value() - Method in record class io.krabka.streams.columnar.ProduceRecord: Returns a copy of the record value.
value() - Method in record class io.krabka.streams.columnar.RecordHeader: Returns a copy of the header value.
value() - Method in record class io.krabka.streams.coordination.CoordinationEntry: Returns the value of the value record component.
value(VectorSchemaRoot, int) - Method in interface io.krabka.streams.columnar.RowValue: Computes the derived value for one row.
VALUE - Enum constant in enum class io.krabka.streams.schema.Role: The schema describes the record value.
valueOf(String) - Static method in enum class io.krabka.streams.columnar.AggregateFunction: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.krabka.streams.columnar.barrier.BarrierCutStatus: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.krabka.streams.columnar.ColumnarErrorPolicy.Action: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.krabka.streams.coordination.Decision.Action: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.krabka.streams.coordination.RecordKind: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.krabka.streams.schema.LocalSchemaCompatibility.Mode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.krabka.streams.schema.RegisterMode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.krabka.streams.schema.Role: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.krabka.streams.schema.SchemaKind: Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.krabka.streams.columnar.AggregateFunction: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.krabka.streams.columnar.barrier.BarrierCutStatus: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.krabka.streams.columnar.ColumnarErrorPolicy.Action: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.krabka.streams.coordination.Decision.Action: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.krabka.streams.coordination.RecordKind: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.krabka.streams.schema.LocalSchemaCompatibility.Mode: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.krabka.streams.schema.RegisterMode: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.krabka.streams.schema.Role: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.krabka.streams.schema.SchemaKind: Returns an array containing the constants of this enum class, in the order they are declared.
version() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.RegisteredSchema: Returns the value of the version record component.
version() - Method in record class io.krabka.streams.schema.KrabkaSchemaRegistryClient.SchemaReference: Returns the value of the version record component.
version(String, int) - Method in class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Fetches one specific version of a subject.
versions(String) - Method in class io.krabka.streams.schema.KrabkaSchemaRegistryClient: Lists a subject's version numbers.

W

WAIT - Enum constant in enum class io.krabka.streams.coordination.Decision.Action: This member waits, and then it evaluates the role state again.
waitUntil(long) - Static method in record class io.krabka.streams.coordination.Decision: Returns the decision to wait until one instant.
waitUntilMillis() - Method in record class io.krabka.streams.coordination.Decision: Returns the value of the waitUntilMillis record component.
Which calls carry authority - Section in interface io.krabka.streams.coordination.CoordinationTransport
window() - Method in record class io.krabka.streams.columnar.ColumnarJoin: Returns the value of the window record component.
WINDOW_END_COLUMN - Static variable in class io.krabka.streams.columnar.BuiltinOp: The window end column added by BuiltinOp.windowedGroupBy(BufferAllocator, Collection, Duration, Aggregation...), epoch milliseconds.
WINDOW_START_COLUMN - Static variable in class io.krabka.streams.columnar.BuiltinOp: The window start column added by BuiltinOp.windowedGroupBy(BufferAllocator, Collection, Duration, Aggregation...), epoch milliseconds.
windowedGroupBy(BufferAllocator, Collection, Duration, Aggregation...) - Static method in class io.krabka.streams.columnar.BuiltinOp: Groups cumulatively into fixed event-time windows using the Kafka timestamp column.
windowedGroupBy(BufferAllocator, Collection, Duration, Duration, Aggregation...) - Static method in class io.krabka.streams.columnar.BuiltinOp: Groups into fixed event-time windows and retains closed windows for the supplied duration.
withColumns(BufferAllocator, DerivedColumn...) - Static method in class io.krabka.streams.columnar.BuiltinOp: Creates an operator that adds or replaces derived columns.
withDefaults(Map) - Static method in class io.krabka.streams.KrabkaStreamsConfig: Copies the supplied settings and adds krabka defaults.
withListener(BarrierListener) - Method in record class io.krabka.streams.columnar.barrier.BarrierAlignment: Returns a copy of this alignment with another listener.
writeLease(Role, FencingToken, Lease) - Method in interface io.krabka.streams.coordination.CoordinationTransport: Writes the lease of a role in a transaction under one token.
writeLease(Role, FencingToken, Lease) - Method in class io.krabka.streams.coordination.KafkaCoordinationTransport: Writes the lease of a role in a transaction under one token.
writerMessageType(int) - Method in class io.krabka.streams.schema.SchemaCache: Returns the cached Protobuf message full name for a schema ID.
writerReferences(int) - Method in class io.krabka.streams.schema.SchemaCache: Returns the cached referenced schemas for a schema ID.
writerSchema(int) - Method in class io.krabka.streams.schema.SchemaCache: Returns a cached writer schema.

A B C D E F G H I J K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form