bulk-cdk-core-extract/io.airbyte.cdk.read/StateManager/StateManagerScopedToFeed

StateManagerScopedToFeed

interface StateManagerScopedToFeed

Properties

Link copied to clipboard
abstract val feed: Feed

The Feed to which the StateManager is scoped in this instance of StateManagerScopedToFeed.

Functions

Link copied to clipboard
abstract fun current(): OpaqueStateValue?

Returns the current state value in the StateManager for this feed.

Link copied to clipboard
abstract fun reset()

Resets the current state value in the StateManager for this feed to zero.

Link copied to clipboard
abstract fun set(state: OpaqueStateValue, numRecords: Long, partitionId: String?, id: Int?)

Updates the current state value in the StateManager for this feed.