diff --git a/pom.xml b/pom.xml index 7625693..2501a19 100644 --- a/pom.xml +++ b/pom.xml @@ -16,7 +16,7 @@ io.airlift airbase - 134 + 138 @@ -37,8 +37,8 @@ true false - 412 - 228 + 415 + 230 ${dep.airlift.version} 1.12.459 2.18.0 @@ -247,6 +247,18 @@ provided + + io.opentelemetry + opentelemetry-api + provided + + + + io.opentelemetry + opentelemetry-context + provided + + com.fasterxml.jackson.core jackson-annotations @@ -336,7 +348,6 @@ org.jetbrains.kotlin kotlin-stdlib-common test - 1.6.20 diff --git a/src/main/java/org/ebyhr/trino/storage/StorageModule.java b/src/main/java/org/ebyhr/trino/storage/StorageModule.java index b28fb1c..c122e0a 100644 --- a/src/main/java/org/ebyhr/trino/storage/StorageModule.java +++ b/src/main/java/org/ebyhr/trino/storage/StorageModule.java @@ -18,6 +18,7 @@ import com.google.inject.Binder; import com.google.inject.Module; import com.google.inject.Scopes; +import io.opentelemetry.api.OpenTelemetry; import io.trino.filesystem.TrinoFileSystemFactory; import io.trino.filesystem.hdfs.HdfsFileSystemFactory; import io.trino.spi.ptf.ConnectorTableFunction; @@ -57,6 +58,7 @@ public void configure(Binder binder) binder.bind(StoragePageSourceProvider.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(OpenTelemetry.class).toInstance(OpenTelemetry.noop()); jsonBinder(binder).addDeserializerBinding(Type.class).to(TypeDeserializer.class); jsonCodecBinder(binder).bindMapJsonCodec(String.class, listJsonCodec(StorageTable.class));