You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by da...@apache.org on 2014/04/04 00:18:25 UTC

svn commit: r1584427 - /pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezPOPackageAnnotator.java

Author: daijy
Date: Thu Apr  3 22:18:24 2014
New Revision: 1584427

URL: http://svn.apache.org/r1584427
Log:
PIG-3862: e2e test Rank_9 fail

Modified:
    pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezPOPackageAnnotator.java

Modified: pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezPOPackageAnnotator.java
URL: http://svn.apache.org/viewvc/pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezPOPackageAnnotator.java?rev=1584427&r1=1584426&r2=1584427&view=diff
==============================================================================
--- pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezPOPackageAnnotator.java (original)
+++ pig/branches/tez/src/org/apache/pig/backend/hadoop/executionengine/tez/TezPOPackageAnnotator.java Thu Apr  3 22:18:24 2014
@@ -176,6 +176,21 @@ public class TezPOPackageAnnotator exten
             pkg.getPkgr().setKeyTuple(lrearrange.isKeyTuple());
             pkg.getPkgr().setKeyCompound(lrearrange.isKeyCompound());
         }
+        
+        @Override
+        public void visitPOLocalRearrangeTez(POLocalRearrangeTez lrearrangeTez) throws VisitorException {
+            visitLocalRearrange(lrearrangeTez);
+        }
+        
+        @Override
+        public void visitIdentityInOutTez(POIdentityInOutTez identityInOutTez) throws VisitorException {
+            visitLocalRearrange(identityInOutTez);
+        }
+        
+        @Override
+        public void visitPOPartitionRearrangeTez(POPartitionRearrangeTez partitionRearrangeTez) throws VisitorException {
+            visitLocalRearrange(partitionRearrangeTez);
+        }
 
         /**
          * @return the loRearrangeFound