-
- Downloads
Made some classes private[stremaing] and deprecated a method in JavaStreamingContext.
Showing
- streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala 5 additions, 1 deletion...pache/spark/streaming/api/java/JavaStreamingContext.scala
- streaming/src/main/scala/org/apache/spark/streaming/util/RateLimitedOutputStream.scala 1 addition, 0 deletions...apache/spark/streaming/util/RateLimitedOutputStream.scala
- streaming/src/main/scala/org/apache/spark/streaming/util/RawTextHelper.scala 1 addition, 0 deletions...scala/org/apache/spark/streaming/util/RawTextHelper.scala
- streaming/src/main/scala/org/apache/spark/streaming/util/RawTextSender.scala 1 addition, 0 deletions...scala/org/apache/spark/streaming/util/RawTextSender.scala
- streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java 3 additions, 3 deletions...rc/test/java/org/apache/spark/streaming/JavaAPISuite.java
Loading
Please register or sign in to comment