Author: xuefu
Date: Thu May 21 04:05:17 2015
New Revision: 1680729
URL: http://svn.apache.org/r1680729
Log:
PIG-4557: Fix POGlobalRearrangeSpark copy constructor for Spark engine (Mohit
via Xuefu)
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POGlobalRearrange.java
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/operator/POGlobalRearrangeSpark.java
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POGlobalRearrange.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POGlobalRearrange.java?rev=1680729&r1=1680728&r2=1680729&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POGlobalRearrange.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/physicalLayer/relationalOperators/POGlobalRearrange.java
Thu May 21 04:05:17 2015
@@ -74,7 +74,13 @@ public class POGlobalRearrange extends P
public POGlobalRearrange(OperatorKey k, int rp, List inp) {
super(k, rp, inp);
}
-
+
+ public POGlobalRearrange(POGlobalRearrange copy) throws ExecException {
+ super(copy);
+ this.cross = copy.cross;
+ this.customPartitioner = copy.customPartitioner;
+ }
+
@Override
public void visit(PhyPlanVisitor v) throws VisitorException {
v.visitGlobalRearrange(this);
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/operator/POGlobalRearrangeSpark.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/operator/POGlobalRearrangeSpark.java?rev=1680729&r1=1680728&r2=1680729&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/operator/POGlobalRearrangeSpark.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/operator/POGlobalRearrangeSpark.java
Thu May 21 04:05:17 2015
@@ -17,6 +17,7 @@
*/
package org.apache.pig.backend.hadoop.executionengine.spark.operator;
+import org.apache.pig.backend.executionengine.ExecException;
import
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POGlobalRearrange;
/**
@@ -28,8 +29,9 @@ public class POGlobalRearrangeSpark exte
// Sort order for secondary keys;
private boolean[] secondarySortOrder;
- public POGlobalRearrangeSpark(POGlobalRearrange copy) {
- super(copy.getOperatorKey());
+ public POGlobalRearrangeSpark(POGlobalRearrange copy)
+ throws ExecException {
+ super(copy);
}
public boolean isUseSecondaryKey() {
