in phoenix5-hive4/src/it/java/org/apache/hadoop/hive/ql/QTestSyntaxUtil.java [123:173]
private static int processLocalCmd(String cmd, CommandProcessor proc, CliSessionState ss) {
int ret = 0;
if (proc != null) {
String firstToken = cmd.trim().split("\\s+")[0];
String cmd1 = cmd.trim().substring(firstToken.length()).trim();
//CommandProcessorResponse res = proc.run(cmd_1);
if (proc instanceof ResetProcessor ||
proc instanceof CompileProcessor ||
proc instanceof ReloadProcessor ||
proc instanceof CryptoProcessor ||
proc instanceof AddResourceProcessor ||
proc instanceof ListResourceProcessor ||
proc instanceof LlapClusterResourceProcessor ||
proc instanceof LlapCacheResourceProcessor) {
if (cmd1.trim().split("\\s+").length < 1) {
ret = -1;
}
}
if (proc instanceof SetProcessor) {
if (!cmd1.contains("=")) {
ret = -1;
}
}
if (proc instanceof DfsProcessor) {
String[] argv = cmd1.trim().split("\\s+");
if ("-put".equals(firstToken) || "-test".equals(firstToken) ||
"-copyFromLocal".equals(firstToken) || "-moveFromLocal".equals(firstToken)) {
if (argv.length < 3) {
ret = -1;
}
} else if ("-get".equals(firstToken) ||
"-copyToLocal".equals(firstToken) || "-moveToLocal".equals(firstToken)) {
if (argv.length < 3) {
ret = -1;
}
} else if ("-mv".equals(firstToken) || "-cp".equals(firstToken)) {
if (argv.length < 3) {
ret = -1;
}
} else if ("-rm".equals(firstToken) || "-rmr".equals(firstToken) ||
"-cat".equals(firstToken) || "-mkdir".equals(firstToken) ||
"-touchz".equals(firstToken) || "-stat".equals(firstToken) ||
"-text".equals(firstToken)) {
if (argv.length < 2) {
ret = -1;
}
}
}
}
return ret;
}