Airbyte Kotlin Bulk CDK

0.1.92

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

StateStore

@Singleton

class StateStore(keyClient: StateKeyClient, histogramStore: StateHistogramStore, stateStatsEnricher: StateStatsEnricher)

Constructors

constructor(keyClient: StateKeyClient, histogramStore: StateHistogramStore, stateStatsEnricher: StateStatsEnricher)

Functions

fun accept(msg: CheckpointMessage)

getNextComplete

fun getNextComplete(): CheckpointMessage?

fun hasStates(): Boolean

fun logStateInfo()