Airbyte Kotlin Bulk CDK

1.0.2

bulk-cdk-toolkit-legacy-task-load-db/io.airbyte.cdk.load.orchestration.db.legacy_typing_deduping/RawTableInitialStatus

RawTableInitialStatus

data class RawTableInitialStatus(val hasUnprocessedRecords: Boolean, val maxProcessedTimestamp: Instant?)

Constructors

RawTableInitialStatus

constructor(hasUnprocessedRecords: Boolean, maxProcessedTimestamp: Instant?)

Types

object Companion

Properties

hasUnprocessedRecords

val hasUnprocessedRecords: Boolean

Whether there were any records with null _airbyte_loaded_at, at the time that this status was fetched.

maxProcessedTimestamp

val maxProcessedTimestamp: Instant?

The highest timestamp such that all records in SELECT * FROM raw_table WHERE _airbyte_extracted_at <= ? have a nonnull _airbyte_loaded_at.

Functions

fun RawTableInitialStatus?.reify(): RawTableInitialStatus

Many callers need to do a create table if not exists. This is a utility method to update the initial status accordingly - i.e. if the table already existed, retain its status; otherwise, use the empty table status.