@Override public Void perform() throws Exception {
        cleanWorkingDirectory(queryWorkingDir);
        return null;
      }
Kafka prefix to form the URI for authentication
kafka-handler/src/java/org/apache/hadoop/hive/kafka/KafkaStorageHandler.java