private Path getQueryWorkingDir(Table table) {
    return new Path(table.getSd().getLocation(), getQueryId());
  }
Kafka prefix to form the URI for authentication
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaStorageHandler.java