This is an automated email from the ASF dual-hosted git repository.
jinsongzhou pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/amoro.git
The following commit(s) were added to refs/heads/master by this push:
new 183c2d803 Change package name for module mixed-format/trino (#2745)
183c2d803 is described below
commit 183c2d80397c639cfa23fcbb0926bdb1c4bc10b2
Author: ZhouJinsong <[email protected]>
AuthorDate: Wed Apr 17 11:03:39 2024 +0800
Change package name for module mixed-format/trino (#2745)
* Change package name in module mixed-format/trino
* fix style error
* Change package name for test classes
* Change package name in suppressions.xml
---
.../apache/amoro}/ArcticErrorCode.java | 2 +-
.../apache/amoro}/trino/ArcticCatalogFactory.java | 2 +-
.../trino/ArcticCatalogSupportTableSuffix.java | 2 +-
.../apache/amoro}/trino/ArcticConfig.java | 2 +-
.../apache/amoro}/trino/ArcticConnector.java | 2 +-
.../amoro}/trino/ArcticConnectorFactory.java | 2 +-
.../amoro}/trino/ArcticConnectorMetadata.java | 8 +++----
.../amoro}/trino/ArcticConnectorSplitManager.java | 8 +++----
.../amoro}/trino/ArcticHadoopAuthentication.java | 2 +-
.../amoro}/trino/ArcticHdfsAuthentication.java | 2 +-
.../amoro}/trino/ArcticHdfsConfiguration.java | 2 +-
.../apache/amoro}/trino/ArcticMetadataFactory.java | 6 ++---
.../apache/amoro}/trino/ArcticModule.java | 12 +++++-----
.../amoro}/trino/ArcticPageSourceProvider.java | 8 +++----
.../apache/amoro}/trino/ArcticPlugin.java | 2 +-
.../amoro}/trino/ArcticSessionProperties.java | 2 +-
.../amoro}/trino/ArcticTransactionManager.java | 2 +-
.../amoro}/trino/DefaultArcticCatalogFactory.java | 2 +-
.../apache/amoro}/trino/TableNameResolve.java | 2 +-
.../amoro}/trino/delete/DummyFileScanTask.java | 2 +-
.../amoro}/trino/delete/TrinoDeleteFile.java | 2 +-
.../apache/amoro}/trino/delete/TrinoRow.java | 2 +-
.../amoro}/trino/keyed/KeyedConnectorMetadata.java | 8 +++----
.../trino/keyed/KeyedConnectorPageSource.java | 14 +++++------
.../amoro}/trino/keyed/KeyedConnectorSplit.java | 4 ++--
.../trino/keyed/KeyedConnectorSplitManager.java | 10 ++++----
.../amoro}/trino/keyed/KeyedDeleteFilter.java | 4 ++--
.../trino/keyed/KeyedPageSourceProvider.java | 6 ++---
.../amoro}/trino/keyed/KeyedTableHandle.java | 4 ++--
.../trino/unkeyed/AdaptHiveIcebergTableHandle.java | 2 +-
.../amoro}/trino/unkeyed/ArcticTrinoCatalog.java | 2 +-
.../trino/unkeyed/ArcticTrinoCatalogFactory.java | 4 ++--
.../amoro}/trino/unkeyed/IcebergMetadata.java | 2 +-
.../amoro}/trino/unkeyed/IcebergPageSource.java | 4 ++--
.../trino/unkeyed/IcebergPageSourceProvider.java | 6 ++---
.../apache/amoro}/trino/unkeyed/IcebergSplit.java | 4 ++--
.../amoro}/trino/unkeyed/IcebergSplitManager.java | 6 ++---
.../amoro}/trino/unkeyed/IcebergSplitSource.java | 4 ++--
.../amoro}/trino/unkeyed/TrinoDeleteFilter.java | 4 ++--
.../apache/amoro}/trino/util/MetricUtil.java | 2 +-
.../amoro}/trino/util/ObjectSerializerUtil.java | 2 +-
.../META-INF/services/io.trino.spi.Plugin | 2 +-
.../amoro}/trino/iceberg/ArcticQueryRunner.java | 2 +-
.../trino/iceberg/ArcticQueryRunnerForClient.java | 4 ++--
.../amoro}/trino/iceberg/BaseConnectorTest.java | 2 +-
.../amoro}/trino/iceberg/SchemaInitializer.java | 2 +-
.../trino/iceberg/TestArcticCatalogFactory.java | 8 +++----
.../trino/iceberg/TestArcticConnectorFactory.java | 6 ++---
.../amoro}/trino/iceberg/TestArcticPlugin.java | 2 +-
.../amoro}/trino/iceberg/TestArcticTable.java | 2 +-
.../trino/iceberg/TestBaseArcticConnectorTest.java | 2 +-
.../trino/iceberg/TestBasicArcticCatalog.java | 2 +-
.../iceberg/TestOnServerArcticConnectorTest.java | 2 +-
.../amoro}/trino/iceberg/TestUnionModule.java | 28 +++++++++++-----------
.../amoro/trino/mixed}/ArcticQueryRunner.java | 4 ++--
.../apache/amoro/trino/mixed}/HiveTestRecords.java | 26 ++++++++++----------
.../amoro/trino/mixed}/TableTestBaseForTrino.java | 2 +-
.../mixed}/TableTestBaseWithInitDataForTrino.java | 2 +-
.../trino/mixed}/TestBaseArcticPrimaryTable.java | 2 +-
.../apache/amoro/trino/mixed}/TestHiveTable.java | 2 +-
.../trino/mixed}/TestHiveTableBaseForTrino.java | 2 +-
tools/maven/suppressions.xml | 18 +++++++-------
62 files changed, 145 insertions(+), 145 deletions(-)
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/ArcticErrorCode.java
b/mixed-format/trino/src/main/java/org/apache/amoro/ArcticErrorCode.java
similarity index 97%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/ArcticErrorCode.java
rename to mixed-format/trino/src/main/java/org/apache/amoro/ArcticErrorCode.java
index c8fdfeef5..955cf84f9 100644
--- a/mixed-format/trino/src/main/java/com/netease/arctic/ArcticErrorCode.java
+++ b/mixed-format/trino/src/main/java/org/apache/amoro/ArcticErrorCode.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic;
+package org.apache.amoro;
import static io.trino.spi.ErrorType.EXTERNAL;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticCatalogFactory.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticCatalogFactory.java
similarity index 97%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticCatalogFactory.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticCatalogFactory.java
index 42611c6f8..4014e175c 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticCatalogFactory.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticCatalogFactory.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
import com.netease.arctic.catalog.ArcticCatalog;
import com.netease.arctic.table.TableMetaStore;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticCatalogSupportTableSuffix.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticCatalogSupportTableSuffix.java
similarity index 99%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticCatalogSupportTableSuffix.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticCatalogSupportTableSuffix.java
index d37670ca7..d3a52dc47 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticCatalogSupportTableSuffix.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticCatalogSupportTableSuffix.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
import com.netease.arctic.TableFormat;
import com.netease.arctic.catalog.ArcticCatalog;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticConfig.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticConfig.java
similarity index 98%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticConfig.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticConfig.java
index 348371061..1697726d9 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticConfig.java
+++ b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticConfig.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
import io.airlift.configuration.Config;
import io.airlift.configuration.ConfigDescription;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticConnector.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticConnector.java
similarity index 99%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticConnector.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticConnector.java
index 0287adf80..07eaaf63e 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticConnector.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticConnector.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
import static
io.trino.spi.connector.ConnectorCapabilities.NOT_NULL_COLUMN_CONSTRAINT;
import static io.trino.spi.transaction.IsolationLevel.SERIALIZABLE;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticConnectorFactory.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticConnectorFactory.java
similarity index 99%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticConnectorFactory.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticConnectorFactory.java
index f16d8b8ba..5af7db5a4 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticConnectorFactory.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticConnectorFactory.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
import static com.google.inject.Scopes.SINGLETON;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticConnectorMetadata.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticConnectorMetadata.java
similarity index 98%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticConnectorMetadata.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticConnectorMetadata.java
index ea3f55e3c..060f5eead 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticConnectorMetadata.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticConnectorMetadata.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
import static io.trino.plugin.hive.util.HiveUtil.isHiveSystemSchema;
import static io.trino.spi.StandardErrorCode.NOT_SUPPORTED;
@@ -24,9 +24,9 @@ import static io.trino.spi.StandardErrorCode.NOT_SUPPORTED;
import com.netease.arctic.catalog.ArcticCatalog;
import com.netease.arctic.table.ArcticTable;
import com.netease.arctic.table.TableIdentifier;
-import com.netease.arctic.trino.keyed.KeyedConnectorMetadata;
-import com.netease.arctic.trino.keyed.KeyedTableHandle;
-import com.netease.arctic.trino.unkeyed.IcebergMetadata;
+import org.apache.amoro.trino.keyed.KeyedConnectorMetadata;
+import org.apache.amoro.trino.keyed.KeyedTableHandle;
+import org.apache.amoro.trino.unkeyed.IcebergMetadata;
import io.airlift.slice.Slice;
import io.trino.spi.TrinoException;
import io.trino.spi.connector.BeginTableExecuteResult;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticConnectorSplitManager.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticConnectorSplitManager.java
similarity index 91%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticConnectorSplitManager.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticConnectorSplitManager.java
index 235714b26..8b32f40ff 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticConnectorSplitManager.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticConnectorSplitManager.java
@@ -16,11 +16,11 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
-import com.netease.arctic.trino.keyed.KeyedConnectorSplitManager;
-import com.netease.arctic.trino.keyed.KeyedTableHandle;
-import com.netease.arctic.trino.unkeyed.IcebergSplitManager;
+import org.apache.amoro.trino.keyed.KeyedConnectorSplitManager;
+import org.apache.amoro.trino.keyed.KeyedTableHandle;
+import org.apache.amoro.trino.unkeyed.IcebergSplitManager;
import io.trino.spi.connector.ConnectorSession;
import io.trino.spi.connector.ConnectorSplitManager;
import io.trino.spi.connector.ConnectorSplitSource;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticHadoopAuthentication.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticHadoopAuthentication.java
similarity index 97%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticHadoopAuthentication.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticHadoopAuthentication.java
index 188e69839..c04d16899 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticHadoopAuthentication.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticHadoopAuthentication.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
import com.google.inject.Inject;
import com.netease.arctic.table.TableMetaStore;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticHdfsAuthentication.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticHdfsAuthentication.java
similarity index 98%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticHdfsAuthentication.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticHdfsAuthentication.java
index e8925931b..eaf8fad33 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticHdfsAuthentication.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticHdfsAuthentication.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
import com.netease.arctic.table.TableMetaStore;
import io.trino.hdfs.authentication.GenericExceptionAction;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticHdfsConfiguration.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticHdfsConfiguration.java
similarity index 97%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticHdfsConfiguration.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticHdfsConfiguration.java
index b9e95df13..b44eb73d3 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticHdfsConfiguration.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticHdfsConfiguration.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
import io.trino.hdfs.HdfsConfiguration;
import io.trino.hdfs.HdfsContext;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticMetadataFactory.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticMetadataFactory.java
similarity index 95%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticMetadataFactory.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticMetadataFactory.java
index e6ae411f0..79808e1cf 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticMetadataFactory.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticMetadataFactory.java
@@ -16,12 +16,12 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
import static java.util.Objects.requireNonNull;
-import com.netease.arctic.trino.keyed.KeyedConnectorMetadata;
-import com.netease.arctic.trino.unkeyed.IcebergMetadata;
+import org.apache.amoro.trino.unkeyed.IcebergMetadata;
+import org.apache.amoro.trino.keyed.KeyedConnectorMetadata;
import io.airlift.json.JsonCodec;
import io.trino.filesystem.TrinoFileSystemFactory;
import io.trino.plugin.iceberg.CommitTaskData;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticModule.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticModule.java
similarity index 95%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticModule.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticModule.java
index 4ee70b409..9a5c47b44 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticModule.java
+++ b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticModule.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
import static com.google.inject.multibindings.Multibinder.newSetBinder;
import static io.airlift.configuration.ConfigBinder.configBinder;
@@ -27,11 +27,11 @@ import com.google.inject.Binder;
import com.google.inject.Module;
import com.google.inject.Scopes;
import com.google.inject.multibindings.Multibinder;
-import com.netease.arctic.trino.keyed.KeyedConnectorSplitManager;
-import com.netease.arctic.trino.keyed.KeyedPageSourceProvider;
-import com.netease.arctic.trino.unkeyed.ArcticTrinoCatalogFactory;
-import com.netease.arctic.trino.unkeyed.IcebergPageSourceProvider;
-import com.netease.arctic.trino.unkeyed.IcebergSplitManager;
+import org.apache.amoro.trino.unkeyed.ArcticTrinoCatalogFactory;
+import org.apache.amoro.trino.unkeyed.IcebergPageSourceProvider;
+import org.apache.amoro.trino.unkeyed.IcebergSplitManager;
+import org.apache.amoro.trino.keyed.KeyedConnectorSplitManager;
+import org.apache.amoro.trino.keyed.KeyedPageSourceProvider;
import io.airlift.configuration.ConfigBinder;
import io.trino.hdfs.HdfsConfig;
import io.trino.hdfs.HdfsConfiguration;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticPageSourceProvider.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticPageSourceProvider.java
similarity index 92%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticPageSourceProvider.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticPageSourceProvider.java
index dc69a6bad..9ecec817a 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticPageSourceProvider.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticPageSourceProvider.java
@@ -16,11 +16,11 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
-import com.netease.arctic.trino.keyed.KeyedPageSourceProvider;
-import com.netease.arctic.trino.keyed.KeyedTableHandle;
-import com.netease.arctic.trino.unkeyed.IcebergPageSourceProvider;
+import org.apache.amoro.trino.unkeyed.IcebergPageSourceProvider;
+import org.apache.amoro.trino.keyed.KeyedPageSourceProvider;
+import org.apache.amoro.trino.keyed.KeyedTableHandle;
import io.trino.spi.connector.ColumnHandle;
import io.trino.spi.connector.ConnectorPageSource;
import io.trino.spi.connector.ConnectorPageSourceProvider;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticPlugin.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticPlugin.java
similarity index 97%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticPlugin.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticPlugin.java
index d4cfc3995..efde6d70e 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticPlugin.java
+++ b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticPlugin.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
import io.trino.spi.Plugin;
import io.trino.spi.connector.ConnectorFactory;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticSessionProperties.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticSessionProperties.java
similarity index 99%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticSessionProperties.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticSessionProperties.java
index 0346c4deb..a9dde7e06 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticSessionProperties.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticSessionProperties.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
import static io.trino.spi.session.PropertyMetadata.booleanProperty;
import static io.trino.spi.session.PropertyMetadata.doubleProperty;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticTransactionManager.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticTransactionManager.java
similarity index 99%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticTransactionManager.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticTransactionManager.java
index f96683032..8a2124c15 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/ArcticTransactionManager.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/ArcticTransactionManager.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
import static java.util.Objects.requireNonNull;
import static
org.apache.iceberg.relocated.com.google.common.base.Preconditions.checkArgument;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/DefaultArcticCatalogFactory.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/DefaultArcticCatalogFactory.java
similarity index 98%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/DefaultArcticCatalogFactory.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/DefaultArcticCatalogFactory.java
index 2c2db1384..5f4844d15 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/DefaultArcticCatalogFactory.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/DefaultArcticCatalogFactory.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
import com.netease.arctic.api.CatalogMeta;
import com.netease.arctic.catalog.ArcticCatalog;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/TableNameResolve.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/TableNameResolve.java
similarity index 98%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/TableNameResolve.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/TableNameResolve.java
index ed1cf9ea4..500352732 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/TableNameResolve.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/TableNameResolve.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino;
+package org.apache.amoro.trino;
import com.netease.arctic.Constants;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/delete/DummyFileScanTask.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/delete/DummyFileScanTask.java
similarity index 99%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/delete/DummyFileScanTask.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/delete/DummyFileScanTask.java
index a70e401ab..540856585 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/delete/DummyFileScanTask.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/delete/DummyFileScanTask.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.delete;
+package org.apache.amoro.trino.delete;
import static java.util.Objects.requireNonNull;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/delete/TrinoDeleteFile.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/delete/TrinoDeleteFile.java
similarity index 99%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/delete/TrinoDeleteFile.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/delete/TrinoDeleteFile.java
index a12889c73..f89a29a45 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/delete/TrinoDeleteFile.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/delete/TrinoDeleteFile.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.delete;
+package org.apache.amoro.trino.delete;
import static io.airlift.slice.SizeOf.SIZE_OF_INT;
import static io.airlift.slice.SizeOf.SIZE_OF_LONG;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/delete/TrinoRow.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/delete/TrinoRow.java
similarity index 98%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/delete/TrinoRow.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/delete/TrinoRow.java
index c3eb27fc1..48c2f666c 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/delete/TrinoRow.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/delete/TrinoRow.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.delete;
+package org.apache.amoro.trino.delete;
import static io.trino.plugin.iceberg.IcebergPageSink.getIcebergValue;
import static java.util.Objects.requireNonNull;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedConnectorMetadata.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedConnectorMetadata.java
similarity index 98%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedConnectorMetadata.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedConnectorMetadata.java
index f32fc6ff5..3ff5968d4 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedConnectorMetadata.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedConnectorMetadata.java
@@ -16,9 +16,8 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.keyed;
+package org.apache.amoro.trino.keyed;
-import static
com.netease.arctic.trino.ArcticSessionProperties.isArcticStatisticsEnabled;
import static
io.trino.plugin.hive.HiveApplyProjectionUtil.extractSupportedProjectedColumns;
import static
io.trino.plugin.hive.HiveApplyProjectionUtil.replaceWithNewVariables;
import static io.trino.plugin.hive.util.HiveUtil.isHiveSystemSchema;
@@ -35,7 +34,8 @@ import com.netease.arctic.catalog.ArcticCatalog;
import com.netease.arctic.table.ArcticTable;
import com.netease.arctic.table.KeyedTable;
import com.netease.arctic.table.TableIdentifier;
-import com.netease.arctic.trino.util.ObjectSerializerUtil;
+import org.apache.amoro.trino.ArcticSessionProperties;
+import org.apache.amoro.trino.util.ObjectSerializerUtil;
import io.trino.plugin.hive.HiveApplyProjectionUtil;
import io.trino.plugin.iceberg.ColumnIdentity;
import io.trino.plugin.iceberg.IcebergColumnHandle;
@@ -406,7 +406,7 @@ public class KeyedConnectorMetadata implements
ConnectorMetadata {
@Override
public TableStatistics getTableStatistics(
ConnectorSession session, ConnectorTableHandle tableHandle) {
- if (!isArcticStatisticsEnabled(session)) {
+ if (!ArcticSessionProperties.isArcticStatisticsEnabled(session)) {
return TableStatistics.empty();
}
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedConnectorPageSource.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedConnectorPageSource.java
similarity index 96%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedConnectorPageSource.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedConnectorPageSource.java
index ad36a2f2b..6e5e98033 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedConnectorPageSource.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedConnectorPageSource.java
@@ -16,9 +16,8 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.keyed;
+package org.apache.amoro.trino.keyed;
-import static com.netease.arctic.ArcticErrorCode.ARCTIC_BAD_DATA;
import static io.trino.plugin.iceberg.IcebergErrorCode.ICEBERG_BAD_DATA;
import static java.util.Objects.requireNonNull;
import static
org.apache.iceberg.relocated.com.google.common.base.Preconditions.checkArgument;
@@ -28,10 +27,10 @@ import com.netease.arctic.data.DataFileType;
import com.netease.arctic.data.PrimaryKeyedFile;
import com.netease.arctic.scan.ArcticFileScanTask;
import com.netease.arctic.table.MetadataColumns;
-import com.netease.arctic.trino.delete.TrinoDeleteFile;
-import com.netease.arctic.trino.delete.TrinoRow;
-import com.netease.arctic.trino.unkeyed.IcebergPageSourceProvider;
-import com.netease.arctic.trino.unkeyed.IcebergSplit;
+import org.apache.amoro.trino.delete.TrinoDeleteFile;
+import org.apache.amoro.trino.delete.TrinoRow;
+import org.apache.amoro.trino.unkeyed.IcebergPageSourceProvider;
+import org.apache.amoro.trino.unkeyed.IcebergSplit;
import io.trino.plugin.iceberg.IcebergColumnHandle;
import io.trino.plugin.iceberg.IcebergFileFormat;
import io.trino.spi.Page;
@@ -47,6 +46,7 @@ import
org.apache.amoro.hive.io.reader.AdaptHiveArcticDeleteFilter;
import org.apache.iceberg.io.CloseableIterable;
import org.apache.iceberg.relocated.com.google.common.collect.ImmutableList;
import org.joda.time.DateTimeZone;
+import org.apache.amoro.ArcticErrorCode;
import java.io.IOException;
import java.util.HashMap;
@@ -189,7 +189,7 @@ public class KeyedConnectorPageSource implements
ConnectorPageSource {
} catch (Exception e) {
closeWithSuppression(e);
throwIfInstanceOf(e, TrinoException.class);
- throw new TrinoException(ARCTIC_BAD_DATA, e);
+ throw new TrinoException(ArcticErrorCode.ARCTIC_BAD_DATA, e);
}
}
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedConnectorSplit.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedConnectorSplit.java
similarity index 96%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedConnectorSplit.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedConnectorSplit.java
index 14fbe4c1e..62168bd29 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedConnectorSplit.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedConnectorSplit.java
@@ -16,13 +16,13 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.keyed;
+package org.apache.amoro.trino.keyed;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.netease.arctic.scan.KeyedTableScanTask;
import com.netease.arctic.scan.NodeFileScanTask;
-import com.netease.arctic.trino.util.ObjectSerializerUtil;
+import org.apache.amoro.trino.util.ObjectSerializerUtil;
import io.trino.spi.HostAddress;
import io.trino.spi.connector.ConnectorSplit;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedConnectorSplitManager.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedConnectorSplitManager.java
similarity index 95%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedConnectorSplitManager.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedConnectorSplitManager.java
index cdd8d1d93..191f636bc 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedConnectorSplitManager.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedConnectorSplitManager.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.keyed;
+package org.apache.amoro.trino.keyed;
import static io.trino.plugin.iceberg.ExpressionConverter.toIcebergExpression;
@@ -25,10 +25,10 @@ import com.netease.arctic.scan.CombinedScanTask;
import com.netease.arctic.scan.KeyedTableScan;
import com.netease.arctic.scan.KeyedTableScanTask;
import com.netease.arctic.table.KeyedTable;
-import com.netease.arctic.trino.ArcticSessionProperties;
-import com.netease.arctic.trino.ArcticTransactionManager;
-import com.netease.arctic.trino.util.MetricUtil;
-import com.netease.arctic.trino.util.ObjectSerializerUtil;
+import org.apache.amoro.trino.ArcticSessionProperties;
+import org.apache.amoro.trino.ArcticTransactionManager;
+import org.apache.amoro.trino.util.MetricUtil;
+import org.apache.amoro.trino.util.ObjectSerializerUtil;
import io.trino.plugin.iceberg.IcebergTableHandle;
import io.trino.plugin.iceberg.PartitionData;
import io.trino.spi.classloader.ThreadContextClassLoader;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedDeleteFilter.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedDeleteFilter.java
similarity index 97%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedDeleteFilter.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedDeleteFilter.java
index 867008375..4aab862ba 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedDeleteFilter.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedDeleteFilter.java
@@ -16,14 +16,14 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.keyed;
+package org.apache.amoro.trino.keyed;
import static io.trino.plugin.iceberg.TypeConverter.toIcebergType;
import static
org.apache.iceberg.relocated.com.google.common.collect.ImmutableList.toImmutableList;
import com.netease.arctic.scan.KeyedTableScanTask;
import com.netease.arctic.table.PrimaryKeySpec;
-import com.netease.arctic.trino.delete.TrinoRow;
+import org.apache.amoro.trino.delete.TrinoRow;
import io.trino.plugin.iceberg.IcebergColumnHandle;
import org.apache.amoro.hive.io.reader.AdaptHiveArcticDeleteFilter;
import org.apache.iceberg.Schema;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedPageSourceProvider.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedPageSourceProvider.java
similarity index 96%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedPageSourceProvider.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedPageSourceProvider.java
index 9a187dc3a..cdf6eadfb 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedPageSourceProvider.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedPageSourceProvider.java
@@ -16,14 +16,14 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.keyed;
+package org.apache.amoro.trino.keyed;
import com.google.inject.Inject;
import com.netease.arctic.data.PrimaryKeyedFile;
import com.netease.arctic.scan.ArcticFileScanTask;
import com.netease.arctic.scan.KeyedTableScanTask;
-import com.netease.arctic.trino.delete.TrinoRow;
-import com.netease.arctic.trino.unkeyed.IcebergPageSourceProvider;
+import org.apache.amoro.trino.delete.TrinoRow;
+import org.apache.amoro.trino.unkeyed.IcebergPageSourceProvider;
import io.trino.filesystem.TrinoFileSystemFactory;
import io.trino.plugin.iceberg.IcebergColumnHandle;
import io.trino.plugin.iceberg.IcebergUtil;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedTableHandle.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedTableHandle.java
similarity index 96%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedTableHandle.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedTableHandle.java
index 7110c887f..2b25d0dd4 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/keyed/KeyedTableHandle.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/keyed/KeyedTableHandle.java
@@ -16,12 +16,12 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.keyed;
+package org.apache.amoro.trino.keyed;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.netease.arctic.table.PrimaryKeySpec;
-import com.netease.arctic.trino.util.ObjectSerializerUtil;
+import org.apache.amoro.trino.util.ObjectSerializerUtil;
import io.trino.plugin.iceberg.IcebergColumnHandle;
import io.trino.plugin.iceberg.IcebergTableHandle;
import io.trino.spi.connector.ConnectorTableHandle;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/AdaptHiveIcebergTableHandle.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/AdaptHiveIcebergTableHandle.java
similarity index 99%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/AdaptHiveIcebergTableHandle.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/AdaptHiveIcebergTableHandle.java
index 937106c19..a9b51a78d 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/AdaptHiveIcebergTableHandle.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/AdaptHiveIcebergTableHandle.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.unkeyed;
+package org.apache.amoro.trino.unkeyed;
import static java.util.Objects.requireNonNull;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/ArcticTrinoCatalog.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/ArcticTrinoCatalog.java
similarity index 99%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/ArcticTrinoCatalog.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/ArcticTrinoCatalog.java
index 1c249e9bf..df2dcd993 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/ArcticTrinoCatalog.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/ArcticTrinoCatalog.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.unkeyed;
+package org.apache.amoro.trino.unkeyed;
import static io.trino.plugin.hive.util.HiveUtil.isHiveSystemSchema;
import static io.trino.spi.StandardErrorCode.NOT_SUPPORTED;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/ArcticTrinoCatalogFactory.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/ArcticTrinoCatalogFactory.java
similarity index 93%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/ArcticTrinoCatalogFactory.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/ArcticTrinoCatalogFactory.java
index 28dab6a57..ddd288067 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/ArcticTrinoCatalogFactory.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/ArcticTrinoCatalogFactory.java
@@ -16,9 +16,9 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.unkeyed;
+package org.apache.amoro.trino.unkeyed;
-import com.netease.arctic.trino.ArcticCatalogFactory;
+import org.apache.amoro.trino.ArcticCatalogFactory;
import io.trino.plugin.iceberg.catalog.TrinoCatalog;
import io.trino.plugin.iceberg.catalog.TrinoCatalogFactory;
import io.trino.spi.security.ConnectorIdentity;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergMetadata.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergMetadata.java
similarity index 99%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergMetadata.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergMetadata.java
index 5c0e07ba4..16cd9924a 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergMetadata.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergMetadata.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.unkeyed;
+package org.apache.amoro.trino.unkeyed;
import static io.trino.plugin.base.util.Procedures.checkProcedureArgument;
import static
io.trino.plugin.hive.HiveApplyProjectionUtil.extractSupportedProjectedColumns;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergPageSource.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergPageSource.java
similarity index 98%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergPageSource.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergPageSource.java
index fd6f7c305..f2f7ebc8c 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergPageSource.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergPageSource.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.unkeyed;
+package org.apache.amoro.trino.unkeyed;
import static io.trino.plugin.base.util.Closables.closeAllSuppress;
import static io.trino.plugin.iceberg.IcebergErrorCode.ICEBERG_BAD_DATA;
@@ -25,7 +25,7 @@ import static
org.apache.iceberg.relocated.com.google.common.base.Preconditions.
import static
org.apache.iceberg.relocated.com.google.common.base.Throwables.throwIfInstanceOf;
import com.netease.arctic.io.reader.DeleteFilter;
-import com.netease.arctic.trino.delete.TrinoRow;
+import org.apache.amoro.trino.delete.TrinoRow;
import io.trino.plugin.hive.ReaderProjectionsAdapter;
import io.trino.plugin.iceberg.IcebergColumnHandle;
import io.trino.plugin.iceberg.delete.IcebergPositionDeletePageSink;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergPageSourceProvider.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergPageSourceProvider.java
similarity index 99%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergPageSourceProvider.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergPageSourceProvider.java
index 8b67038e4..dc16a1cb9 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergPageSourceProvider.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergPageSourceProvider.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.unkeyed;
+package org.apache.amoro.trino.unkeyed;
import static io.airlift.slice.Slices.utf8Slice;
import static
io.trino.memory.context.AggregatedMemoryContext.newSimpleAggregatedMemoryContext;
@@ -83,8 +83,8 @@ import com.netease.arctic.data.ChangeAction;
import com.netease.arctic.data.DataFileType;
import com.netease.arctic.io.reader.DeleteFilter;
import com.netease.arctic.table.MetadataColumns;
-import com.netease.arctic.trino.delete.DummyFileScanTask;
-import com.netease.arctic.trino.delete.TrinoRow;
+import org.apache.amoro.trino.delete.DummyFileScanTask;
+import org.apache.amoro.trino.delete.TrinoRow;
import io.airlift.json.JsonCodec;
import io.trino.filesystem.TrinoFileSystem;
import io.trino.filesystem.TrinoFileSystemFactory;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergSplit.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergSplit.java
similarity index 98%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergSplit.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergSplit.java
index 1ce549776..70c212db8 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergSplit.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergSplit.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.unkeyed;
+package org.apache.amoro.trino.unkeyed;
import static io.airlift.slice.SizeOf.estimatedSizeOf;
import static java.lang.Math.toIntExact;
@@ -26,7 +26,7 @@ import static
org.apache.iceberg.relocated.com.google.common.base.MoreObjects.to
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.netease.arctic.data.DataFileType;
-import com.netease.arctic.trino.delete.TrinoDeleteFile;
+import org.apache.amoro.trino.delete.TrinoDeleteFile;
import io.trino.plugin.iceberg.IcebergFileFormat;
import io.trino.spi.HostAddress;
import io.trino.spi.connector.ConnectorSplit;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergSplitManager.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergSplitManager.java
similarity index 96%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergSplitManager.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergSplitManager.java
index 36994eabb..2e1d5460a 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergSplitManager.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergSplitManager.java
@@ -16,14 +16,14 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.unkeyed;
+package org.apache.amoro.trino.unkeyed;
import static
io.trino.plugin.iceberg.IcebergSessionProperties.getDynamicFilteringWaitTimeout;
import static
io.trino.plugin.iceberg.IcebergSessionProperties.getMinimumAssignedSplitWeight;
import static java.util.Objects.requireNonNull;
-import com.netease.arctic.trino.ArcticTransactionManager;
-import com.netease.arctic.trino.TableNameResolve;
+import org.apache.amoro.trino.ArcticTransactionManager;
+import org.apache.amoro.trino.TableNameResolve;
import io.airlift.units.Duration;
import io.trino.filesystem.TrinoFileSystemFactory;
import io.trino.plugin.base.classloader.ClassLoaderSafeConnectorSplitSource;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergSplitSource.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergSplitSource.java
similarity index 99%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergSplitSource.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergSplitSource.java
index a466f1ebb..e72fb7c88 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/IcebergSplitSource.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/IcebergSplitSource.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.unkeyed;
+package org.apache.amoro.trino.unkeyed;
import static io.airlift.slice.Slices.utf8Slice;
import static io.trino.plugin.iceberg.ExpressionConverter.toIcebergExpression;
@@ -48,7 +48,7 @@ import com.netease.arctic.data.DataFileType;
import com.netease.arctic.data.PrimaryKeyedFile;
import com.netease.arctic.scan.ArcticFileScanTask;
import com.netease.arctic.scan.ChangeTableIncrementalScan;
-import com.netease.arctic.trino.delete.TrinoDeleteFile;
+import org.apache.amoro.trino.delete.TrinoDeleteFile;
import io.airlift.units.DataSize;
import io.airlift.units.Duration;
import io.trino.filesystem.TrinoFileSystemFactory;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/TrinoDeleteFilter.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/TrinoDeleteFilter.java
similarity index 97%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/TrinoDeleteFilter.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/TrinoDeleteFilter.java
index c5360c60f..fa812abf6 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/unkeyed/TrinoDeleteFilter.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/unkeyed/TrinoDeleteFilter.java
@@ -16,14 +16,14 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.unkeyed;
+package org.apache.amoro.trino.unkeyed;
import static java.util.Objects.requireNonNull;
import static
org.apache.iceberg.relocated.com.google.common.collect.ImmutableList.toImmutableList;
import static
org.apache.iceberg.relocated.com.google.common.collect.ImmutableSet.toImmutableSet;
import com.netease.arctic.io.reader.DeleteFilter;
-import com.netease.arctic.trino.delete.TrinoRow;
+import org.apache.amoro.trino.delete.TrinoRow;
import io.trino.plugin.iceberg.IcebergColumnHandle;
import org.apache.iceberg.FileScanTask;
import org.apache.iceberg.Schema;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/util/MetricUtil.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/util/MetricUtil.java
similarity index 97%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/util/MetricUtil.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/util/MetricUtil.java
index b34a7217e..8309f9811 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/util/MetricUtil.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/util/MetricUtil.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.util;
+package org.apache.amoro.trino.util;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/util/ObjectSerializerUtil.java
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/util/ObjectSerializerUtil.java
similarity index 98%
rename from
mixed-format/trino/src/main/java/com/netease/arctic/trino/util/ObjectSerializerUtil.java
rename to
mixed-format/trino/src/main/java/org/apache/amoro/trino/util/ObjectSerializerUtil.java
index c696c09f2..a82f084f3 100644
---
a/mixed-format/trino/src/main/java/com/netease/arctic/trino/util/ObjectSerializerUtil.java
+++
b/mixed-format/trino/src/main/java/org/apache/amoro/trino/util/ObjectSerializerUtil.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.util;
+package org.apache.amoro.trino.util;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
diff --git
a/mixed-format/trino/src/main/resources/META-INF/services/io.trino.spi.Plugin
b/mixed-format/trino/src/main/resources/META-INF/services/io.trino.spi.Plugin
index c7dce8891..fc65a7f28 100644
---
a/mixed-format/trino/src/main/resources/META-INF/services/io.trino.spi.Plugin
+++
b/mixed-format/trino/src/main/resources/META-INF/services/io.trino.spi.Plugin
@@ -34,4 +34,4 @@
# limitations under the License.
#
-com.netease.arctic.trino.ArcticPlugin
\ No newline at end of file
+org.apache.amoro.trino.ArcticPlugin
\ No newline at end of file
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/ArcticQueryRunner.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/ArcticQueryRunner.java
similarity index 99%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/ArcticQueryRunner.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/ArcticQueryRunner.java
index f27e88b8a..60af23276 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/ArcticQueryRunner.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/ArcticQueryRunner.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.iceberg;
+package org.apache.amoro.trino.iceberg;
import static io.airlift.testing.Closeables.closeAllSuppress;
import static io.trino.testing.TestingSession.testSessionBuilder;
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/ArcticQueryRunnerForClient.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/ArcticQueryRunnerForClient.java
similarity index 97%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/ArcticQueryRunnerForClient.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/ArcticQueryRunnerForClient.java
index 1c15eb073..745e61f21 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/ArcticQueryRunnerForClient.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/ArcticQueryRunnerForClient.java
@@ -16,15 +16,15 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.iceberg;
+package org.apache.amoro.trino.iceberg;
import static io.trino.testing.TestingSession.testSessionBuilder;
-import com.netease.arctic.trino.ArcticPlugin;
import io.airlift.log.Logger;
import io.airlift.log.Logging;
import io.trino.Session;
import io.trino.testing.DistributedQueryRunner;
+import org.apache.amoro.trino.ArcticPlugin;
import org.apache.iceberg.relocated.com.google.common.collect.ImmutableMap;
import java.nio.file.Path;
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/BaseConnectorTest.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/BaseConnectorTest.java
similarity index 99%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/BaseConnectorTest.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/BaseConnectorTest.java
index 02903cba1..d4b0dcec2 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/BaseConnectorTest.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/BaseConnectorTest.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.iceberg;
+package org.apache.amoro.trino.iceberg;
import static io.airlift.units.Duration.nanosSince;
import static
io.trino.SystemSessionProperties.IGNORE_STATS_CALCULATOR_FAILURES;
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/SchemaInitializer.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/SchemaInitializer.java
similarity index 98%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/SchemaInitializer.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/SchemaInitializer.java
index 7f004c2c2..a0006c025 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/SchemaInitializer.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/SchemaInitializer.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.iceberg;
+package org.apache.amoro.trino.iceberg;
import static io.trino.plugin.tpch.TpchMetadata.TINY_SCHEMA_NAME;
import static io.trino.testing.QueryAssertions.copyTpchTables;
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestArcticCatalogFactory.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestArcticCatalogFactory.java
similarity index 90%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestArcticCatalogFactory.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestArcticCatalogFactory.java
index 879771cae..0c7f6dfaf 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestArcticCatalogFactory.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestArcticCatalogFactory.java
@@ -16,14 +16,14 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.iceberg;
+package org.apache.amoro.trino.iceberg;
import com.netease.arctic.catalog.ArcticCatalog;
import com.netease.arctic.table.TableMetaStore;
-import com.netease.arctic.trino.ArcticCatalogFactory;
-import com.netease.arctic.trino.ArcticCatalogSupportTableSuffix;
-import com.netease.arctic.trino.ArcticConfig;
import io.trino.spi.classloader.ThreadContextClassLoader;
+import org.apache.amoro.trino.ArcticCatalogFactory;
+import org.apache.amoro.trino.ArcticCatalogSupportTableSuffix;
+import org.apache.amoro.trino.ArcticConfig;
import javax.inject.Inject;
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestArcticConnectorFactory.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestArcticConnectorFactory.java
similarity index 97%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestArcticConnectorFactory.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestArcticConnectorFactory.java
index b15c89452..4c5a8716d 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestArcticConnectorFactory.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestArcticConnectorFactory.java
@@ -16,15 +16,13 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.iceberg;
+package org.apache.amoro.trino.iceberg;
import static com.google.inject.Scopes.SINGLETON;
import com.google.inject.Injector;
import com.google.inject.Key;
import com.google.inject.TypeLiteral;
-import com.netease.arctic.trino.ArcticConnector;
-import com.netease.arctic.trino.ArcticTransactionManager;
import io.airlift.bootstrap.Bootstrap;
import io.airlift.bootstrap.LifeCycleManager;
import io.airlift.event.client.EventModule;
@@ -58,6 +56,8 @@ import io.trino.spi.connector.ConnectorSplitManager;
import io.trino.spi.connector.TableProcedureMetadata;
import io.trino.spi.procedure.Procedure;
import io.trino.spi.type.TypeManager;
+import org.apache.amoro.trino.ArcticConnector;
+import org.apache.amoro.trino.ArcticTransactionManager;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.weakref.jmx.guice.MBeanModule;
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestArcticPlugin.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestArcticPlugin.java
similarity index 96%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestArcticPlugin.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestArcticPlugin.java
index 1a86cf495..3e5bc3663 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestArcticPlugin.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestArcticPlugin.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.iceberg;
+package org.apache.amoro.trino.iceberg;
import io.trino.spi.Plugin;
import io.trino.spi.connector.ConnectorFactory;
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestArcticTable.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestArcticTable.java
similarity index 99%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestArcticTable.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestArcticTable.java
index 900e1f1fb..020497ee0 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestArcticTable.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestArcticTable.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.iceberg;
+package org.apache.amoro.trino.iceberg;
import com.netease.arctic.io.ArcticFileIO;
import com.netease.arctic.table.BasicUnkeyedTable;
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestBaseArcticConnectorTest.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestBaseArcticConnectorTest.java
similarity index 99%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestBaseArcticConnectorTest.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestBaseArcticConnectorTest.java
index 1df7b3d5f..19325f404 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestBaseArcticConnectorTest.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestBaseArcticConnectorTest.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.iceberg;
+package org.apache.amoro.trino.iceberg;
import static com.google.common.collect.MoreCollectors.onlyElement;
import static
io.trino.SystemSessionProperties.PREFERRED_WRITE_PARTITIONING_MIN_NUMBER_OF_PARTITIONS;
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestBasicArcticCatalog.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestBasicArcticCatalog.java
similarity index 99%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestBasicArcticCatalog.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestBasicArcticCatalog.java
index d000bca42..e8943747b 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestBasicArcticCatalog.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestBasicArcticCatalog.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.iceberg;
+package org.apache.amoro.trino.iceberg;
import com.netease.arctic.catalog.BasicArcticCatalog;
import com.netease.arctic.table.ArcticTable;
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestOnServerArcticConnectorTest.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestOnServerArcticConnectorTest.java
similarity index 97%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestOnServerArcticConnectorTest.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestOnServerArcticConnectorTest.java
index b9a4bc1b4..bfc88306e 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestOnServerArcticConnectorTest.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestOnServerArcticConnectorTest.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.iceberg;
+package org.apache.amoro.trino.iceberg;
import io.airlift.log.Logger;
import io.trino.testing.DistributedQueryRunner;
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestUnionModule.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestUnionModule.java
similarity index 89%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestUnionModule.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestUnionModule.java
index e66e81bde..b0d047235 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/iceberg/TestUnionModule.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/iceberg/TestUnionModule.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.iceberg;
+package org.apache.amoro.trino.iceberg;
import static com.google.inject.multibindings.Multibinder.newSetBinder;
import static io.airlift.configuration.ConfigBinder.configBinder;
@@ -27,19 +27,6 @@ import com.google.inject.Binder;
import com.google.inject.Module;
import com.google.inject.Scopes;
import com.google.inject.multibindings.Multibinder;
-import com.netease.arctic.trino.ArcticCatalogFactory;
-import com.netease.arctic.trino.ArcticConfig;
-import com.netease.arctic.trino.ArcticConnectorSplitManager;
-import com.netease.arctic.trino.ArcticHdfsAuthentication;
-import com.netease.arctic.trino.ArcticHdfsConfiguration;
-import com.netease.arctic.trino.ArcticMetadataFactory;
-import com.netease.arctic.trino.ArcticPageSourceProvider;
-import com.netease.arctic.trino.ArcticTransactionManager;
-import com.netease.arctic.trino.keyed.KeyedConnectorSplitManager;
-import com.netease.arctic.trino.keyed.KeyedPageSourceProvider;
-import com.netease.arctic.trino.unkeyed.ArcticTrinoCatalogFactory;
-import com.netease.arctic.trino.unkeyed.IcebergPageSourceProvider;
-import com.netease.arctic.trino.unkeyed.IcebergSplitManager;
import io.airlift.configuration.ConfigBinder;
import io.trino.hdfs.HdfsConfig;
import io.trino.hdfs.HdfsConfiguration;
@@ -72,6 +59,19 @@ import io.trino.spi.connector.ConnectorPageSourceProvider;
import io.trino.spi.connector.ConnectorSplitManager;
import io.trino.spi.connector.TableProcedureMetadata;
import io.trino.spi.procedure.Procedure;
+import org.apache.amoro.trino.ArcticCatalogFactory;
+import org.apache.amoro.trino.ArcticConfig;
+import org.apache.amoro.trino.ArcticConnectorSplitManager;
+import org.apache.amoro.trino.ArcticHdfsAuthentication;
+import org.apache.amoro.trino.ArcticHdfsConfiguration;
+import org.apache.amoro.trino.ArcticMetadataFactory;
+import org.apache.amoro.trino.ArcticPageSourceProvider;
+import org.apache.amoro.trino.ArcticTransactionManager;
+import org.apache.amoro.trino.keyed.KeyedConnectorSplitManager;
+import org.apache.amoro.trino.keyed.KeyedPageSourceProvider;
+import org.apache.amoro.trino.unkeyed.ArcticTrinoCatalogFactory;
+import org.apache.amoro.trino.unkeyed.IcebergPageSourceProvider;
+import org.apache.amoro.trino.unkeyed.IcebergSplitManager;
import org.weakref.jmx.guice.ExportBinder;
public class TestUnionModule implements Module {
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/ArcticQueryRunner.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/ArcticQueryRunner.java
similarity index 97%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/ArcticQueryRunner.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/ArcticQueryRunner.java
index 1b859e043..c03ad03ce 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/ArcticQueryRunner.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/ArcticQueryRunner.java
@@ -16,16 +16,16 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.arctic;
+package org.apache.amoro.trino.mixed;
import static io.airlift.testing.Closeables.closeAllSuppress;
import static io.trino.testing.TestingSession.testSessionBuilder;
import static java.util.Objects.requireNonNull;
-import com.netease.arctic.trino.ArcticPlugin;
import io.airlift.log.Logger;
import io.trino.plugin.tpch.TpchPlugin;
import io.trino.testing.DistributedQueryRunner;
+import org.apache.amoro.trino.ArcticPlugin;
import org.apache.iceberg.relocated.com.google.common.collect.ImmutableMap;
import java.io.File;
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/HiveTestRecords.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/HiveTestRecords.java
similarity index 90%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/HiveTestRecords.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/HiveTestRecords.java
index 12b7bcdfd..4950c843b 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/HiveTestRecords.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/HiveTestRecords.java
@@ -16,20 +16,20 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.arctic;
+package org.apache.amoro.trino.mixed;
-import static
com.netease.arctic.trino.arctic.TestHiveTableBaseForTrino.COLUMN_NAME_ARRAY;
-import static
com.netease.arctic.trino.arctic.TestHiveTableBaseForTrino.COLUMN_NAME_D;
-import static
com.netease.arctic.trino.arctic.TestHiveTableBaseForTrino.COLUMN_NAME_ID;
-import static
com.netease.arctic.trino.arctic.TestHiveTableBaseForTrino.COLUMN_NAME_MAP;
-import static
com.netease.arctic.trino.arctic.TestHiveTableBaseForTrino.COLUMN_NAME_NAME;
-import static
com.netease.arctic.trino.arctic.TestHiveTableBaseForTrino.COLUMN_NAME_OP_TIME;
-import static
com.netease.arctic.trino.arctic.TestHiveTableBaseForTrino.COLUMN_NAME_OP_TIME_WITH_ZONE;
-import static
com.netease.arctic.trino.arctic.TestHiveTableBaseForTrino.COLUMN_NAME_STRUCT;
-import static
com.netease.arctic.trino.arctic.TestHiveTableBaseForTrino.COLUMN_NAME_STRUCT_SUB1;
-import static
com.netease.arctic.trino.arctic.TestHiveTableBaseForTrino.COLUMN_NAME_STRUCT_SUB2;
-import static
com.netease.arctic.trino.arctic.TestHiveTableBaseForTrino.HIVE_TABLE_SCHEMA;
-import static
com.netease.arctic.trino.arctic.TestHiveTableBaseForTrino.STRUCT_SUB_SCHEMA;
+import static
org.apache.amoro.trino.mixed.TestHiveTableBaseForTrino.COLUMN_NAME_ARRAY;
+import static
org.apache.amoro.trino.mixed.TestHiveTableBaseForTrino.COLUMN_NAME_D;
+import static
org.apache.amoro.trino.mixed.TestHiveTableBaseForTrino.COLUMN_NAME_ID;
+import static
org.apache.amoro.trino.mixed.TestHiveTableBaseForTrino.COLUMN_NAME_MAP;
+import static
org.apache.amoro.trino.mixed.TestHiveTableBaseForTrino.COLUMN_NAME_NAME;
+import static
org.apache.amoro.trino.mixed.TestHiveTableBaseForTrino.COLUMN_NAME_OP_TIME;
+import static
org.apache.amoro.trino.mixed.TestHiveTableBaseForTrino.COLUMN_NAME_OP_TIME_WITH_ZONE;
+import static
org.apache.amoro.trino.mixed.TestHiveTableBaseForTrino.COLUMN_NAME_STRUCT;
+import static
org.apache.amoro.trino.mixed.TestHiveTableBaseForTrino.COLUMN_NAME_STRUCT_SUB1;
+import static
org.apache.amoro.trino.mixed.TestHiveTableBaseForTrino.COLUMN_NAME_STRUCT_SUB2;
+import static
org.apache.amoro.trino.mixed.TestHiveTableBaseForTrino.HIVE_TABLE_SCHEMA;
+import static
org.apache.amoro.trino.mixed.TestHiveTableBaseForTrino.STRUCT_SUB_SCHEMA;
import org.apache.iceberg.data.GenericRecord;
import org.apache.iceberg.data.Record;
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/TableTestBaseForTrino.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/TableTestBaseForTrino.java
similarity index 99%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/TableTestBaseForTrino.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/TableTestBaseForTrino.java
index cb6cb5106..0a398f0bc 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/TableTestBaseForTrino.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/TableTestBaseForTrino.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.arctic;
+package org.apache.amoro.trino.mixed;
import static com.netease.arctic.MockArcticMetastoreServer.TEST_CATALOG_NAME;
import static com.netease.arctic.MockArcticMetastoreServer.TEST_DB_NAME;
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/TableTestBaseWithInitDataForTrino.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/TableTestBaseWithInitDataForTrino.java
similarity index 99%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/TableTestBaseWithInitDataForTrino.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/TableTestBaseWithInitDataForTrino.java
index a8c35792b..00a7d4556 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/TableTestBaseWithInitDataForTrino.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/TableTestBaseWithInitDataForTrino.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.arctic;
+package org.apache.amoro.trino.mixed;
import com.netease.arctic.data.ChangeAction;
import com.netease.arctic.io.writer.GenericBaseTaskWriter;
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/TestBaseArcticPrimaryTable.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/TestBaseArcticPrimaryTable.java
similarity index 99%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/TestBaseArcticPrimaryTable.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/TestBaseArcticPrimaryTable.java
index 1fb3014be..3cfd5bc96 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/TestBaseArcticPrimaryTable.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/TestBaseArcticPrimaryTable.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.arctic;
+package org.apache.amoro.trino.mixed;
import static com.netease.arctic.MockArcticMetastoreServer.TEST_CATALOG_NAME;
import static org.assertj.core.api.Assertions.assertThat;
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/TestHiveTable.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/TestHiveTable.java
similarity index 99%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/TestHiveTable.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/TestHiveTable.java
index ba12248b3..08bf82156 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/TestHiveTable.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/TestHiveTable.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.arctic;
+package org.apache.amoro.trino.mixed;
import static com.netease.arctic.MockArcticMetastoreServer.TEST_CATALOG_NAME;
import static com.netease.arctic.table.TableProperties.BASE_FILE_FORMAT;
diff --git
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/TestHiveTableBaseForTrino.java
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/TestHiveTableBaseForTrino.java
similarity index 99%
rename from
mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/TestHiveTableBaseForTrino.java
rename to
mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/TestHiveTableBaseForTrino.java
index 5dfe3ecda..54995a295 100644
---
a/mixed-format/trino/src/test/java/com/netease/arctic/trino/arctic/TestHiveTableBaseForTrino.java
+++
b/mixed-format/trino/src/test/java/org/apache/amoro/trino/mixed/TestHiveTableBaseForTrino.java
@@ -16,7 +16,7 @@
* limitations under the License.
*/
-package com.netease.arctic.trino.arctic;
+package org.apache.amoro.trino.mixed;
import static com.netease.arctic.MockArcticMetastoreServer.TEST_CATALOG_NAME;
diff --git a/tools/maven/suppressions.xml b/tools/maven/suppressions.xml
index 8fc8fdf46..4e9ed590c 100644
--- a/tools/maven/suppressions.xml
+++ b/tools/maven/suppressions.xml
@@ -83,33 +83,33 @@ under the License.
files="org[/\\]apache[/\\]hadoop[/\\]util[/\\]VersionInfo\.java"
checks="MethodName"/>
<suppress
-
files="com[/\\]netease[/\\]arctic[/\\]trino[/\\]iceberg[/\\]TestBaseArcticConnectorTest\.java"
+
files="org[/\\]apache[/\\]amoro[/\\]trino[/\\]iceberg[/\\]TestBaseArcticConnectorTest\.java"
checks="FileLength"/>
<suppress
-
files="com[/\\]netease[/\\]arctic[/\\]trino[/\\]iceberg[/\\]BaseConnectorTest\.java"
+
files="org[/\\]apache[/\\]amoro[/\\]trino[/\\]iceberg[/\\]BaseConnectorTest\.java"
checks="FileLength"/>
<suppress
-
files="com[/\\]netease[/\\]arctic[/\\]trino[/\\]keyed[/\\]KeyedConnectorSplit\.java"
+
files="org[/\\]apache[/\\]amoro[/\\]trino[/\\]keyed[/\\]KeyedConnectorSplit\.java"
checks="Regexp"/>
<suppress
-
files="com[/\\]netease[/\\]arctic[/\\]trino[/\\]keyed[/\\]KeyedTableHandle\.java"
+
files="org[/\\]apache[/\\]amoro[/\\]trino[/\\]keyed[/\\]KeyedTableHandle\.java"
checks="Regexp"/>
<suppress
-
files="com[/\\]netease[/\\]arctic[/\\]trino[/\\]delete[/\\]TrinoDeleteFile\.java"
+
files="org[/\\]apache[/\\]amoro[/\\]trino[/\\]delete[/\\]TrinoDeleteFile\.java"
checks="Regexp"/>
<suppress
-
files="com[/\\]netease[/\\]arctic[/\\]trino[/\\]unkeyed[/\\]IcebergSplit\.java"
+
files="org[/\\]apache[/\\]amoro[/\\]trino[/\\]unkeyed[/\\]IcebergSplit\.java"
checks="Regexp"/>
<suppress
-
files="com[/\\]netease[/\\]arctic[/\\]trino[/\\]unkeyed[/\\]AdaptHiveIcebergTableHandle\.java"
+
files="org[/\\]apache[/\\]amoro[/\\]trino[/\\]unkeyed[/\\]AdaptHiveIcebergTableHandle\.java"
checks="Regexp"/>
<!-- BaseConnectorTest and TestBaseArcticConnectorTest can be replace by
shaded guava
because the shaded guava version is too low -->
<suppress
-
files="com[/\\]netease[/\\]arctic[/\\]trino[/\\]iceberg[/\\]BaseConnectorTest.java"
+
files="org[/\\]apache[/\\]amoro[/\\]trino[/\\]iceberg[/\\]BaseConnectorTest.java"
checks="IllegalImport"/>
<suppress
-
files="com[/\\]netease[/\\]arctic[/\\]trino[/\\]iceberg[/\\]TestBaseArcticConnectorTest.java"
+
files="org[/\\]apache[/\\]amoro[/\\]trino[/\\]iceberg[/\\]TestBaseArcticConnectorTest.java"
checks="IllegalImport"/>
</suppressions>
