-
- Downloads
fixing kafkaStream Java API and adding test
Showing
- streaming/src/main/scala/spark/streaming/api/java/JavaStreamingContext.scala 7 additions, 3 deletions...scala/spark/streaming/api/java/JavaStreamingContext.scala
- streaming/src/test/java/spark/streaming/JavaAPISuite.java 6 additions, 0 deletionsstreaming/src/test/java/spark/streaming/JavaAPISuite.java
Loading
Please register or sign in to comment