-
- Downloads
Merge pull request #443 from tdas/filestream-fix
Made some classes private[stremaing] and deprecated a method in JavaStreamingContext. Classes `RawTextHelper`, `RawTextSender` and `RateLimitedOutputStream` are not useful in the streaming API. There are not used by the core functionality and was there as a support classes for an obscure example. One of the classes is RawTextSender has a main function which can be executed using bin/spark-class even if it is made private[streaming]. In future, I will probably completely remove these classes. For the time being, I am just converting them to private[streaming]. Accessing underlying JavaSparkContext in JavaStreamingContext was through `JavaStreamingContext.sc` . This is deprecated and preferred method is `JavaStreamingContext.sparkContext` to keep it consistent with the `StreamingContext.sparkContext`.
No related branches found
No related tags found
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