Author: xuefu
Date: Wed Jun 17 02:04:40 2015
New Revision: 1685925
URL: http://svn.apache.org/r1685925
Log:
PIG-4604: Clean up: refactor the package import order in the files under
pig/src/org/apache/pig/backend/hadoop/executionengine/spark according to
certain rule (Liyun via Xuefu)
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/DistinctConverter.java
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/FRJoinConverter.java
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/FilterConverter.java
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/GlobalRearrangeConverter.java
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/LoadConverter.java
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/LocalRearrangeConverter.java
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/MergeJoinConverter.java
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/PackageConverter.java
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/RankConverter.java
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SkewedJoinConverter.java
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SortConverter.java
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SplitConverter.java
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/StoreConverter.java
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/StreamConverter.java
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/UnionConverter.java
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/DistinctConverter.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/DistinctConverter.java?rev=1685925&r1=1685924&r2=1685925&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/DistinctConverter.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/DistinctConverter.java
Wed Jun 17 02:04:40 2015
@@ -21,6 +21,10 @@ import java.io.IOException;
import java.io.Serializable;
import java.util.List;
+import scala.Tuple2;
+import scala.runtime.AbstractFunction1;
+import scala.runtime.AbstractFunction2;
+
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.PODistinct;
@@ -29,10 +33,6 @@ import org.apache.pig.data.Tuple;
import org.apache.spark.rdd.PairRDDFunctions;
import org.apache.spark.rdd.RDD;
-import scala.Tuple2;
-import scala.runtime.AbstractFunction1;
-import scala.runtime.AbstractFunction2;
-
@SuppressWarnings({ "serial" })
public class DistinctConverter implements RDDConverter<Tuple, Tuple,
PODistinct> {
private static final Log LOG = LogFactory.getLog(DistinctConverter.class);
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/FRJoinConverter.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/FRJoinConverter.java?rev=1685925&r1=1685924&r2=1685925&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/FRJoinConverter.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/FRJoinConverter.java
Wed Jun 17 02:04:40 2015
@@ -19,28 +19,29 @@ package org.apache.pig.backend.hadoop.ex
import java.io.IOException;
import java.io.Serializable;
-import java.util.List;
import java.util.Iterator;
+import java.util.List;
+
+import scala.Tuple2;
+import scala.runtime.AbstractFunction1;
-import com.google.common.base.Optional;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.pig.PigException;
import org.apache.pig.backend.executionengine.ExecException;
import org.apache.pig.backend.hadoop.executionengine.physicalLayer.POStatus;
-import
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFRJoin;
import org.apache.pig.backend.hadoop.executionengine.physicalLayer.Result;
+import
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFRJoin;
import org.apache.pig.backend.hadoop.executionengine.spark.SparkUtil;
import org.apache.pig.data.Tuple;
import org.apache.pig.data.TupleFactory;
-import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaPairRDD;
+import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.function.FlatMapFunction;
import org.apache.spark.api.java.function.PairFunction;
import org.apache.spark.rdd.RDD;
-import scala.Tuple2;
-import scala.runtime.AbstractFunction1;
+import com.google.common.base.Optional;
@SuppressWarnings("serial")
public class FRJoinConverter implements
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/FilterConverter.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/FilterConverter.java?rev=1685925&r1=1685924&r2=1685925&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/FilterConverter.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/FilterConverter.java
Wed Jun 17 02:04:40 2015
@@ -20,14 +20,14 @@ package org.apache.pig.backend.hadoop.ex
import java.io.Serializable;
import java.util.List;
+import scala.runtime.AbstractFunction1;
+
import org.apache.pig.backend.executionengine.ExecException;
import org.apache.pig.backend.hadoop.executionengine.physicalLayer.POStatus;
import org.apache.pig.backend.hadoop.executionengine.physicalLayer.Result;
import
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFilter;
import org.apache.pig.backend.hadoop.executionengine.spark.SparkUtil;
import org.apache.pig.data.Tuple;
-
-import scala.runtime.AbstractFunction1;
import org.apache.spark.rdd.RDD;
/**
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/GlobalRearrangeConverter.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/GlobalRearrangeConverter.java?rev=1685925&r1=1685924&r2=1685925&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/GlobalRearrangeConverter.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/GlobalRearrangeConverter.java
Wed Jun 17 02:04:40 2015
@@ -24,6 +24,12 @@ import java.util.Comparator;
import java.util.Iterator;
import java.util.List;
+import scala.Product2;
+import scala.Tuple2;
+import scala.collection.JavaConversions;
+import scala.collection.Seq;
+import scala.runtime.AbstractFunction1;
+
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.pig.backend.executionengine.ExecException;
@@ -40,12 +46,6 @@ import org.apache.spark.api.java.functio
import org.apache.spark.rdd.CoGroupedRDD;
import org.apache.spark.rdd.RDD;
-import scala.Product2;
-import scala.Tuple2;
-import scala.collection.JavaConversions;
-import scala.collection.Seq;
-import scala.runtime.AbstractFunction1;
-
@SuppressWarnings({ "serial" })
public class GlobalRearrangeConverter implements
RDDConverter<Tuple, Tuple, POGlobalRearrangeSpark> {
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/LoadConverter.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/LoadConverter.java?rev=1685925&r1=1685924&r2=1685925&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/LoadConverter.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/LoadConverter.java
Wed Jun 17 02:04:40 2015
@@ -17,8 +17,6 @@
*/
package org.apache.pig.backend.hadoop.executionengine.spark.converter;
-import com.google.common.collect.Lists;
-
import java.io.File;
import java.io.IOException;
import java.io.Serializable;
@@ -27,6 +25,10 @@ import java.util.ArrayList;
import java.util.List;
import java.util.Map;
+import scala.Function1;
+import scala.Tuple2;
+import scala.runtime.AbstractFunction1;
+
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.io.Text;
@@ -43,12 +45,10 @@ import org.apache.pig.impl.PigContext;
import org.apache.pig.impl.io.FileSpec;
import org.apache.pig.impl.plan.OperatorKey;
import org.apache.pig.impl.util.ObjectSerializer;
-import org.apache.spark.rdd.RDD;
import org.apache.spark.SparkContext;
+import org.apache.spark.rdd.RDD;
-import scala.Function1;
-import scala.Tuple2;
-import scala.runtime.AbstractFunction1;
+import com.google.common.collect.Lists;
/**
* Converter that loads data via POLoad and converts it to RRD<Tuple>.
Abuses
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/LocalRearrangeConverter.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/LocalRearrangeConverter.java?rev=1685925&r1=1685924&r2=1685925&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/LocalRearrangeConverter.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/LocalRearrangeConverter.java
Wed Jun 17 02:04:40 2015
@@ -21,6 +21,8 @@ import java.io.IOException;
import java.io.Serializable;
import java.util.List;
+import scala.runtime.AbstractFunction1;
+
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.pig.backend.executionengine.ExecException;
@@ -29,8 +31,6 @@ import org.apache.pig.backend.hadoop.exe
import
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POLocalRearrange;
import org.apache.pig.backend.hadoop.executionengine.spark.SparkUtil;
import org.apache.pig.data.Tuple;
-
-import scala.runtime.AbstractFunction1;
import org.apache.spark.rdd.RDD;
@SuppressWarnings({ "serial" })
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/MergeJoinConverter.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/MergeJoinConverter.java?rev=1685925&r1=1685924&r2=1685925&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/MergeJoinConverter.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/MergeJoinConverter.java
Wed Jun 17 02:04:40 2015
@@ -19,8 +19,11 @@ package org.apache.pig.backend.hadoop.ex
import java.io.IOException;
import java.io.Serializable;
-import java.util.List;
import java.util.Iterator;
+import java.util.List;
+
+import scala.Tuple2;
+import scala.runtime.AbstractFunction1;
import org.apache.pig.PigException;
import org.apache.pig.backend.executionengine.ExecException;
@@ -30,15 +33,11 @@ import org.apache.pig.backend.hadoop.exe
import org.apache.pig.backend.hadoop.executionengine.spark.SparkUtil;
import org.apache.pig.data.Tuple;
import org.apache.pig.data.TupleFactory;
-import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaPairRDD;
+import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.function.FlatMapFunction;
import org.apache.spark.rdd.RDD;
-import scala.Tuple2;
-import scala.runtime.AbstractFunction1;
-
-
@SuppressWarnings("serial")
public class MergeJoinConverter implements
RDDConverter<Tuple, Tuple, POMergeJoin> {
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/PackageConverter.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/PackageConverter.java?rev=1685925&r1=1685924&r2=1685925&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/PackageConverter.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/PackageConverter.java
Wed Jun 17 02:04:40 2015
@@ -22,6 +22,8 @@ import java.io.Serializable;
import java.util.Iterator;
import java.util.List;
+import scala.runtime.AbstractFunction1;
+
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.mapred.JobConf;
@@ -37,8 +39,6 @@ import org.apache.pig.impl.io.NullableTu
import org.apache.pig.impl.io.PigNullableWritable;
import org.apache.spark.rdd.RDD;
-import scala.runtime.AbstractFunction1;
-
@SuppressWarnings({ "serial" })
public class PackageConverter implements RDDConverter<Tuple, Tuple, POPackage>
{
private static final Log LOG = LogFactory.getLog(PackageConverter.class);
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/RankConverter.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/RankConverter.java?rev=1685925&r1=1685924&r2=1685925&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/RankConverter.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/RankConverter.java
Wed Jun 17 02:04:40 2015
@@ -23,6 +23,8 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import scala.Tuple2;
+
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.pig.backend.executionengine.ExecException;
@@ -36,8 +38,6 @@ import org.apache.spark.api.java.functio
import org.apache.spark.api.java.function.PairFunction;
import org.apache.spark.rdd.RDD;
-import scala.Tuple2;
-
public class RankConverter implements RDDConverter<Tuple, Tuple, PORank> {
private static final Log LOG = LogFactory.getLog(RankConverter.class);
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SkewedJoinConverter.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SkewedJoinConverter.java?rev=1685925&r1=1685924&r2=1685925&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SkewedJoinConverter.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SkewedJoinConverter.java
Wed Jun 17 02:04:40 2015
@@ -22,6 +22,9 @@ import java.io.Serializable;
import java.util.Iterator;
import java.util.List;
+import scala.Tuple2;
+import scala.runtime.AbstractFunction1;
+
import org.apache.pig.backend.executionengine.ExecException;
import
org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator;
import org.apache.pig.backend.hadoop.executionengine.physicalLayer.Result;
@@ -41,9 +44,6 @@ import org.apache.spark.api.java.JavaRDD
import org.apache.spark.api.java.function.FlatMapFunction;
import org.apache.spark.rdd.RDD;
-import scala.Tuple2;
-import scala.runtime.AbstractFunction1;
-
public class SkewedJoinConverter implements
RDDConverter<Tuple, Tuple, POSkewedJoin>, Serializable {
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SortConverter.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SortConverter.java?rev=1685925&r1=1685924&r2=1685925&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SortConverter.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SortConverter.java
Wed Jun 17 02:04:40 2015
@@ -22,18 +22,16 @@ import java.io.Serializable;
import java.util.Iterator;
import java.util.List;
+import scala.Tuple2;
+import scala.runtime.AbstractFunction1;
+
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSort;
-import
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSort.SortComparator;
import org.apache.pig.backend.hadoop.executionengine.spark.SparkUtil;
import org.apache.pig.data.Tuple;
-
-import scala.Tuple2;
-import scala.runtime.AbstractFunction1;
-
-import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaPairRDD;
+import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.function.FlatMapFunction;
import org.apache.spark.rdd.RDD;
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SplitConverter.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SplitConverter.java?rev=1685925&r1=1685924&r2=1685925&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SplitConverter.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SplitConverter.java
Wed Jun 17 02:04:40 2015
@@ -20,11 +20,9 @@ package org.apache.pig.backend.hadoop.ex
import java.io.IOException;
import java.util.List;
-import
org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator;
import
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POSplit;
import org.apache.pig.backend.hadoop.executionengine.spark.SparkUtil;
import org.apache.pig.data.Tuple;
-
import org.apache.spark.rdd.RDD;
public class SplitConverter implements RDDConverter<Tuple, Tuple, POSplit> {
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/StoreConverter.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/StoreConverter.java?rev=1685925&r1=1685924&r2=1685925&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/StoreConverter.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/StoreConverter.java
Wed Jun 17 02:04:40 2015
@@ -17,12 +17,12 @@
*/
package org.apache.pig.backend.hadoop.executionengine.spark.converter;
-import com.google.common.collect.Lists;
-
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
+import scala.Tuple2;
+
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.fs.Path;
@@ -30,6 +30,7 @@ import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapred.FileOutputFormat;
import org.apache.hadoop.mapred.JobConf;
import org.apache.hadoop.mapreduce.Job;
+import org.apache.hadoop.mapreduce.lib.output.LazyOutputFormat;
import org.apache.pig.PigConfiguration;
import org.apache.pig.StoreFuncInterface;
import
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobControlCompiler;
@@ -44,9 +45,8 @@ import org.apache.spark.api.java.JavaRDD
import org.apache.spark.api.java.function.Function;
import org.apache.spark.rdd.PairRDDFunctions;
import org.apache.spark.rdd.RDD;
-import org.apache.hadoop.mapreduce.lib.output.LazyOutputFormat;
-import scala.Tuple2;
+import com.google.common.collect.Lists;
/**
* Converter that takes a POStore and stores it's content.
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/StreamConverter.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/StreamConverter.java?rev=1685925&r1=1685924&r2=1685925&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/StreamConverter.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/StreamConverter.java
Wed Jun 17 02:04:40 2015
@@ -34,8 +34,8 @@ import org.apache.pig.data.SchemaTupleBa
import org.apache.pig.data.Tuple;
import org.apache.pig.impl.PigContext;
import org.apache.pig.impl.util.ObjectSerializer;
-import org.apache.spark.rdd.RDD;
import org.apache.spark.api.java.function.FlatMapFunction;
+import org.apache.spark.rdd.RDD;
public class StreamConverter implements
RDDConverter<Tuple, Tuple, POStream> {
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/UnionConverter.java
URL:
http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/UnionConverter.java?rev=1685925&r1=1685924&r2=1685925&view=diff
==============================================================================
---
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/UnionConverter.java
(original)
+++
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/UnionConverter.java
Wed Jun 17 02:04:40 2015
@@ -20,14 +20,14 @@ package org.apache.pig.backend.hadoop.ex
import java.io.IOException;
import java.util.List;
+import scala.collection.JavaConversions;
+
import
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POUnion;
import org.apache.pig.backend.hadoop.executionengine.spark.SparkUtil;
import org.apache.pig.data.Tuple;
-
-import scala.collection.JavaConversions;
-import org.apache.spark.rdd.UnionRDD;
-import org.apache.spark.rdd.RDD;
import org.apache.spark.SparkContext;
+import org.apache.spark.rdd.RDD;
+import org.apache.spark.rdd.UnionRDD;
public class UnionConverter implements RDDConverter<Tuple, Tuple, POUnion> {
