-
- Downloads
Fixed differences in APIs of StreamingContext and JavaStreamingContext. Change...
Fixed differences in APIs of StreamingContext and JavaStreamingContext. Change rawNetworkStream to rawSocketStream, and added twitter, actor, zeroMQ streams to JavaStreamingContext. Also added them to JavaAPISuite.
Showing
- examples/src/main/scala/spark/streaming/examples/RawNetworkGrep.scala 1 addition, 1 deletion.../main/scala/spark/streaming/examples/RawNetworkGrep.scala
- streaming/src/main/scala/spark/streaming/StreamingContext.scala 9 additions, 7 deletions...ing/src/main/scala/spark/streaming/StreamingContext.scala
- streaming/src/main/scala/spark/streaming/api/java/JavaStreamingContext.scala 189 additions, 12 deletions...scala/spark/streaming/api/java/JavaStreamingContext.scala
- streaming/src/test/java/spark/streaming/JavaAPISuite.java 32 additions, 5 deletionsstreaming/src/test/java/spark/streaming/JavaAPISuite.java
- streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala 1 addition, 1 deletion...ng/src/test/scala/spark/streaming/InputStreamsSuite.scala
Loading
Please register or sign in to comment