You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by an...@apache.org on 2013/08/16 23:49:54 UTC
svn commit: r1514903 - in /pig/trunk: CHANGES.txt
src/org/apache/pig/newplan/logical/optimizer/LogicalPlanOptimizer.java
Author: aniket486
Date: Fri Aug 16 21:49:54 2013
New Revision: 1514903
URL: http://svn.apache.org/r1514903
Log:
PIG-3410: LimitOptimizer is applied before PartitionFilterOptimizer (aniket486)
Modified:
pig/trunk/CHANGES.txt
pig/trunk/src/org/apache/pig/newplan/logical/optimizer/LogicalPlanOptimizer.java
Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1514903&r1=1514902&r2=1514903&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Fri Aug 16 21:49:54 2013
@@ -212,6 +212,8 @@ PIG-3013: BinInterSedes improve chararra
BUG FIXES
+PIG-3410: LimitOptimizer is applied before PartitionFilterOptimizer (aniket486)
+
PIG-3405: Top UDF documentation indicates improper use (aniket486 via cheolsoo)
PIG-3425: Hive jdo api jar referenced in pig script throws error (deepesh via cheolsoo)
Modified: pig/trunk/src/org/apache/pig/newplan/logical/optimizer/LogicalPlanOptimizer.java
URL: http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/newplan/logical/optimizer/LogicalPlanOptimizer.java?rev=1514903&r1=1514902&r2=1514903&view=diff
==============================================================================
--- pig/trunk/src/org/apache/pig/newplan/logical/optimizer/LogicalPlanOptimizer.java (original)
+++ pig/trunk/src/org/apache/pig/newplan/logical/optimizer/LogicalPlanOptimizer.java Fri Aug 16 21:49:54 2013
@@ -112,15 +112,6 @@ public class LogicalPlanOptimizer extend
checkAndAddRule(s, r);
if (!s.isEmpty())
ls.add(s);
-
- // Limit Set
- // This set of rules push up limit
- s = new HashSet<Rule>();
- // Optimize limit
- r = new LimitOptimizer("LimitOptimizer");
- checkAndAddRule(s, r);
- if (!s.isEmpty())
- ls.add(s);
// Split Set
// This set of rules does splitting of operators only.
@@ -202,6 +193,15 @@ public class LogicalPlanOptimizer extend
if(!s.isEmpty())
ls.add(s);
+ // Limit Set
+ // This set of rules push up limit
+ s = new HashSet<Rule>();
+ // Optimize limit
+ r = new LimitOptimizer("LimitOptimizer");
+ checkAndAddRule(s, r);
+ if (!s.isEmpty())
+ ls.add(s);
+
return ls;
}