Skip to content

Commit 0d2f4c7

Browse files
ankurdaveankurdave
committed
Organize imports
1 parent 43cf4a3 commit 0d2f4c7

File tree

5 files changed

+27
-95
lines changed

5 files changed

+27
-95
lines changed

‎graphx/src/main/scala/org/apache/spark/graphx/api/java/JavaEdgeRDD.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,13 +23,13 @@ import scala.collection.JavaConversions._
2323
import scala.language.implicitConversions
2424
import scala.reflect.ClassTag
2525

26+
import org.apache.spark.api.java.JavaPairRDD._
27+
import org.apache.spark.api.java.JavaRDD
2628
import org.apache.spark.api.java.JavaSparkContext.fakeClassTag
2729
import org.apache.spark.api.java.JavaUtils
2830
import org.apache.spark.api.java.function.{Function => JFunction, Function2 => JFunction2,
2931
Function3 => JFunction3, Function4 => JFunction4, _}
3032
import org.apache.spark.graphx._
31-
import org.apache.spark.api.java.JavaRDD
32-
import org.apache.spark.api.java.JavaPairRDD._
3333

3434
class JavaEdgeRDD[ED, VD](override val rdd: EdgeRDD[ED, VD])(
3535
implicit val edTag: ClassTag[ED], val vdTag: ClassTag[VD])

‎graphx/src/main/scala/org/apache/spark/graphx/api/java/JavaGraph.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,18 +24,18 @@ import scala.collection.JavaConversions._
2424
import scala.language.implicitConversions
2525
import scala.reflect.ClassTag
2626

27-
import org.apache.spark.api.java.JavaPairRDD
28-
import org.apache.spark.api.java.JavaUtils
2927
import com.google.common.base.Optional
28+
import org.apache.spark.api.java.JavaPairRDD
3029
import org.apache.spark.api.java.JavaPairRDD._
3130
import org.apache.spark.api.java.JavaRDD
3231
import org.apache.spark.api.java.JavaRDD._
3332
import org.apache.spark.api.java.JavaSparkContext.fakeClassTag
33+
import org.apache.spark.api.java.JavaUtils
3434
import org.apache.spark.api.java.function.{Function => JFunction, Function2 => JFunction2,
3535
Function3 => JFunction3, _}
3636
import org.apache.spark.graphx._
37-
import org.apache.spark.storage.StorageLevel
3837
import org.apache.spark.rdd.RDD
38+
import org.apache.spark.storage.StorageLevel
3939

4040
class JavaGraph[VD, ED](val graph: Graph[VD, ED])(
4141
implicit val vdTag: ClassTag[VD], implicit val edTag: ClassTag[ED]) extends Serializable {

‎graphx/src/test/java/org/apache/spark/graphx/JavaEdgeRDDSuite.java

Lines changed: 6 additions & 32 deletions
Original file line numberDiff line numberDiff line change
@@ -17,45 +17,19 @@
1717

1818
package org.apache.spark.graphx;
1919

20-
import java.io.*;
21-
import java.net.URI;
20+
import java.io.File;
21+
import java.io.Serializable;
2222
import java.util.*;
2323

24-
import scala.Tuple2;
25-
import scala.Tuple3;
26-
import scala.Tuple4;
27-
28-
import com.google.common.collect.Iterables;
29-
import com.google.common.collect.Iterators;
30-
import com.google.common.collect.Lists;
31-
import com.google.common.collect.Maps;
32-
import com.google.common.base.Optional;
33-
import com.google.common.base.Charsets;
3424
import com.google.common.io.Files;
35-
import org.apache.hadoop.io.IntWritable;
36-
import org.apache.hadoop.io.Text;
37-
import org.apache.hadoop.io.compress.DefaultCodec;
38-
import org.apache.hadoop.mapred.SequenceFileInputFormat;
39-
import org.apache.hadoop.mapred.SequenceFileOutputFormat;
40-
import org.apache.hadoop.mapreduce.Job;
41-
import org.junit.After;
42-
import org.junit.Assert;
43-
import org.junit.Before;
44-
import org.junit.Test;
45-
46-
import org.apache.spark.api.java.JavaDoubleRDD;
47-
import org.apache.spark.api.java.JavaPairRDD;
48-
import org.apache.spark.api.java.JavaRDD;
4925
import org.apache.spark.api.java.JavaSparkContext;
5026
import org.apache.spark.api.java.function.*;
51-
import org.apache.spark.executor.TaskMetrics;
52-
import org.apache.spark.partial.BoundedDouble;
53-
import org.apache.spark.partial.PartialResult;
54-
import org.apache.spark.storage.StorageLevel;
55-
import org.apache.spark.util.StatCounter;
56-
5727
import org.apache.spark.graphx.*;
5828
import org.apache.spark.graphx.api.java.*;
29+
import org.junit.After;
30+
import org.junit.Assert;
31+
import org.junit.Before;
32+
import org.junit.Test;
5933

6034
public class JavaEdgeRDDSuite implements Serializable {
6135
private transient JavaSparkContext sc;

‎graphx/src/test/java/org/apache/spark/graphx/JavaGraphSuite.java

Lines changed: 9 additions & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -17,45 +17,25 @@
1717

1818
package org.apache.spark.graphx;
1919

20-
import java.io.*;
21-
import java.net.URI;
20+
import java.io.File;
21+
import java.io.Serializable;
2222
import java.util.*;
2323

24-
import scala.Tuple2;
25-
import scala.Tuple3;
26-
import scala.Tuple4;
27-
28-
import com.google.common.collect.Iterables;
29-
import com.google.common.collect.Iterators;
30-
import com.google.common.collect.Lists;
31-
import com.google.common.collect.Maps;
3224
import com.google.common.base.Optional;
33-
import com.google.common.base.Charsets;
3425
import com.google.common.io.Files;
35-
import org.apache.hadoop.io.IntWritable;
36-
import org.apache.hadoop.io.Text;
37-
import org.apache.hadoop.io.compress.DefaultCodec;
38-
import org.apache.hadoop.mapred.SequenceFileInputFormat;
39-
import org.apache.hadoop.mapred.SequenceFileOutputFormat;
40-
import org.apache.hadoop.mapreduce.Job;
41-
import org.junit.After;
42-
import org.junit.Assert;
43-
import org.junit.Before;
44-
import org.junit.Test;
45-
46-
import org.apache.spark.api.java.JavaDoubleRDD;
4726
import org.apache.spark.api.java.JavaPairRDD;
4827
import org.apache.spark.api.java.JavaRDD;
4928
import org.apache.spark.api.java.JavaSparkContext;
5029
import org.apache.spark.api.java.function.*;
51-
import org.apache.spark.executor.TaskMetrics;
52-
import org.apache.spark.partial.BoundedDouble;
53-
import org.apache.spark.partial.PartialResult;
54-
import org.apache.spark.storage.StorageLevel;
55-
import org.apache.spark.util.StatCounter;
56-
5730
import org.apache.spark.graphx.*;
5831
import org.apache.spark.graphx.api.java.*;
32+
import org.apache.spark.storage.StorageLevel;
33+
import org.junit.After;
34+
import org.junit.Assert;
35+
import org.junit.Before;
36+
import org.junit.Test;
37+
import scala.Tuple2;
38+
import scala.Tuple4;
5939

6040
public class JavaGraphSuite implements Serializable {
6141
private transient JavaSparkContext sc;

‎graphx/src/test/java/org/apache/spark/graphx/JavaVertexRDDSuite.java

Lines changed: 7 additions & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -17,45 +17,23 @@
1717

1818
package org.apache.spark.graphx;
1919

20-
import java.io.*;
21-
import java.net.URI;
20+
import java.io.File;
21+
import java.io.Serializable;
2222
import java.util.*;
2323

24-
import scala.Tuple2;
25-
import scala.Tuple3;
26-
import scala.Tuple4;
27-
28-
import com.google.common.collect.Iterables;
29-
import com.google.common.collect.Iterators;
30-
import com.google.common.collect.Lists;
31-
import com.google.common.collect.Maps;
3224
import com.google.common.base.Optional;
33-
import com.google.common.base.Charsets;
3425
import com.google.common.io.Files;
35-
import org.apache.hadoop.io.IntWritable;
36-
import org.apache.hadoop.io.Text;
37-
import org.apache.hadoop.io.compress.DefaultCodec;
38-
import org.apache.hadoop.mapred.SequenceFileInputFormat;
39-
import org.apache.hadoop.mapred.SequenceFileOutputFormat;
40-
import org.apache.hadoop.mapreduce.Job;
41-
import org.junit.After;
42-
import org.junit.Assert;
43-
import org.junit.Before;
44-
import org.junit.Test;
45-
46-
import org.apache.spark.api.java.JavaDoubleRDD;
4726
import org.apache.spark.api.java.JavaPairRDD;
4827
import org.apache.spark.api.java.JavaRDD;
4928
import org.apache.spark.api.java.JavaSparkContext;
5029
import org.apache.spark.api.java.function.*;
51-
import org.apache.spark.executor.TaskMetrics;
52-
import org.apache.spark.partial.BoundedDouble;
53-
import org.apache.spark.partial.PartialResult;
54-
import org.apache.spark.storage.StorageLevel;
55-
import org.apache.spark.util.StatCounter;
56-
5730
import org.apache.spark.graphx.*;
5831
import org.apache.spark.graphx.api.java.*;
32+
import org.junit.After;
33+
import org.junit.Assert;
34+
import org.junit.Before;
35+
import org.junit.Test;
36+
import scala.Tuple2;
5937

6038
public class JavaVertexRDDSuite implements Serializable {
6139
private transient JavaSparkContext sc;

0 commit comments

Comments
 (0)