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