jprdonnelly/airbyte
1
0
Fork 0
mirror of synced 2025-12-25 02:09:19 -05:00
Code Issues Packages Projects Releases Wiki Activity

[source volcano] Decorate stream with cursor field for trigger based CDC stream (#53152)

Browse Source
This commit is contained in:
Wenqi Hu
2025-02-12 12:31:22 -08:00
committed by GitHub
parent ddd9e0dcc0
commit f0a96b3c1c
10 changed files with 162 additions and 59 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
airbyte-integrations/connectors/source-mysql/src/test/kotlin/io/airbyte/integrations/source/mysql/MySqlSourceCdcIntegrationTest.kt
View File

@@ -123,7 +123,12 @@ class MySqlSourceCdcIntegrationTest {
columns = listOf(Field("k", IntFieldType), Field("v", StringFieldType)),
primaryKeyColumnIDs = listOf(listOf("k")),
)
val stream: AirbyteStream = MySqlSourceOperations().createGlobal(discoveredStream)
val stream: AirbyteStream =
MySqlSourceOperations()
.create(
MySqlSourceConfigurationFactory().make(config()),
discoveredStream,
)
val configuredStream: ConfiguredAirbyteStream =
CatalogHelpers.toDefaultConfiguredStream(stream)
.withSyncMode(SyncMode.INCREMENTAL)

7
airbyte-integrations/connectors/source-mysql/src/test/kotlin/io/airbyte/integrations/source/mysql/MySqlSourceCursorBasedIntegrationTest.kt
View File

@@ -196,7 +196,12 @@ class MySqlSourceCursorBasedIntegrationTest {
columns = listOf(Field("k", IntFieldType), Field("v", StringFieldType)),
primaryKeyColumnIDs = listOf(listOf("k")),
)
val stream: AirbyteStream = MySqlSourceOperations().createGlobal(discoveredStream)
val stream: AirbyteStream =
MySqlSourceOperations()
.create(
MySqlSourceConfigurationFactory().make(config),
discoveredStream,
)
val configuredStream: ConfiguredAirbyteStream =
CatalogHelpers.toDefaultConfiguredStream(stream)
.withSyncMode(SyncMode.INCREMENTAL)