-
- Downloads
[SPARK-8378] [STREAMING] Add the Python API for Flume
Author: zsxwing <zsxwing@gmail.com> Closes #6830 from zsxwing/flume-python and squashes the following commits: 78dfdac [zsxwing] Fix the compile error in the test code f1bf3c0 [zsxwing] Address TD's comments 0449723 [zsxwing] Add sbt goal streaming-flume-assembly/assembly e93736b [zsxwing] Fix the test case for determine_modules_to_test 9d5821e [zsxwing] Fix pyspark_core dependencies f9ee681 [zsxwing] Merge branch 'master' into flume-python 7a55837 [zsxwing] Add streaming_flume_assembly to run-tests.py b96b0de [zsxwing] Merge branch 'master' into flume-python ce85e83 [zsxwing] Fix incompatible issues for Python 3 01cbb3d [zsxwing] Add import sys 152364c [zsxwing] Fix the issue that StringIO doesn't work in Python 3 14ba0ff [zsxwing] Add flume-assembly for sbt building b8d5551 [zsxwing] Merge branch 'master' into flume-python 4762c34 [zsxwing] Fix the doc 0336579 [zsxwing] Refactor Flume unit tests and also add tests for Python API 9f33873 [zsxwing] Add the Python API for Flume
Showing
- dev/run-tests.py 4 additions, 3 deletionsdev/run-tests.py
- dev/sparktestsupport/modules.py 12 additions, 3 deletionsdev/sparktestsupport/modules.py
- docs/streaming-flume-integration.md 18 additions, 0 deletionsdocs/streaming-flume-integration.md
- docs/streaming-programming-guide.md 1 addition, 1 deletiondocs/streaming-programming-guide.md
- examples/src/main/python/streaming/flume_wordcount.py 55 additions, 0 deletionsexamples/src/main/python/streaming/flume_wordcount.py
- external/flume-assembly/pom.xml 135 additions, 0 deletionsexternal/flume-assembly/pom.xml
- external/flume/src/main/scala/org/apache/spark/streaming/flume/FlumeTestUtils.scala 116 additions, 0 deletions...ala/org/apache/spark/streaming/flume/FlumeTestUtils.scala
- external/flume/src/main/scala/org/apache/spark/streaming/flume/FlumeUtils.scala 75 additions, 1 deletion...n/scala/org/apache/spark/streaming/flume/FlumeUtils.scala
- external/flume/src/main/scala/org/apache/spark/streaming/flume/PollingFlumeTestUtils.scala 209 additions, 0 deletions.../apache/spark/streaming/flume/PollingFlumeTestUtils.scala
- external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumePollingStreamSuite.scala 34 additions, 139 deletions...pache/spark/streaming/flume/FlumePollingStreamSuite.scala
- external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumeStreamSuite.scala 22 additions, 84 deletions...a/org/apache/spark/streaming/flume/FlumeStreamSuite.scala
- pom.xml 1 addition, 0 deletionspom.xml
- project/SparkBuild.scala 3 additions, 3 deletionsproject/SparkBuild.scala
- python/pyspark/streaming/flume.py 147 additions, 0 deletionspython/pyspark/streaming/flume.py
- python/pyspark/streaming/tests.py 177 additions, 2 deletionspython/pyspark/streaming/tests.py
Loading
Please register or sign in to comment