diff options
author | seanm <sean.mcnamara@webtrends.com> | 2013-03-24 13:40:19 -0600 |
---|---|---|
committer | seanm <sean.mcnamara@webtrends.com> | 2013-04-16 17:17:16 -0600 |
commit | 7e56e99573b4cf161293e648aeb159375c9c0fcb (patch) | |
tree | 9fa6d9f686cb39b3bb9a97196818079a71a38b31 /streaming/src/test | |
parent | 8ac9efba5a435443be9abf8ebbe867806d42c9db (diff) | |
download | spark-7e56e99573b4cf161293e648aeb159375c9c0fcb.tar.gz spark-7e56e99573b4cf161293e648aeb159375c9c0fcb.tar.bz2 spark-7e56e99573b4cf161293e648aeb159375c9c0fcb.zip |
Surfacing decoders on KafkaInputDStream
Diffstat (limited to 'streaming/src/test')
-rw-r--r-- | streaming/src/test/java/spark/streaming/JavaAPISuite.java | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/streaming/src/test/java/spark/streaming/JavaAPISuite.java b/streaming/src/test/java/spark/streaming/JavaAPISuite.java index 3bed500f73..61e4c0a207 100644 --- a/streaming/src/test/java/spark/streaming/JavaAPISuite.java +++ b/streaming/src/test/java/spark/streaming/JavaAPISuite.java @@ -23,7 +23,6 @@ import spark.streaming.api.java.JavaPairDStream; import spark.streaming.api.java.JavaStreamingContext; import spark.streaming.JavaTestUtils; import spark.streaming.JavaCheckpointTestUtils; -import spark.streaming.dstream.KafkaPartitionKey; import spark.streaming.InputStreamsSuite; import java.io.*; @@ -1203,10 +1202,9 @@ public class JavaAPISuite implements Serializable { @Test public void testKafkaStream() { HashMap<String, Integer> topics = Maps.newHashMap(); - HashMap<KafkaPartitionKey, Long> offsets = Maps.newHashMap(); JavaDStream test1 = ssc.kafkaStream("localhost:12345", "group", topics); - JavaDStream test2 = ssc.kafkaStream("localhost:12345", "group", topics, offsets); - JavaDStream test3 = ssc.kafkaStream("localhost:12345", "group", topics, offsets, + JavaDStream test2 = ssc.kafkaStream("localhost:12345", "group", topics); + JavaDStream test3 = ssc.kafkaStream("localhost:12345", "group", topics, StorageLevel.MEMORY_AND_DISK()); } |