-
- Downloads
[SPARK-1633][Streaming] Java API unit test and example for custom streaming receiver in Java
Author: Tathagata Das <tathagata.das1565@gmail.com> Closes #558 from tdas/more-fixes and squashes the following commits: c0c84e6 [Tathagata Das] Removing extra println() d8a8cf4 [Tathagata Das] More tweaks to make unit test work in Jenkins. b7caa98 [Tathagata Das] More tweaks. d337367 [Tathagata Das] More tweaks 22d6f2d [Tathagata Das] Merge remote-tracking branch 'apache/master' into more-fixes 40a961b [Tathagata Das] Modified java test to reduce flakiness. 9410ca6 [Tathagata Das] Merge remote-tracking branch 'apache/master' into more-fixes 86d9147 [Tathagata Das] scala style fix 2f3d7b1 [Tathagata Das] Added Scala custom receiver example. d677611 [Tathagata Das] Merge remote-tracking branch 'apache/master' into more-fixes bec3fc2 [Tathagata Das] Added license. 51d6514 [Tathagata Das] Fixed docs on receiver. 81aafa0 [Tathagata Das] Added Java test for Receiver API, and added JavaCustomReceiver example.
Showing
- examples/src/main/java/org/apache/spark/streaming/examples/JavaCustomReceiver.java 152 additions, 0 deletions...g/apache/spark/streaming/examples/JavaCustomReceiver.java
- examples/src/main/java/org/apache/spark/streaming/examples/JavaNetworkWordCount.java 1 addition, 4 deletions...apache/spark/streaming/examples/JavaNetworkWordCount.java
- examples/src/main/scala/org/apache/spark/streaming/examples/CustomReceiver.scala 108 additions, 0 deletions.../org/apache/spark/streaming/examples/CustomReceiver.scala
- streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala 1 addition, 1 deletion...pache/spark/streaming/api/java/JavaStreamingContext.scala
- streaming/src/main/scala/org/apache/spark/streaming/receiver/Receiver.scala 64 additions, 26 deletions.../scala/org/apache/spark/streaming/receiver/Receiver.scala
- streaming/src/test/java/org/apache/spark/streaming/JavaReceiverAPISuite.java 144 additions, 0 deletions...java/org/apache/spark/streaming/JavaReceiverAPISuite.java
- streaming/src/test/java/org/apache/spark/streaming/JavaTestUtils.scala 2 additions, 2 deletions.../test/java/org/apache/spark/streaming/JavaTestUtils.scala
- streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala 2 additions, 1 deletion.../scala/org/apache/spark/streaming/InputStreamsSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/StreamingContextSuite.scala 1 addition, 1 deletion...la/org/apache/spark/streaming/StreamingContextSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/TestSuiteBase.scala 1 addition, 0 deletions...test/scala/org/apache/spark/streaming/TestSuiteBase.scala
Loading
Please register or sign in to comment