AppImpala.java 文件源码

/**
 * Special case: STORE operator.
 * 
 * @param queryArray
 * @param i
 * @param file
 * @return
 * @throws Exception
 */
public static ResultSet storeOperator(String[] queryArray, int i, boolean file) throws Exception {
    ParseTree tree = TriALQLParseQuery.parse(queryArray[i] + ";", file);
    TriALQLClassListener extractor = new TriALQLClassListener();
    ParseTreeWalker.DEFAULT.walk(extractor, tree);

    theLastQuery = true;
    if (QueryStruct.oldTableName.get(i).equals(QueryStruct.newTableName.get(i))) {
        // results = ImpalaDaemon.main(QueryStruct.baseQuery.get(i - 1));
        notToDrop = QueryStruct.newTableName.get(i);
    } else {
        parseTree = false;
        queryExecutor(queryArray[i] + ";", file, theLastQuery, parseTree);

        results = ImpalaDaemon.main(QueryStruct.baseQuery.get(i));
    }
    return results;
}