bulk-cdk-toolkit-extract-trigger/io.airbyte.cdk/TriggerStreamStateValue/Companion

Companion

object Companion

Properties

Link copied to clipboard
val snapshotCompleted: OpaqueStateValue

Empty json representing the completion of a FULL_REFRESH snapshot.

Functions

Link copied to clipboard
fun cursorIncrementalCheckpoint(cursor: Field, cursorCheckpoint: JsonNode): OpaqueStateValue

Value representing the progress of an ongoing incremental cursor read.

Link copied to clipboard
fun snapshotCheckpoint(primaryKey: List<Field>, primaryKeyCheckpoint: List<JsonNode>): OpaqueStateValue

Value representing the progress of an ongoing snapshot not involving cursor columns.

Link copied to clipboard
fun snapshotWithCursorCheckpoint(primaryKey: List<Field>, primaryKeyCheckpoint: List<JsonNode>, cursor: Field, cursorUpperBound: JsonNode): OpaqueStateValue

Value representing the progress of an ongoing snapshot involving cursor columns.