diff --git druid-handler/src/java/org/apache/hadoop/hive/druid/io/HiveDruidSplit.java druid-handler/src/java/org/apache/hadoop/hive/druid/io/HiveDruidSplit.java index 58cb47a..a2e41f4 100644 --- druid-handler/src/java/org/apache/hadoop/hive/druid/io/HiveDruidSplit.java +++ druid-handler/src/java/org/apache/hadoop/hive/druid/io/HiveDruidSplit.java @@ -62,8 +62,13 @@ public String getDruidQuery() { } @Override + public String[] getLocations() throws IOException { + return hosts; + } + + @Override public String toString() { - return "HiveDruidSplit{" + druidQuery + ", " + return "HiveDruidSplit{" + druidQuery + ", " + (hosts == null ? "empty hosts" : Arrays.toString(hosts)) + "}"; }