Renaming to paimon

JingsongLi · Mar 20, 2023 · df24eff · df24eff
1 parent f09ea51
commit df24eff
Show file tree

Hide file tree

Showing 41 changed files with 170 additions and 172 deletions.
diff --git a/README.md b/README.md
@@ -1,6 +1,6 @@
-# Flink Table Store Trino
+# Paimon Trino
 
-Because Trino's dependency is JDK 11, it is not possible to include the trino connector in [flink-table-store](https://github.com/apache/flink-table-store).
+Because Trino's dependency is JDK 11, it is not possible to include the trino connector in [Paimon](https://github.com/apache/incubator-paimon).
 
 ## Deploy Table Store Trino Connector
 
@@ -13,7 +13,7 @@ Building Table Store Trino Bundled Jar is by running:
 
 NOTE: For JDK 17,  when [Deploying Trino](https://trino.io/docs/current/installation/deployment.html), should add jvm options: `--add-opens=java.base/sun.nio.ch=ALL-UNNAMED --add-opens=java.base/java.nio=ALL-UNNAMED`
 
-Then, copy `target/flink-table-store-trino-*.jar` and [flink-shaded-hadoop-2-uber-2.8.3-10.0.jar](https://repo.maven.apache.org/maven2/org/apache/flink/flink-shaded-hadoop-2-uber/2.8.3-10.0/flink-shaded-hadoop-2-uber-2.8.3-10.0.jar)
+Then, copy `target/paimon-trino-*.jar` and [flink-shaded-hadoop-2-uber-2.8.3-10.0.jar](https://repo.maven.apache.org/maven2/org/apache/flink/flink-shaded-hadoop-2-uber/2.8.3-10.0/flink-shaded-hadoop-2-uber-2.8.3-10.0.jar)
 to `plugin/tablestore`.
 
 ## Configure Table Store Catalog

diff --git a/pom.xml b/pom.xml
@@ -28,9 +28,9 @@ under the License.
         <version>23</version>
     </parent>
 
-    <groupId>org.apache.flink</groupId>
-    <artifactId>flink-table-store-trino</artifactId>
-    <name>Flink Table Store : Trino</name>
+    <groupId>org.apache.paimon</groupId>
+    <artifactId>paimon-trino</artifactId>
+    <name>Paimon : Trino</name>
     <version>0.4-SNAPSHOT</version>
 
     <packaging>jar</packaging>
@@ -45,10 +45,9 @@ under the License.
     </properties>
 
     <dependencies>
-        <!-- Flink All dependencies -->
         <dependency>
-            <groupId>org.apache.flink</groupId>
-            <artifactId>flink-table-store-shade</artifactId>
+            <groupId>org.apache.paimon</groupId>
+            <artifactId>paimon-shade</artifactId>
             <version>${project.version}</version>
         </dependency>
 
@@ -234,7 +233,7 @@ under the License.
                         <configuration>
                             <artifactSet>
                                 <includes combine.children="append">
-                                    <include>org.apache.flink:flink-table-store-shade</include>
+                                    <include>org.apache.paimon:paimon-shade</include>
                                     <include>org.slf4j:slf4j-api</include>
                                     <include>org.xerial.snappy:snappy-java</include>
                                     <include>org.apache.commons:commons-lang3</include>
@@ -252,7 +251,7 @@ under the License.
                                 <!-- The ApacheNoticeResourceTransformer collects and aggregates NOTICE files -->
                                 <transformer
                                         implementation="org.apache.maven.plugins.shade.resource.ApacheNoticeResourceTransformer">
-                                    <projectName>Apache Flink</projectName>
+                                    <projectName>Apache Paimon</projectName>
                                     <encoding>UTF-8</encoding>
                                 </transformer>
                             </transformers>

diff --git a/...flink.table.store.trino/DecimalUtils.java → ...org.apache.paimon.trino/DecimalUtils.java b/...flink.table.store.trino/DecimalUtils.java → ...org.apache.paimon.trino/DecimalUtils.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 import io.airlift.slice.Slice;
 import java.math.BigInteger;

diff --git a/...le.store.trino/TrinoConnectorFactory.java → ...e.paimon.trino/TrinoConnectorFactory.java b/...le.store.trino/TrinoConnectorFactory.java → ...e.paimon.trino/TrinoConnectorFactory.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 import io.trino.spi.connector.ConnectorFactory;
 import io.trino.spi.connector.ConnectorHandleResolver;

diff --git a/...able.store.trino/TrinoHandleResolver.java → ...che.paimon.trino/TrinoHandleResolver.java b/...able.store.trino/TrinoHandleResolver.java → ...che.paimon.trino/TrinoHandleResolver.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 import io.trino.spi.connector.ColumnHandle;
 import io.trino.spi.connector.ConnectorHandleResolver;

diff --git a/...link.table.store.trino/TrinoMetadata.java → ...rg.apache.paimon.trino/TrinoMetadata.java b/...link.table.store.trino/TrinoMetadata.java → ...rg.apache.paimon.trino/TrinoMetadata.java
@@ -16,9 +16,9 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
-import org.apache.flink.table.store.options.Options;
+import org.apache.paimon.options.Options;
 
 public class TrinoMetadata extends TrinoMetadataBase {
 

diff --git a/...nk.table.store.trino/TrinoPageSource.java → ....apache.paimon.trino/TrinoPageSource.java b/...nk.table.store.trino/TrinoPageSource.java → ....apache.paimon.trino/TrinoPageSource.java
@@ -16,12 +16,12 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 import io.trino.spi.connector.ColumnHandle;
 
-import org.apache.flink.table.store.data.InternalRow;
-import org.apache.flink.table.store.reader.RecordReader;
+import org.apache.paimon.data.InternalRow;
+import org.apache.paimon.reader.RecordReader;
 
 import java.util.List;
 

diff --git a/....table.store.trino/TrinoSplitManager.java → ...pache.paimon.trino/TrinoSplitManager.java b/....table.store.trino/TrinoSplitManager.java → ...pache.paimon.trino/TrinoSplitManager.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 import io.trino.spi.connector.ConnectorSession;
 import io.trino.spi.connector.ConnectorSplitSource;

diff --git a/...k.table.store.trino/TrinoSplitSource.java → ...apache.paimon.trino/TrinoSplitSource.java b/...k.table.store.trino/TrinoSplitSource.java → ...apache.paimon.trino/TrinoSplitSource.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 import io.trino.spi.connector.ConnectorPartitionHandle;
 

diff --git a/...flink.table.store.trino/DecimalUtils.java → ...org.apache.paimon.trino/DecimalUtils.java b/...flink.table.store.trino/DecimalUtils.java → ...org.apache.paimon.trino/DecimalUtils.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 import io.trino.spi.type.Int128;
 import java.math.BigInteger;

diff --git a/...le.store.trino/TrinoConnectorFactory.java → ...e.paimon.trino/TrinoConnectorFactory.java b/...le.store.trino/TrinoConnectorFactory.java → ...e.paimon.trino/TrinoConnectorFactory.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 public class TrinoConnectorFactory extends TrinoConnectorFactoryBase {
 }
diff --git a/...link.table.store.trino/TrinoMetadata.java → ...rg.apache.paimon.trino/TrinoMetadata.java b/...link.table.store.trino/TrinoMetadata.java → ...rg.apache.paimon.trino/TrinoMetadata.java
@@ -16,9 +16,9 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
-import org.apache.flink.table.store.options.Options;
+import org.apache.paimon.options.Options;
 
 public class TrinoMetadata extends TrinoMetadataBase {
 

diff --git a/...nk.table.store.trino/TrinoPageSource.java → ....apache.paimon.trino/TrinoPageSource.java b/...nk.table.store.trino/TrinoPageSource.java → ....apache.paimon.trino/TrinoPageSource.java
@@ -16,12 +16,12 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 import io.trino.spi.connector.ColumnHandle;
 
-import org.apache.flink.table.store.data.InternalRow;
-import org.apache.flink.table.store.reader.RecordReader;
+import org.apache.paimon.data.InternalRow;
+import org.apache.paimon.reader.RecordReader;
 
 import java.util.List;
 

diff --git a/....table.store.trino/TrinoSplitManager.java → ...pache.paimon.trino/TrinoSplitManager.java b/....table.store.trino/TrinoSplitManager.java → ...pache.paimon.trino/TrinoSplitManager.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 import io.trino.spi.connector.ConnectorSession;
 import io.trino.spi.connector.ConnectorSplitManager;

diff --git a/...k.table.store.trino/TrinoSplitSource.java → ...apache.paimon.trino/TrinoSplitSource.java b/...k.table.store.trino/TrinoSplitSource.java → ...apache.paimon.trino/TrinoSplitSource.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 import io.trino.spi.connector.ConnectorPartitionHandle;
 

diff --git a/...flink.table.store.trino/DecimalUtils.java → ...org/apache/paimon/trino/DecimalUtils.java b/...flink.table.store.trino/DecimalUtils.java → ...org/apache/paimon/trino/DecimalUtils.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 import io.trino.spi.type.Int128;
 import java.math.BigInteger;

diff --git a/...le.store.trino/TrinoConnectorFactory.java → ...e/paimon/trino/TrinoConnectorFactory.java b/...le.store.trino/TrinoConnectorFactory.java → ...e/paimon/trino/TrinoConnectorFactory.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 public class TrinoConnectorFactory extends TrinoConnectorFactoryBase {
 }
diff --git a/...link.table.store.trino/TrinoMetadata.java → ...rg/apache/paimon/trino/TrinoMetadata.java b/...link.table.store.trino/TrinoMetadata.java → ...rg/apache/paimon/trino/TrinoMetadata.java
@@ -16,9 +16,9 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
-import org.apache.flink.table.store.options.Options;
+import org.apache.paimon.options.Options;
 
 public class TrinoMetadata extends TrinoMetadataBase {
 

diff --git a/...nk.table.store.trino/TrinoPageSource.java → .../apache/paimon/trino/TrinoPageSource.java b/...nk.table.store.trino/TrinoPageSource.java → .../apache/paimon/trino/TrinoPageSource.java
@@ -16,12 +16,12 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 import io.trino.spi.connector.ColumnHandle;
 
-import org.apache.flink.table.store.data.InternalRow;
-import org.apache.flink.table.store.reader.RecordReader;
+import org.apache.paimon.data.InternalRow;
+import org.apache.paimon.reader.RecordReader;
 
 import java.util.List;
 

diff --git a/....table.store.trino/TrinoSplitManager.java → ...pache/paimon/trino/TrinoSplitManager.java b/....table.store.trino/TrinoSplitManager.java → ...pache/paimon/trino/TrinoSplitManager.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 import io.trino.spi.connector.ConnectorSession;
 import io.trino.spi.connector.ConnectorSplitSource;

diff --git a/...k.table.store.trino/TrinoSplitSource.java → ...apache/paimon/trino/TrinoSplitSource.java b/...k.table.store.trino/TrinoSplitSource.java → ...apache/paimon/trino/TrinoSplitSource.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 import java.util.List;
 import java.util.concurrent.CompletableFuture;

diff --git a/...k/table/store/trino/ClassLoaderUtils.java → ...apache/paimon/trino/ClassLoaderUtils.java b/...k/table/store/trino/ClassLoaderUtils.java → ...apache/paimon/trino/ClassLoaderUtils.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 import java.util.function.Supplier;
 

diff --git a/...link/table/store/trino/EncodingUtils.java → ...rg/apache/paimon/trino/EncodingUtils.java b/...link/table/store/trino/EncodingUtils.java → ...rg/apache/paimon/trino/EncodingUtils.java
@@ -16,9 +16,9 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
-import org.apache.flink.table.store.utils.InstantiationUtil;
+import org.apache.paimon.utils.InstantiationUtil;
 
 
 import java.util.Base64;

diff --git a/...ink/table/store/trino/FieldNameUtils.java → ...g/apache/paimon/trino/FieldNameUtils.java b/...ink/table/store/trino/FieldNameUtils.java → ...g/apache/paimon/trino/FieldNameUtils.java
@@ -16,10 +16,10 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
-import org.apache.flink.table.store.types.DataField;
-import org.apache.flink.table.store.types.RowType;
+import org.apache.paimon.types.DataField;
+import org.apache.paimon.types.RowType;
 
 
 import java.util.List;

diff --git a/.../table/store/trino/TrinoColumnHandle.java → ...pache/paimon/trino/TrinoColumnHandle.java b/.../table/store/trino/TrinoColumnHandle.java → ...pache/paimon/trino/TrinoColumnHandle.java
@@ -16,17 +16,17 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import io.trino.spi.connector.ColumnHandle;
 import io.trino.spi.connector.ColumnMetadata;
 import io.trino.spi.type.Type;
 
-import org.apache.flink.table.store.file.utils.JsonSerdeUtil;
-import org.apache.flink.table.store.types.DataType;
-import org.apache.flink.table.store.types.DataTypeJsonParser;
+import org.apache.paimon.utils.JsonSerdeUtil;
+import org.apache.paimon.types.DataType;
+import org.apache.paimon.types.DataTypeJsonParser;
 
 
 import static java.util.Objects.requireNonNull;

diff --git a/...ink/table/store/trino/TrinoConnector.java → ...g/apache/paimon/trino/TrinoConnector.java b/...ink/table/store/trino/TrinoConnector.java → ...g/apache/paimon/trino/TrinoConnector.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
 import io.trino.spi.connector.Connector;
 import io.trino.spi.connector.ConnectorTransactionHandle;

diff --git a/...tore/trino/TrinoConnectorFactoryBase.java → ...imon/trino/TrinoConnectorFactoryBase.java b/...tore/trino/TrinoConnectorFactoryBase.java → ...imon/trino/TrinoConnectorFactoryBase.java
@@ -16,9 +16,9 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
-import org.apache.flink.table.store.options.Options;
+import org.apache.paimon.options.Options;
 
 import java.util.Map;
 
@@ -30,7 +30,7 @@
 public abstract class TrinoConnectorFactoryBase implements ConnectorFactory {
     @Override
     public String getName() {
-        return "tablestore";
+        return "paimon";
     }
 
     @Override

diff --git a/...ble/store/trino/TrinoFilterConverter.java → ...he/paimon/trino/TrinoFilterConverter.java b/...ble/store/trino/TrinoFilterConverter.java → ...he/paimon/trino/TrinoFilterConverter.java
@@ -16,14 +16,14 @@
  * limitations under the License.
  */
 
-package org.apache.flink.table.store.trino;
+package org.apache.paimon.trino;
 
-import org.apache.flink.table.store.data.BinaryString;
-import org.apache.flink.table.store.data.Decimal;
-import org.apache.flink.table.store.data.Timestamp;
-import org.apache.flink.table.store.file.predicate.Predicate;
-import org.apache.flink.table.store.file.predicate.PredicateBuilder;
-import org.apache.flink.table.store.types.RowType;
+import org.apache.paimon.data.BinaryString;
+import org.apache.paimon.data.Decimal;
+import org.apache.paimon.data.Timestamp;
+import org.apache.paimon.predicate.Predicate;
+import org.apache.paimon.predicate.PredicateBuilder;
+import org.apache.paimon.types.RowType;
 
 import io.airlift.slice.Slice;
 import io.trino.spi.predicate.Domain;
@@ -56,8 +56,8 @@
 import static java.lang.Float.intBitsToFloat;
 import static java.lang.Math.toIntExact;
 import static java.util.Objects.requireNonNull;
-import static org.apache.flink.table.store.file.predicate.PredicateBuilder.and;
-import static org.apache.flink.table.store.file.predicate.PredicateBuilder.or;
+import static org.apache.paimon.predicate.PredicateBuilder.and;
+import static org.apache.paimon.predicate.PredicateBuilder.or;
 
 /** Trino filter to flink predicate. */
 public class TrinoFilterConverter {