bulk-cdk-core-base/io.airbyte.cdk.command/GlobalInputState

GlobalInputState

data class GlobalInputState(val global: OpaqueStateValue, val globalStreams: Map<StreamIdentifier, OpaqueStateValue>, val nonGlobalStreams: Map<StreamIdentifier, OpaqueStateValue>) : InputState

Constructors

Link copied to clipboard
constructor(global: OpaqueStateValue, globalStreams: Map<StreamIdentifier, OpaqueStateValue>, nonGlobalStreams: Map<StreamIdentifier, OpaqueStateValue>)

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
val nonGlobalStreams: Map<StreamIdentifier, OpaqueStateValue>

Conceivably, some streams may undergo a full refresh alongside independently of the rest.