Skip to content

Commit

Permalink
Fix typo in LocalExecutionPlanner
Browse files Browse the repository at this point in the history
  • Loading branch information
cberner committed Mar 30, 2015
1 parent b0e75ae commit 042d42f
Showing 1 changed file with 4 additions and 4 deletions.
Expand Up @@ -789,13 +789,13 @@ private PhysicalOperation visitScanFilterAndProject(
sourceTypes, sourceTypes,
concat(singleton(rewrittenFilter), rewrittenProjections)); concat(singleton(rewrittenFilter), rewrittenProjections));


RowExpression traslatedFilter = SqlToRowExpressionTranslator.translate(rewrittenFilter, expressionTypes, metadata, session, true); RowExpression translatedFilter = SqlToRowExpressionTranslator.translate(rewrittenFilter, expressionTypes, metadata, session, true);
List<RowExpression> translatedProjections = SqlToRowExpressionTranslator.translate(rewrittenProjections, expressionTypes, metadata, session, true); List<RowExpression> translatedProjections = SqlToRowExpressionTranslator.translate(rewrittenProjections, expressionTypes, metadata, session, true);


try { try {
if (columns != null) { if (columns != null) {
CursorProcessor cursorProcessor = compiler.compileCursorProcessor(traslatedFilter, translatedProjections, sourceNode.getId()); CursorProcessor cursorProcessor = compiler.compileCursorProcessor(translatedFilter, translatedProjections, sourceNode.getId());
PageProcessor pageProcessor = compiler.compilePageProcessor(traslatedFilter, translatedProjections); PageProcessor pageProcessor = compiler.compilePageProcessor(translatedFilter, translatedProjections);


SourceOperatorFactory operatorFactory = new ScanFilterAndProjectOperator.ScanFilterAndProjectOperatorFactory( SourceOperatorFactory operatorFactory = new ScanFilterAndProjectOperator.ScanFilterAndProjectOperatorFactory(
context.getNextOperatorId(), context.getNextOperatorId(),
Expand All @@ -809,7 +809,7 @@ private PhysicalOperation visitScanFilterAndProject(
return new PhysicalOperation(operatorFactory, outputMappings); return new PhysicalOperation(operatorFactory, outputMappings);
} }
else { else {
PageProcessor processor = compiler.compilePageProcessor(traslatedFilter, translatedProjections); PageProcessor processor = compiler.compilePageProcessor(translatedFilter, translatedProjections);


OperatorFactory operatorFactory = new FilterAndProjectOperator.FilterAndProjectOperatorFactory( OperatorFactory operatorFactory = new FilterAndProjectOperator.FilterAndProjectOperatorFactory(
context.getNextOperatorId(), context.getNextOperatorId(),
Expand Down

0 comments on commit 042d42f

Please sign in to comment.