From 29367f3336f9fbbc2f021506faae76aa06911c41 Mon Sep 17 00:00:00 2001 From: Wenqi Hu Date: Sun, 2 Feb 2025 15:41:46 -0800 Subject: [PATCH] [source volcano] Allow field to be used as CDC cursor --- .../main/kotlin/io/airbyte/cdk/discover/MetaFieldDecorator.kt | 2 +- .../airbyte/cdk/load/write/BasicFunctionalityIntegrationTest.kt | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/airbyte-cdk/bulk/core/extract/src/main/kotlin/io/airbyte/cdk/discover/MetaFieldDecorator.kt b/airbyte-cdk/bulk/core/extract/src/main/kotlin/io/airbyte/cdk/discover/MetaFieldDecorator.kt index ca7ab028687aa..def480d35fb50 100644 --- a/airbyte-cdk/bulk/core/extract/src/main/kotlin/io/airbyte/cdk/discover/MetaFieldDecorator.kt +++ b/airbyte-cdk/bulk/core/extract/src/main/kotlin/io/airbyte/cdk/discover/MetaFieldDecorator.kt @@ -14,7 +14,7 @@ import java.time.OffsetDateTime interface MetaFieldDecorator { /** [MetaField] to use as a global cursor, if applicable. */ - val globalCursor: MetaField? + val globalCursor: FieldOrMetaField? /** * All [MetaField]s to be found in [Global] stream records. diff --git a/airbyte-cdk/bulk/core/load/src/testFixtures/kotlin/io/airbyte/cdk/load/write/BasicFunctionalityIntegrationTest.kt b/airbyte-cdk/bulk/core/load/src/testFixtures/kotlin/io/airbyte/cdk/load/write/BasicFunctionalityIntegrationTest.kt index 8c5ee55c913ec..3906709d2915e 100644 --- a/airbyte-cdk/bulk/core/load/src/testFixtures/kotlin/io/airbyte/cdk/load/write/BasicFunctionalityIntegrationTest.kt +++ b/airbyte-cdk/bulk/core/load/src/testFixtures/kotlin/io/airbyte/cdk/load/write/BasicFunctionalityIntegrationTest.kt @@ -143,7 +143,7 @@ enum class UnionBehavior { abstract class BasicFunctionalityIntegrationTest( /** The config to pass into the connector, as a serialized JSON blob */ - configContents: String, + val configContents: String, val configSpecClass: Class, dataDumper: DestinationDataDumper, destinationCleaner: DestinationCleaner,