| Commit message (Collapse) | Author | Age | Files | Lines |
|
|
|
| |
for creating XYZ streams.
|
|
|
|
|
|
|
|
|
|
| |
Conflicts:
examples/src/main/java/org/apache/spark/streaming/examples/JavaFlumeEventCount.java
streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala
streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala
streaming/src/test/java/org/apache/spark/streaming/JavaAPISuite.java
streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala
streaming/src/test/scala/org/apache/spark/streaming/TestSuiteBase.scala
|
|
|
|
| |
package. Also fixed packages of Flume and MQTT tests.
|
| |
|
|
|
|
| |
repositoris from other poms and sbt.
|
|
|
|
| |
their own self-contained scala API, java API, scala unit tests and java unit tests. Updated examples to use the external projects.
|
|
|