-
- Downloads
Upgrade Kafka 0.7.2 to Kafka 0.8.0-beta1 for Spark Streaming
Showing
- examples/pom.xml 22 additions, 6 deletionsexamples/pom.xml
- examples/src/main/java/org/apache/spark/streaming/examples/JavaKafkaWordCount.java 98 additions, 0 deletions...g/apache/spark/streaming/examples/JavaKafkaWordCount.java
- examples/src/main/scala/org/apache/spark/streaming/examples/KafkaWordCount.scala 15 additions, 13 deletions.../org/apache/spark/streaming/examples/KafkaWordCount.scala
- project/SparkBuild.scala 6 additions, 3 deletionsproject/SparkBuild.scala
- streaming/lib/org/apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.jar 0 additions, 0 deletions.../org/apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.jar
- streaming/lib/org/apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.jar.md5 0 additions, 1 deletion.../apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.jar.md5
- streaming/lib/org/apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.jar.sha1 0 additions, 1 deletion...apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.jar.sha1
- streaming/lib/org/apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.pom 0 additions, 9 deletions.../org/apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.pom
- streaming/lib/org/apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.pom.md5 0 additions, 1 deletion.../apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.pom.md5
- streaming/lib/org/apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.pom.sha1 0 additions, 1 deletion...apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.pom.sha1
- streaming/lib/org/apache/kafka/kafka/maven-metadata-local.xml 0 additions, 12 deletions...aming/lib/org/apache/kafka/kafka/maven-metadata-local.xml
- streaming/lib/org/apache/kafka/kafka/maven-metadata-local.xml.md5 0 additions, 1 deletion...g/lib/org/apache/kafka/kafka/maven-metadata-local.xml.md5
- streaming/lib/org/apache/kafka/kafka/maven-metadata-local.xml.sha1 0 additions, 1 deletion.../lib/org/apache/kafka/kafka/maven-metadata-local.xml.sha1
- streaming/pom.xml 21 additions, 11 deletionsstreaming/pom.xml
- streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala 14 additions, 6 deletions...n/scala/org/apache/spark/streaming/StreamingContext.scala
- streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala 21 additions, 12 deletions...pache/spark/streaming/api/java/JavaStreamingContext.scala
- streaming/src/main/scala/org/apache/spark/streaming/dstream/KafkaInputDStream.scala 36 additions, 25 deletions...rg/apache/spark/streaming/dstream/KafkaInputDStream.scala
- streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java 11 additions, 5 deletions...rc/test/java/org/apache/spark/streaming/JavaAPISuite.java
- streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala 6 additions, 2 deletions.../scala/org/apache/spark/streaming/InputStreamsSuite.scala
Loading
Please register or sign in to comment