diff --git a/pom.xml b/pom.xml index 3783714..2373823 100644 --- a/pom.xml +++ b/pom.xml @@ -37,7 +37,7 @@ true false - 416 + 417 230 ${dep.airlift.version} 1.12.464 @@ -92,12 +92,6 @@ ${dep.trino.version} - - io.trino - trino-hive - ${dep.trino.version} - - io.trino trino-memory-context diff --git a/src/main/java/org/ebyhr/trino/storage/StorageConnectorFactory.java b/src/main/java/org/ebyhr/trino/storage/StorageConnectorFactory.java index 68bca6a..0eac093 100644 --- a/src/main/java/org/ebyhr/trino/storage/StorageConnectorFactory.java +++ b/src/main/java/org/ebyhr/trino/storage/StorageConnectorFactory.java @@ -18,9 +18,9 @@ import io.airlift.json.JsonModule; import io.trino.hdfs.HdfsModule; import io.trino.hdfs.authentication.HdfsAuthenticationModule; -import io.trino.plugin.hive.azure.HiveAzureModule; -import io.trino.plugin.hive.gcs.HiveGcsModule; -import io.trino.plugin.hive.s3.HiveS3Module; +import io.trino.hdfs.azure.HiveAzureModule; +import io.trino.hdfs.gcs.HiveGcsModule; +import io.trino.hdfs.s3.HiveS3Module; import io.trino.spi.connector.Connector; import io.trino.spi.connector.ConnectorContext; import io.trino.spi.connector.ConnectorFactory; diff --git a/src/main/java/org/ebyhr/trino/storage/StorageModule.java b/src/main/java/org/ebyhr/trino/storage/StorageModule.java index 30e7fb9..1dd9b47 100644 --- a/src/main/java/org/ebyhr/trino/storage/StorageModule.java +++ b/src/main/java/org/ebyhr/trino/storage/StorageModule.java @@ -22,6 +22,7 @@ import io.opentelemetry.api.OpenTelemetry; import io.trino.filesystem.TrinoFileSystemFactory; import io.trino.filesystem.hdfs.HdfsFileSystemFactory; +import io.trino.hdfs.TrinoHdfsFileSystemStats; import io.trino.spi.ptf.ConnectorTableFunction; import io.trino.spi.type.Type; import io.trino.spi.type.TypeManager; @@ -63,6 +64,7 @@ public void configure(Binder binder) newSetBinder(binder, ConnectorTableFunction.class).addBinding().toProvider(ReadFileTableFunction.class).in(Scopes.SINGLETON); newSetBinder(binder, ConnectorTableFunction.class).addBinding().toProvider(ListTableFunction.class).in(Scopes.SINGLETON); binder.bind(TrinoFileSystemFactory.class).to(HdfsFileSystemFactory.class).in(Scopes.SINGLETON); + binder.bind(TrinoHdfsFileSystemStats.class).in(Scopes.SINGLETON); binder.bind(OpenTelemetry.class).toInstance(OpenTelemetry.noop()); jsonBinder(binder).addDeserializerBinding(Type.class).to(TypeDeserializer.class);