Skip to content

Commit 408261f

Browse files
authored
Increase method visibility level for Teradata. (#49858)
Increase the visibility on these functions to unblock Teradata's current implementation.
1 parent a99bc69 commit 408261f

File tree

4 files changed

+8
-6
lines changed

4 files changed

+8
-6
lines changed

airbyte-cdk/java/airbyte-cdk/README.md

+2-1
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,8 @@ corresponds to that version.
174174

175175
| Version | Date | Pull Request | Subject |
176176
|:-----------|:-----------|:------------------------------------------------------------|:---------------------------------------------------------------------------------------------------------------------------------------------------------------|
177-
| 0.48.1 | 2024-11-13 | [\#48482](https://github.com/airbytehq/airbyte/pull/48482) | Adding support converting very large numbers via BigInteger l |
177+
| 0.48.3 | 2024-12-23 | [\#49858](https://github.com/airbytehq/airbyte/pull/49858) | Relax various Destination CDK methods visibility. |
178+
| 0.48.1 | 2024-11-13 | [\#48482](https://github.com/airbytehq/airbyte/pull/48482) | Adding support converting very large numbers via BigInteger |
178179
| 0.48.0 | 2024-10-23 | [\#46302](https://github.com/airbytehq/airbyte/pull/46302) | Add support for file transfer |
179180
| 0.47.3 | 2024-10-23 | [\#46689](https://github.com/airbytehq/airbyte/pull/46689) | Split DestinationAcceptanceTest |
180181
| 0.47.2 | 2024-10-21 | [\#47216](https://github.com/airbytehq/airbyte/pull/47216) | improve java compatibiilty |
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
version=0.48.2
1+
version=0.48.3

airbyte-cdk/java/airbyte-cdk/db-destinations/src/main/kotlin/io/airbyte/cdk/integrations/destination/jdbc/typing_deduping/JdbcDestinationHandler.kt

+3-2
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ abstract class JdbcDestinationHandler<DestinationState>(
7474
): ResultSet = dbmetadata.getTables(catalogName, id.rawNamespace, id.rawName + suffix, null)
7575

7676
@Throws(Exception::class)
77-
private fun isFinalTableEmpty(id: StreamId): Boolean {
77+
protected open fun isFinalTableEmpty(id: StreamId): Boolean {
7878
return !jdbcDatabase.queryBoolean(
7979
dslContext
8080
.select(
@@ -211,7 +211,8 @@ abstract class JdbcDestinationHandler<DestinationState>(
211211
}
212212

213213
@Throws(SQLException::class)
214-
protected fun getAllDestinationStates(): Map<AirbyteStreamNameNamespacePair, DestinationState> {
214+
protected open fun getAllDestinationStates():
215+
Map<AirbyteStreamNameNamespacePair, DestinationState> {
215216
try {
216217
// Guarantee the table exists.
217218
jdbcDatabase.execute(

airbyte-cdk/java/airbyte-cdk/db-destinations/src/main/kotlin/io/airbyte/cdk/integrations/destination/jdbc/typing_deduping/JdbcSqlGenerator.kt

+2-2
Original file line numberDiff line numberDiff line change
@@ -403,7 +403,7 @@ constructor(
403403
.columns(buildFinalTableFields(columns, metaFields))
404404
}
405405

406-
private fun insertAndDeleteTransaction(
406+
protected open fun insertAndDeleteTransaction(
407407
streamConfig: StreamConfig,
408408
finalSuffix: String?,
409409
minRawTimestamp: Optional<Instant>,
@@ -507,7 +507,7 @@ constructor(
507507
return createSchemaSql.sql
508508
}
509509

510-
protected fun createTableSql(
510+
protected open fun createTableSql(
511511
namespace: String,
512512
tableName: String,
513513
columns: LinkedHashMap<ColumnId, AirbyteType>

0 commit comments

Comments
 (0)