Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[S3-data-lake] Remove/Rename all occurences of iceberg.v2 #51012

Merged
merged 9 commits into from
Jan 9, 2025
Merged

[S3-data-lake] Remove/Rename all occurences of iceberg.v2 #51012

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
5c7a79e
Remove/Rename all occurences of iceberg.v2
frifriSF59 Jan 9, 2025
62c1bea
Some weird changes?
frifriSF59 Jan 9, 2025
3135b6d
Forgot some I guess
frifriSF59 Jan 9, 2025
513d4d7
And update the ones that were not caught by the rename action
frifriSF59 Jan 9, 2025
8672207
And more
frifriSF59 Jan 9, 2025
3d3011e
chore: auto-fix lint and format issues
octavia-squidington-iii Jan 9, 2025
e917690
Version change
frifriSF59 Jan 9, 2025
05813dc
Update entry point for the destination
frifriSF59 Jan 9, 2025
2aba828
Change name of IcebergDestination to S3DataLakeDestination. Same thin…
frifriSF59 Jan 9, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion airbyte-integrations/connectors/destination-s3-data-lake/build.gradle
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ airbyteBulkConnector {
}

application {
mainClass = 'io.airbyte.integrations.destination.iceberg.v2.IcebergDestination'
mainClass = 'io.airbyte.integrations.destination.s3_data_lake.S3DataLakeDestination'

applicationDefaultJvmArgs = ['-XX:+ExitOnOutOfMemoryError', '-XX:MaxRAMPercentage=75.0']

Expand Down
2 changes: 1 addition & 1 deletion airbyte-integrations/connectors/destination-s3-data-lake/metadata.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ data:
alias: airbyte-connector-testing-secret-store
connectorType: destination
definitionId: 716ca874-520b-4902-9f80-9fad66754b89
dockerImageTag: 0.2.7
dockerImageTag: 0.2.8
dockerRepository: airbyte/destination-s3-data-lake
documentationUrl: https://docs.airbyte.com/integrations/destinations/s3-data-lake
githubIssueLabel: destination-s3-data-lake
Expand Down
2 changes: 1 addition & 1 deletion ...on/iceberg/v2/io/BaseDeltaTaskWriter.java → .../s3_data_lake/io/BaseDeltaTaskWriter.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2.io;
package io.airbyte.integrations.destination.s3_data_lake.io;

import java.io.IOException;
import java.util.Set;
Expand Down
2 changes: 1 addition & 1 deletion ...ion/iceberg/v2/GlueCredentialsProvider.kt → ...n/s3_data_lake/GlueCredentialsProvider.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2
package io.airbyte.integrations.destination.s3_data_lake

import software.amazon.awssdk.auth.credentials.AwsBasicCredentials
import software.amazon.awssdk.auth.credentials.AwsCredentials
Expand Down
4 changes: 2 additions & 2 deletions ...tination/iceberg/v2/IcebergDestination.kt → ...nation/s3_data_lake/IcebergDestination.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,11 +2,11 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2
package io.airbyte.integrations.destination.s3_data_lake

import io.airbyte.cdk.AirbyteDestinationRunner

object IcebergDestination {
object S3DataLakeDestination {
@JvmStatic
fun main(args: Array<String>) {
AirbyteDestinationRunner.run(*args)
Expand Down
8 changes: 4 additions & 4 deletions ...ination/iceberg/v2/IcebergStreamLoader.kt → ...ation/s3_data_lake/IcebergStreamLoader.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2
package io.airbyte.integrations.destination.s3_data_lake

import edu.umd.cs.findbugs.annotations.SuppressFBWarnings
import io.airbyte.cdk.load.command.DestinationStream
Expand All @@ -12,9 +12,9 @@ import io.airbyte.cdk.load.message.DestinationRecordAirbyteValue
import io.airbyte.cdk.load.message.SimpleBatch
import io.airbyte.cdk.load.state.StreamProcessingFailed
import io.airbyte.cdk.load.write.StreamLoader
import io.airbyte.integrations.destination.iceberg.v2.io.IcebergTableCleaner
import io.airbyte.integrations.destination.iceberg.v2.io.IcebergTableWriterFactory
import io.airbyte.integrations.destination.iceberg.v2.io.IcebergUtil
import io.airbyte.integrations.destination.s3_data_lake.io.IcebergTableCleaner
import io.airbyte.integrations.destination.s3_data_lake.io.IcebergTableWriterFactory
import io.airbyte.integrations.destination.s3_data_lake.io.IcebergUtil
import io.github.oshai.kotlinlogging.KotlinLogging
import org.apache.iceberg.Table

Expand Down
6 changes: 3 additions & 3 deletions ...estination/iceberg/v2/IcebergV2Checker.kt → ...tination/s3_data_lake/IcebergV2Checker.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,12 +2,12 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2
package io.airbyte.integrations.destination.s3_data_lake

import io.airbyte.cdk.load.check.DestinationChecker
import io.airbyte.cdk.load.command.DestinationStream
import io.airbyte.integrations.destination.iceberg.v2.io.IcebergTableCleaner
import io.airbyte.integrations.destination.iceberg.v2.io.IcebergUtil
import io.airbyte.integrations.destination.s3_data_lake.io.IcebergTableCleaner
import io.airbyte.integrations.destination.s3_data_lake.io.IcebergUtil
import javax.inject.Singleton
import org.apache.iceberg.Schema
import org.apache.iceberg.types.Types
Expand Down
2 changes: 1 addition & 1 deletion ...tion/iceberg/v2/IcebergV2Configuration.kt → ...on/s3_data_lake/IcebergV2Configuration.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2
package io.airbyte.integrations.destination.s3_data_lake

import io.airbyte.cdk.load.command.DestinationConfiguration
import io.airbyte.cdk.load.command.DestinationConfigurationFactory
Expand Down
2 changes: 1 addition & 1 deletion ...tion/iceberg/v2/IcebergV2Specification.kt → ...on/s3_data_lake/IcebergV2Specification.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2
package io.airbyte.integrations.destination.s3_data_lake

import com.fasterxml.jackson.annotation.JsonPropertyDescription
import com.kjetland.jackson.jsonSchema.annotations.JsonSchemaInject
Expand Down
6 changes: 3 additions & 3 deletions ...destination/iceberg/v2/IcebergV2Writer.kt → ...stination/s3_data_lake/IcebergV2Writer.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,14 +2,14 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2
package io.airbyte.integrations.destination.s3_data_lake

import io.airbyte.cdk.load.command.DestinationStream
import io.airbyte.cdk.load.data.iceberg.parquet.IcebergParquetPipelineFactory
import io.airbyte.cdk.load.write.DestinationWriter
import io.airbyte.cdk.load.write.StreamLoader
import io.airbyte.integrations.destination.iceberg.v2.io.IcebergTableWriterFactory
import io.airbyte.integrations.destination.iceberg.v2.io.IcebergUtil
import io.airbyte.integrations.destination.s3_data_lake.io.IcebergTableWriterFactory
import io.airbyte.integrations.destination.s3_data_lake.io.IcebergUtil
import javax.inject.Singleton
import org.apache.iceberg.Schema

Expand Down
2 changes: 1 addition & 1 deletion ...estination/iceberg/v2/TableIdGenerator.kt → ...tination/s3_data_lake/TableIdGenerator.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2
package io.airbyte.integrations.destination.s3_data_lake

import io.airbyte.cdk.load.command.DestinationStream
import io.airbyte.cdk.load.command.iceberg.parquet.GlueCatalogConfiguration
Expand Down
2 changes: 1 addition & 1 deletion ...tion/iceberg/v2/io/IcebergTableCleaner.kt → ...on/s3_data_lake/io/IcebergTableCleaner.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2.io
package io.airbyte.integrations.destination.s3_data_lake.io

import jakarta.inject.Singleton
import org.apache.iceberg.Table
Expand Down
2 changes: 1 addition & 1 deletion ...ceberg/v2/io/IcebergTableWriterFactory.kt → ...data_lake/io/IcebergTableWriterFactory.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2.io
package io.airbyte.integrations.destination.s3_data_lake.io

import io.airbyte.cdk.load.command.Append
import io.airbyte.cdk.load.command.Dedupe
Expand Down
12 changes: 6 additions & 6 deletions .../destination/iceberg/v2/io/IcebergUtil.kt → ...estination/s3_data_lake/io/IcebergUtil.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2.io
package io.airbyte.integrations.destination.s3_data_lake.io

import com.fasterxml.jackson.annotation.JsonProperty
import io.airbyte.cdk.load.command.Dedupe
Expand All @@ -18,11 +18,11 @@ import io.airbyte.cdk.load.data.iceberg.parquet.toIcebergRecord
import io.airbyte.cdk.load.data.iceberg.parquet.toIcebergSchema
import io.airbyte.cdk.load.data.withAirbyteMeta
import io.airbyte.cdk.load.message.DestinationRecordAirbyteValue
import io.airbyte.integrations.destination.iceberg.v2.ACCESS_KEY_ID
import io.airbyte.integrations.destination.iceberg.v2.GlueCredentialsProvider
import io.airbyte.integrations.destination.iceberg.v2.IcebergV2Configuration
import io.airbyte.integrations.destination.iceberg.v2.SECRET_ACCESS_KEY
import io.airbyte.integrations.destination.iceberg.v2.TableIdGenerator
import io.airbyte.integrations.destination.s3_data_lake.ACCESS_KEY_ID
import io.airbyte.integrations.destination.s3_data_lake.GlueCredentialsProvider
import io.airbyte.integrations.destination.s3_data_lake.IcebergV2Configuration
import io.airbyte.integrations.destination.s3_data_lake.SECRET_ACCESS_KEY
import io.airbyte.integrations.destination.s3_data_lake.TableIdGenerator
import io.github.oshai.kotlinlogging.KotlinLogging
import jakarta.inject.Singleton
import java.time.Duration
Expand Down
2 changes: 1 addition & 1 deletion ...ns/destination/iceberg/v2/io/Operation.kt → .../destination/s3_data_lake/io/Operation.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2.io
package io.airbyte.integrations.destination.s3_data_lake.io

/** Delta operations for data. */
enum class Operation {
Expand Down
2 changes: 1 addition & 1 deletion ...ation/iceberg/v2/io/PartitionedWriters.kt → ...ion/s3_data_lake/io/PartitionedWriters.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2.io
package io.airbyte.integrations.destination.s3_data_lake.io

import java.io.IOException
import java.io.UncheckedIOException
Expand Down
2 changes: 1 addition & 1 deletion ...estination/iceberg/v2/io/RecordWrapper.kt → ...tination/s3_data_lake/io/RecordWrapper.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2.io
package io.airbyte.integrations.destination.s3_data_lake.io

import org.apache.iceberg.data.Record

Expand Down
4 changes: 2 additions & 2 deletions ...ion/iceberg/v2/io/UnpartitionedWriters.kt → ...n/s3_data_lake/io/UnpartitionedWriters.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2.io
package io.airbyte.integrations.destination.s3_data_lake.io

import org.apache.iceberg.FileFormat
import org.apache.iceberg.PartitionSpec
Expand Down Expand Up @@ -40,7 +40,7 @@ class UnpartitionedDeltaWriter(

private val writer = RowDataDeltaWriter(null)

override fun route(row: Record): RowDataDeltaWriter {
override fun route(row: Record): BaseDeltaTaskWriter.RowDataDeltaWriter {
return writer
}

Expand Down
8 changes: 4 additions & 4 deletions ...n/iceberg/v2/IcebergDestinationCleaner.kt → ...s3_data_lake/IcebergDestinationCleaner.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,18 +2,18 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2
package io.airbyte.integrations.destination.s3_data_lake

import io.airbyte.cdk.load.test.util.DestinationCleaner
import io.airbyte.cdk.load.test.util.IntegrationTest.Companion.isNamespaceOld
import io.airbyte.cdk.load.test.util.IntegrationTest.Companion.randomizedNamespaceRegex
import io.airbyte.integrations.destination.iceberg.v2.io.IcebergTableCleaner
import io.airbyte.integrations.destination.iceberg.v2.io.IcebergUtil
import io.airbyte.integrations.destination.s3_data_lake.io.IcebergTableCleaner
import io.airbyte.integrations.destination.s3_data_lake.io.IcebergUtil
import org.apache.iceberg.catalog.Catalog
import org.apache.iceberg.catalog.Namespace
import org.apache.iceberg.catalog.SupportsNamespaces

class IcebergDestinationCleaner(private val catalog: Catalog) : DestinationCleaner {
class S3DataLakeDestinationCleaner(private val catalog: Catalog) : DestinationCleaner {
override fun cleanup() {
val namespaces: List<Namespace> =
(catalog as SupportsNamespaces).listNamespaces().filter {
Expand Down
2 changes: 1 addition & 1 deletion ...iceberg/v2/IcebergExpectedRecordMapper.kt → ..._data_lake/IcebergExpectedRecordMapper.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2
package io.airbyte.integrations.destination.s3_data_lake

import io.airbyte.cdk.load.data.AirbyteType
import io.airbyte.cdk.load.data.AirbyteValue
Expand Down
4 changes: 2 additions & 2 deletions ...tination/iceberg/v2/IcebergV2CheckTest.kt → ...nation/s3_data_lake/IcebergV2CheckTest.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,11 +2,11 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2
package io.airbyte.integrations.destination.s3_data_lake

import io.airbyte.cdk.load.check.CheckIntegrationTest
import io.airbyte.cdk.load.check.CheckTestConfig
import io.airbyte.integrations.destination.iceberg.v2.IcebergV2TestUtil.GLUE_CONFIG_PATH
import io.airbyte.integrations.destination.s3_data_lake.IcebergV2TestUtil.GLUE_CONFIG_PATH

class IcebergV2CheckTest :
CheckIntegrationTest<IcebergV2Specification>(
Expand Down
2 changes: 1 addition & 1 deletion ...ination/iceberg/v2/IcebergV2DataDumper.kt → ...ation/s3_data_lake/IcebergV2DataDumper.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2
package io.airbyte.integrations.destination.s3_data_lake

import io.airbyte.cdk.command.ConfigurationSpecification
import io.airbyte.cdk.load.command.DestinationStream
Expand Down
2 changes: 1 addition & 1 deletion ...stination/iceberg/v2/IcebergV2SpecTest.kt → ...ination/s3_data_lake/IcebergV2SpecTest.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2
package io.airbyte.integrations.destination.s3_data_lake

import io.airbyte.cdk.load.spec.SpecTest

Expand Down
6 changes: 3 additions & 3 deletions ...stination/iceberg/v2/IcebergV2TestUtil.kt → ...ination/s3_data_lake/IcebergV2TestUtil.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,14 +2,14 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2
package io.airbyte.integrations.destination.s3_data_lake

import com.fasterxml.jackson.core.type.TypeReference
import io.airbyte.cdk.command.ConfigurationSpecification
import io.airbyte.cdk.command.ValidatedJsonUtils
import io.airbyte.cdk.load.util.Jsons
import io.airbyte.integrations.destination.iceberg.v2.io.AWSSystemCredentials
import io.airbyte.integrations.destination.iceberg.v2.io.IcebergUtil
import io.airbyte.integrations.destination.s3_data_lake.io.AWSSystemCredentials
import io.airbyte.integrations.destination.s3_data_lake.io.IcebergUtil
import java.nio.file.Files
import java.nio.file.Path

Expand Down
6 changes: 3 additions & 3 deletions ...tination/iceberg/v2/IcebergV2WriteTest.kt → ...nation/s3_data_lake/IcebergV2WriteTest.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2
package io.airbyte.integrations.destination.s3_data_lake

import com.fasterxml.jackson.databind.JsonNode
import com.fasterxml.jackson.databind.ObjectMapper
Expand Down Expand Up @@ -86,7 +86,7 @@ abstract class IcebergV2WriteTest(
class IcebergGlueWriteTest :
IcebergV2WriteTest(
Files.readString(IcebergV2TestUtil.GLUE_CONFIG_PATH),
IcebergDestinationCleaner(
S3DataLakeDestinationCleaner(
IcebergV2TestUtil.getCatalog(
IcebergV2TestUtil.parseConfig(IcebergV2TestUtil.GLUE_CONFIG_PATH),
IcebergV2TestUtil.getAWSSystemCredentials()
Expand All @@ -97,7 +97,7 @@ class IcebergGlueWriteTest :
class IcebergGlueAssumeRoleWriteTest :
IcebergV2WriteTest(
Files.readString(IcebergV2TestUtil.GLUE_ASSUME_ROLE_CONFIG_PATH),
IcebergDestinationCleaner(
S3DataLakeDestinationCleaner(
IcebergV2TestUtil.getCatalog(
IcebergV2TestUtil.parseConfig(IcebergV2TestUtil.GLUE_ASSUME_ROLE_CONFIG_PATH),
IcebergV2TestUtil.getAWSSystemCredentials()
Expand Down
2 changes: 1 addition & 1 deletion ...nation/iceberg/v2/NessieTestContainers.kt → ...tion/s3_data_lake/NessieTestContainers.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2
package io.airbyte.integrations.destination.s3_data_lake

import io.airbyte.cdk.load.util.setOnce
import java.io.File
Expand Down
6 changes: 3 additions & 3 deletions ...ination/iceberg/v2/IcebergV2WriterTest.kt → ...ation/s3_data_lake/IcebergV2WriterTest.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2
package io.airbyte.integrations.destination.s3_data_lake

import io.airbyte.cdk.load.command.Append
import io.airbyte.cdk.load.command.Dedupe
Expand All @@ -23,8 +23,8 @@ import io.airbyte.cdk.load.message.Meta.Companion.COLUMN_NAME_AB_EXTRACTED_AT
import io.airbyte.cdk.load.message.Meta.Companion.COLUMN_NAME_AB_GENERATION_ID
import io.airbyte.cdk.load.message.Meta.Companion.COLUMN_NAME_AB_META
import io.airbyte.cdk.load.message.Meta.Companion.COLUMN_NAME_AB_RAW_ID
import io.airbyte.integrations.destination.iceberg.v2.io.IcebergTableWriterFactory
import io.airbyte.integrations.destination.iceberg.v2.io.IcebergUtil
import io.airbyte.integrations.destination.s3_data_lake.io.IcebergTableWriterFactory
import io.airbyte.integrations.destination.s3_data_lake.io.IcebergUtil
import io.mockk.every
import io.mockk.mockk
import org.apache.iceberg.Schema
Expand Down
4 changes: 2 additions & 2 deletions .../iceberg/v2/io/BaseDeltaTaskWriterTest.kt → ...3_data_lake/io/BaseDeltaTaskWriterTest.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,9 +2,9 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2.io
package io.airbyte.integrations.destination.s3_data_lake.io

import io.airbyte.integrations.destination.iceberg.v2.io.BaseDeltaTaskWriter.RowDataDeltaWriter
import io.airbyte.integrations.destination.s3_data_lake.io.BaseDeltaTaskWriter.RowDataDeltaWriter
import io.mockk.every
import io.mockk.mockk
import io.mockk.verify
Expand Down
2 changes: 1 addition & 1 deletion .../iceberg/v2/io/IcebergTableCleanerTest.kt → ...3_data_lake/io/IcebergTableCleanerTest.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2.io
package io.airbyte.integrations.destination.s3_data_lake.io

import io.mockk.Runs
import io.mockk.called
Expand Down
2 changes: 1 addition & 1 deletion ...rg/v2/io/IcebergTableWriterFactoryTest.kt → ..._lake/io/IcebergTableWriterFactoryTest.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
* Copyright (c) 2024 Airbyte, Inc., all rights reserved.
*/

package io.airbyte.integrations.destination.iceberg.v2.io
package io.airbyte.integrations.destination.s3_data_lake.io

import io.airbyte.cdk.load.command.Append
import io.airbyte.cdk.load.command.Dedupe
Expand Down
Loading
Loading