diff --git a/pom.xml b/pom.xml index 39ed2db..3e27421 100644 --- a/pom.xml +++ b/pom.xml @@ -22,13 +22,15 @@ under the License. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 4.0.0 - org.apache.paimon - paimon-parent - 1.0-SNAPSHOT + org.apache + apache + 23 + org.apache.paimon paimon-trino-${trino.version} Paimon : Trino : ${trino.version} + 1.0-SNAPSHOT https://github.com/apache/paimon-trino @@ -37,9 +39,10 @@ under the License. - 1.0-SNAPSHOT - 21 - 21 + 1.0.1 + 21 + ${java.version} + ${java.version} 440 241 2.2 @@ -194,9 +197,21 @@ under the License. + org.apache.maven.plugins maven-compiler-plugin + 3.14.0 + + ${java.version} + ${java.version} + + false + + + -Xpkginfo:always + + diff --git a/src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java b/src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java index debafbc..3e6f2c9 100644 --- a/src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java +++ b/src/main/java/org/apache/paimon/trino/catalog/TrinoCatalog.java @@ -18,15 +18,10 @@ package org.apache.paimon.trino.catalog; -import org.apache.paimon.catalog.Catalog; -import org.apache.paimon.catalog.CatalogContext; -import org.apache.paimon.catalog.CatalogFactory; -import org.apache.paimon.catalog.Database; -import org.apache.paimon.catalog.Identifier; +import org.apache.paimon.catalog.*; import org.apache.paimon.fs.FileIO; -import org.apache.paimon.fs.Path; -import org.apache.paimon.manifest.PartitionEntry; import org.apache.paimon.options.Options; +import org.apache.paimon.partition.Partition; import org.apache.paimon.schema.Schema; import org.apache.paimon.schema.SchemaChange; import org.apache.paimon.security.SecurityContext; @@ -109,6 +104,11 @@ public Map options() { return current.options(); } + @Override + public boolean caseSensitive() { + return false; + } + @Override public FileIO fileIO() { if (!inited) { @@ -134,19 +134,20 @@ public Database getDatabase(String name) throws DatabaseNotExistException { } @Override - public void dropDatabase(String s, boolean b, boolean b1) + public void dropDatabase(String name, boolean ignoreIfNotExists, boolean cascade) throws DatabaseNotExistException, DatabaseNotEmptyException { - current.dropDatabase(s, b, b1); + current.dropDatabase(name, ignoreIfNotExists, cascade); } @Override - public Table getTable(Identifier identifier) throws TableNotExistException { - return current.getTable(identifier); + public void alterDatabase(String name, List changes, boolean ignoreIfNotExists) throws DatabaseNotExistException { + + current.alterDatabase(name, changes, ignoreIfNotExists); } @Override - public Path getTableLocation(Identifier identifier) { - return current.getTableLocation(identifier); + public Table getTable(Identifier identifier) throws TableNotExistException { + return current.getTable(identifier); } @Override @@ -190,7 +191,7 @@ public void dropPartition(Identifier identifier, Map partitions) } @Override - public List listPartitions(Identifier identifier) + public List listPartitions(Identifier identifier) throws TableNotExistException { return current.listPartitions(identifier); } @@ -213,9 +214,4 @@ public void alterTable(Identifier identifier, SchemaChange change, boolean ignor throws TableNotExistException, ColumnAlreadyExistException, ColumnNotExistException { current.alterTable(identifier, change, ignoreIfNotExists); } - - @Override - public boolean allowUpperCase() { - return current.allowUpperCase(); - } }