Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-core-load/io.airbyte.cdk.load.dataflow.state.stats/StateStatsEnricher

StateStatsEnricher

@Singleton

class StateStatsEnricher(statsStore: CommittedStatsStore, namespaceMapper: NamespaceMapper, stateAdditionalStatsStore: StateAdditionalStatsStore)

Decorates states with destination stats — both top level and per stream.

Constructors

StateStatsEnricher

constructor(statsStore: CommittedStatsStore, namespaceMapper: NamespaceMapper, stateAdditionalStatsStore: StateAdditionalStatsStore)

Functions

fun enrich(msg: CheckpointMessage, key: StateKey): CheckpointMessage

enrichGlobalState

fun enrichGlobalState(msg: CheckpointMessage, key: StateKey): CheckpointMessage

enrichStreamState

fun enrichStreamState(msg: StreamCheckpoint, key: StateKey): CheckpointMessage

enrichTopLevelDestinationStats

fun enrichTopLevelDestinationStats(msg: CheckpointMessage, desc: DestinationStream.Descriptor, partitionKeys: List<PartitionKey>, count: Long): CheckpointMessage

enrichTopLevelDestinationStatsGlobalState

fun enrichTopLevelDestinationStatsGlobalState(msg: CheckpointMessage, count: Long): CheckpointMessage

enrichTopLevelStats

fun enrichTopLevelStats(msg: CheckpointMessage, stats: EmissionStats): CheckpointMessage