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

StateReconciler

@Singleton
class StateReconciler(stateStore: StateStore, emittedStatsStore: EmittedStatsStore, consumer: OutputConsumer, @Named(value = "stateReconcilerScope") scope: CoroutineScope, @Named(value = "stateReconcilerInterval") interval: Duration?)

At an interval it checks for any complete states and flushes them to the platform.

Constructors

Link copied to clipboard
constructor(stateStore: StateStore, emittedStatsStore: EmittedStatsStore, consumer: OutputConsumer, @Named(value = "stateReconcilerScope") scope: CoroutineScope, @Named(value = "stateReconcilerInterval") interval: Duration?)

Functions

Link copied to clipboard
suspend fun disable()
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
fun publish(msg: AirbyteMessage)
Link copied to clipboard
fun run()