bulk-cdk-core-load/io.airbyte.cdk.load.dataflow.state/InferredStateKeyClient

InferredStateKeyClient

@Singleton

@Requires(property = "airbyte.destination.core.data-channel.medium", value = "STDIO")

class InferredStateKeyClient(catalog: DestinationCatalog) : StateKeyClient

Calculates state / partition keys based off per stream counters. For per-stream state, partitions are 1:1 with state messages. For global states, each state has a partition for each stream.

Only for use for single threaded input streams.

Constructors

InferredStateKeyClient

constructor(catalog: DestinationCatalog)

Functions

getPartitionKey

open override fun getPartitionKey(msg: DestinationRecordRaw): PartitionKey

getStateKey

open override fun getStateKey(msg: CheckpointMessage): StateKey