private void cleanWorkingDirectory(Path queryWorkingDir) throws IOException {
    FileSystem fs = FileSystem.get(getConf());
    fs.delete(queryWorkingDir, true);
  }
Kafka prefix to form the URI for authentication
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaStorageHandler.java