diff --git a/integration-tests/src/main/java/org/apache/druid/quidem/Launcher.java b/integration-tests/src/main/java/org/apache/druid/quidem/Launcher.java index 48ff2daf001..5cc9009c427 100644 --- a/integration-tests/src/main/java/org/apache/druid/quidem/Launcher.java +++ b/integration-tests/src/main/java/org/apache/druid/quidem/Launcher.java @@ -47,8 +47,6 @@ import static org.junit.Assert.assertNotEquals; public class Launcher { - public static final String URI_PREFIX = "druidtest://"; - public static final String DEFAULT_URI = URI_PREFIX + "/"; static final SqlTestFrameworkConfigStore CONFIG_STORE = new SqlTestFrameworkConfigStore(); private static Logger log = new Logger(Launcher.class); diff --git a/integration-tests/src/main/java/org/apache/druid/quidem/QuidemRecorder.java b/integration-tests/src/main/java/org/apache/druid/quidem/QuidemRecorder.java index 0178ab9797f..a5df03ef990 100644 --- a/integration-tests/src/main/java/org/apache/druid/quidem/QuidemRecorder.java +++ b/integration-tests/src/main/java/org/apache/druid/quidem/QuidemRecorder.java @@ -40,9 +40,9 @@ public class QuidemRecorder implements AutoCloseable, DruidHook } @Override - public void dispatch1(HookKey key, T object) + public void invoke(HookKey key, T object) { - if(DruidHook.SQL.equals(key)) { + if (DruidHook.SQL.equals(key)) { printStream.print(object); printStream.println(";"); printStream.println("!ok"); diff --git a/sql/src/test/java/org/apache/druid/quidem/DruidHook.java b/sql/src/test/java/org/apache/druid/quidem/DruidHook.java index 51d6775a685..8e955c6ec32 100644 --- a/sql/src/test/java/org/apache/druid/quidem/DruidHook.java +++ b/sql/src/test/java/org/apache/druid/quidem/DruidHook.java @@ -58,7 +58,7 @@ public interface DruidHook if (getClass() != obj.getClass()) { return false; } - HookKey other = (HookKey) obj; + HookKey other = (HookKey) obj; return Objects.equals(label, other.label) && Objects.equals(type, other.type); } @@ -67,7 +67,7 @@ public interface DruidHook public static final HookKey DRUID_PLAN = new HookKey<>("druidPlan", RelNode.class); public static final HookKey SQL = new HookKey<>("sql", String.class); - void dispatch1(HookKey key, T object); + void invoke(HookKey key, T object); static Map, List> GLOBAL = new HashMap<>(); @@ -99,7 +99,7 @@ public interface DruidHook List hooks = GLOBAL.get(key); if (hooks != null) { for (DruidHook hook : hooks) { - hook.dispatch1(key, object); + hook.invoke(key, object); } } }