diff options
author | Tathagata Das <tathagata.das1565@gmail.com> | 2014-01-15 12:15:46 -0800 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2014-01-15 12:15:46 -0800 |
commit | 9e6375349e945fed87bbeae565f35ab9ca28f70f (patch) | |
tree | d6f41dc97121d6a99c4c057a55de687c6d11dcfe /streaming/src/test/java/org/apache | |
parent | 0e15bd7827d5acb5c1ccb071e358338817f95a79 (diff) | |
download | spark-9e6375349e945fed87bbeae565f35ab9ca28f70f.tar.gz spark-9e6375349e945fed87bbeae565f35ab9ca28f70f.tar.bz2 spark-9e6375349e945fed87bbeae565f35ab9ca28f70f.zip |
Made some classes private[stremaing] and deprecated a method in JavaStreamingContext.
Diffstat (limited to 'streaming/src/test/java/org/apache')
-rw-r--r-- | streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java b/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java index 8b7d7709bf..4fbbce9b8b 100644 --- a/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java +++ b/streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java @@ -297,9 +297,9 @@ public class JavaAPISuite extends LocalJavaStreamingContext implements Serializa Arrays.asList(7,8,9)); JavaSparkContext jsc = new JavaSparkContext(ssc.ssc().sc()); - JavaRDD<Integer> rdd1 = ssc.sc().parallelize(Arrays.asList(1, 2, 3)); - JavaRDD<Integer> rdd2 = ssc.sc().parallelize(Arrays.asList(4, 5, 6)); - JavaRDD<Integer> rdd3 = ssc.sc().parallelize(Arrays.asList(7,8,9)); + JavaRDD<Integer> rdd1 = ssc.sparkContext().parallelize(Arrays.asList(1, 2, 3)); + JavaRDD<Integer> rdd2 = ssc.sparkContext().parallelize(Arrays.asList(4, 5, 6)); + JavaRDD<Integer> rdd3 = ssc.sparkContext().parallelize(Arrays.asList(7,8,9)); LinkedList<JavaRDD<Integer>> rdds = Lists.newLinkedList(); rdds.add(rdd1); |