Method processPig

src/org/apache/pig/parser/DryRunGruntParser.java:246–320

(String cmd)

    }

    @Override
    protected void processPig(String cmd) throws IOException {
        
        int start = getLineNumber();
       
        StringBuilder blder = new StringBuilder();
        for (int i = 1; i < start; i++) {
            blder.append("\n");            
        }
        
        if (cmd.charAt(cmd.length() - 1) != ';') {
            cmd += ";";
        }
        
        blder.append(cmd);
        cmd = blder.toString();
        
        CommonTokenStream tokenStream = QueryParserDriver.tokenize(cmd, source);
        Tree ast = null;

        try {
            ast = QueryParserDriver.parse( tokenStream );
        } catch(RuntimeException ex) {
            throw new ParserException( ex.getMessage() );
        }    

        if (!hasMacro) {
            List<CommonTree> importNodes = new ArrayList<CommonTree>();
            List<CommonTree> macroNodes = new ArrayList<CommonTree>();
            List<CommonTree> inlineNodes = new ArrayList<CommonTree>();
            
            QueryParserDriver.traverseImport(ast, importNodes);
            QueryParserDriver.traverse(ast, macroNodes, inlineNodes);
            
            if (!importNodes.isEmpty() || !macroNodes.isEmpty()
                            || !inlineNodes.isEmpty()) {
                hasMacro = true;
            }
        }

        if (parserTree == null) {
            parserTree = ast;
        } else {
            int n = ast.getChildCount();
            for (int i = 0; i < n; i++) {
                parserTree.addChild(ast.getChild(i));
            }
        }
 
        CommonTree dup = (CommonTree)parserTree.dupNode();
        dup.addChildren(((CommonTree)parserTree).getChildren());

        QueryParserDriver driver = new QueryParserDriver(context, "0",
                new HashMap<String, String>());
        Tree newAst = driver.expandMacro(dup);
        
        CommonTreeNodeStream nodes = new CommonTreeNodeStream( newAst );
        AstPrinter walker = new AstPrinter( nodes );