Add main method to Kudu query runner

trinodb · Feb 23, 2022 · 46c3c5b · 46c3c5b
1 parent dd0b5dc
commit 46c3c5b
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 0 deletions.
diff --git a/plugin/trino-kudu/pom.xml b/plugin/trino-kudu/pom.xml
@@ -43,6 +43,12 @@
             <artifactId>log</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>io.airlift</groupId>
+            <artifactId>log-manager</artifactId>
+            <scope>compile</scope>
+        </dependency>
+
         <dependency>
             <groupId>io.airlift</groupId>
             <artifactId>units</artifactId>

diff --git a/plugin/trino-kudu/src/test/java/io/trino/plugin/kudu/KuduQueryRunnerFactory.java b/plugin/trino-kudu/src/test/java/io/trino/plugin/kudu/KuduQueryRunnerFactory.java
@@ -16,6 +16,8 @@
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.ImmutableMap;
 import com.google.common.net.HostAndPort;
+import io.airlift.log.Logger;
+import io.airlift.log.Logging;
 import io.trino.Session;
 import io.trino.plugin.tpch.TpchPlugin;
 import io.trino.testing.DistributedQueryRunner;
@@ -152,4 +154,19 @@ public static Session createSession(String schema)
                 .setSchema(schema)
                 .build();
     }
+
+    public static void main(String[] args)
+            throws Exception
+    {
+        Logging.initialize();
+        DistributedQueryRunner queryRunner = (DistributedQueryRunner) createKuduQueryRunnerTpch(
+                new TestingKuduServer(),
+                Optional.empty(),
+                ImmutableMap.of(),
+                ImmutableMap.of("http-server.http.port", "8080"),
+                TpchTable.getTables());
+        Logger log = Logger.get(KuduQueryRunnerFactory.class);
+        log.info("======== SERVER STARTED ========");
+        log.info("\n====\n%s\n====", queryRunner.getCoordinator().getBaseUrl());
+    }
 }