bulk-cdk-core-load/io.airbyte.cdk.load.message/Meta/Companion

Companion

object Companion(source)

Properties

AIRBYTE_META_CHANGES

const val AIRBYTE_META_CHANGES: String

AIRBYTE_META_SYNC_ID

const val AIRBYTE_META_SYNC_ID: String

CHECKPOINT_ID_NAME

const val CHECKPOINT_ID_NAME: String

CHECKPOINT_INDEX_NAME

const val CHECKPOINT_INDEX_NAME: String

COLUMN_NAME_AB_EXTRACTED_AT

const val COLUMN_NAME_AB_EXTRACTED_AT: String

COLUMN_NAME_AB_GENERATION_ID

const val COLUMN_NAME_AB_GENERATION_ID: String

COLUMN_NAME_AB_LOADED_AT

const val COLUMN_NAME_AB_LOADED_AT: String

A legacy column name. Destinations with "typing and deduping" used this in the raw tables to indicate when a record went through T+D.

COLUMN_NAME_AB_META

const val COLUMN_NAME_AB_META: String

COLUMN_NAME_AB_RAW_ID

const val COLUMN_NAME_AB_RAW_ID: String

COLUMN_NAME_DATA

const val COLUMN_NAME_DATA: String

val COLUMN_NAMES: Set<String>

Functions

fun getEmittedAtMs(emittedAtMs: Long, extractedAtAsTimestampWithTimezone: Boolean): AirbyteValue

fun getMetaValue(metaColumnName: String, value: String): AirbyteValue