Package org.apache.pig.impl.logicalLayer

Examples of org.apache.pig.impl.logicalLayer.ExpressionOperator

346
347
348
349
350
351
352
353
354
355
356
       
        exprOpsMap.put(colOp, op);
    }

    public void visit(LOAnd binOp) throws VisitorException {
        ExpressionOperator left = binOp.getLhsOperand();
        ExpressionOperator right = binOp.getRhsOperand();
               
        AndExpression ae = new AndExpression(exprPlan, exprOpsMap.get(left), exprOpsMap.get(right));
        exprOpsMap.put(binOp, ae);           
    }
View Full Code Here
354
355
356
357
358
359
360
361
362
363
364
        AndExpression ae = new AndExpression(exprPlan, exprOpsMap.get(left), exprOpsMap.get(right));
        exprOpsMap.put(binOp, ae);           
    }

    public void visit(LOOr binOp) throws VisitorException {
        ExpressionOperator left = binOp.getLhsOperand();
        ExpressionOperator right = binOp.getRhsOperand();
               
        OrExpression ae = new OrExpression(exprPlan, exprOpsMap.get(left), exprOpsMap.get(right));
        exprOpsMap.put(binOp, ae);
    }
View Full Code Here
362
363
364
365
366
367
368
369
370
        OrExpression ae = new OrExpression(exprPlan, exprOpsMap.get(left), exprOpsMap.get(right));
        exprOpsMap.put(binOp, ae);
    }

    public void visit(LONot uniOp) throws VisitorException {
        ExpressionOperator exp = uniOp.getOperand();
        NotExpression not = new NotExpression(exprPlan, exprOpsMap.get(exp));
        exprOpsMap.put(uniOp, not);
    }
View Full Code Here
368
369
370
371
372
373
374
375
376
        NotExpression not = new NotExpression(exprPlan, exprOpsMap.get(exp));
        exprOpsMap.put(uniOp, not);
    }

    public void visit(LOIsNull uniOp) throws VisitorException {
        ExpressionOperator exp = uniOp.getOperand();
        IsNullExpression isNull = new IsNullExpression(exprPlan, exprOpsMap.get(exp));
        exprOpsMap.put(uniOp, isNull);
    }
View Full Code Here
783
784
785
786
787
788
789
790
791
792
793
    }

    void GenerateMatchingTupleHelper(Tuple t, LOAnd op, boolean invert)
            throws ExecException {
        ExpressionOperator input = op.getLhsOperand();
        GenerateMatchingTupleHelper(t, input, invert);
        input = op.getRhsOperand();
        GenerateMatchingTupleHelper(t, input, invert);

    }
View Full Code Here
792
793
794
795
796
797
798
799
800
801
802
    }

    void GenerateMatchingTupleHelper(Tuple t, LOOr op, boolean invert)
            throws ExecException {
        ExpressionOperator input = op.getLhsOperand();
        GenerateMatchingTupleHelper(t, input, invert);
        input = op.getRhsOperand();
        GenerateMatchingTupleHelper(t, input, invert);

    }
View Full Code Here
801
802
803
804
805
806
807
808
809
    }

    void GenerateMatchingTupleHelper(Tuple t, LONot op, boolean invert)
            throws ExecException {
        ExpressionOperator input = op.getOperand();
        GenerateMatchingTupleHelper(t, input, !invert);

    }
View Full Code Here
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
    }

    @Override
    public void visit(LOMod binOp) throws VisitorException {
        ExpressionOperator lhs = binOp.getLhsOperand() ;
        ExpressionOperator rhs = binOp.getRhsOperand() ;

        byte lhsType = lhs.getType() ;
        byte rhsType = rhs.getType() ;

        if ( (lhsType == DataType.INTEGER) &&
             (rhsType == DataType.INTEGER)
           ) {
           //do nothing
View Full Code Here
2515
2516
2517
2518
2519
2520
2521
2522
2523
2524
2525
2526
        if (leaves.size() > 1) {
            int errCode = 2060;
            String msg = "Expected one leaf. Found " + leaves.size() + " leaves.";
            throw new TypeCheckerException(msg, errCode, PigException.BUG);
        }
        ExpressionOperator currentOutput = (ExpressionOperator) leaves.get(0);
        collectCastWarning(frj, currentOutput.getType(), toType);
        OperatorKey newKey = genNewOperatorKey(currentOutput);
        LOCast cast = new LOCast(innerPlan, newKey, toType);
        innerPlan.add(cast);
        try {
            innerPlan.connect(currentOutput, cast);
View Full Code Here
2549
2550
2551
2552
2553
2554
2555
2556
2557
2558
2559
2560
        if (leaves.size() > 1) {
            int errCode = 2060;
            String msg = "Expected one leaf. Found " + leaves.size() + " leaves.";
            throw new TypeCheckerException(msg, errCode, PigException.BUG);
        }
        ExpressionOperator currentOutput = (ExpressionOperator) leaves.get(0) ;
        collectCastWarning(cg, currentOutput.getType(), toType) ;
        OperatorKey newKey = genNewOperatorKey(currentOutput) ;
        LOCast cast = new LOCast(innerPlan, newKey, toType) ;
        innerPlan.add(cast) ;
        try {
            innerPlan.connect(currentOutput, cast) ;
View Full Code Here
TOP

Related Classes of org.apache.pig.impl.logicalLayer.ExpressionOperator

  • org.apache.pig.experimental.logical.LogicalPlanMigrationVistor$LogicalExpPlanMigrationVistor
  • org.apache.pig.impl.logicalLayer.optimizer.PruneColumns
  • org.apache.pig.impl.logicalLayer.validators.TypeCheckingVisitor
  • org.apache.pig.newplan.logical.LogicalExpPlanMigrationVistor
  • org.apache.pig.pen.AugmentBaseDataVisitor
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.