-
- Downloads
[SPARK-14073][STREAMING][TEST-MAVEN] Move flume back to Spark
## What changes were proposed in this pull request? This PR moves flume back to Spark as per the discussion in the dev mail-list. ## How was this patch tested? Existing Jenkins tests. Author: Shixiong Zhu <shixiong@databricks.com> Closes #11895 from zsxwing/move-flume-back.
Showing
- dev/audit-release/audit_release.py 1 addition, 1 deletiondev/audit-release/audit_release.py
- dev/run-tests.py 1 addition, 0 deletionsdev/run-tests.py
- dev/sparktestsupport/modules.py 34 additions, 0 deletionsdev/sparktestsupport/modules.py
- examples/pom.xml 5 additions, 0 deletionsexamples/pom.xml
- examples/src/main/java/org/apache/spark/examples/streaming/JavaFlumeEventCount.java 75 additions, 0 deletions.../apache/spark/examples/streaming/JavaFlumeEventCount.java
- examples/src/main/scala/org/apache/spark/examples/streaming/FlumeEventCount.scala 70 additions, 0 deletions...org/apache/spark/examples/streaming/FlumeEventCount.scala
- examples/src/main/scala/org/apache/spark/examples/streaming/FlumePollingEventCount.scala 67 additions, 0 deletions...che/spark/examples/streaming/FlumePollingEventCount.scala
- external/flume-assembly/pom.xml 168 additions, 0 deletionsexternal/flume-assembly/pom.xml
- external/flume-sink/pom.xml 129 additions, 0 deletionsexternal/flume-sink/pom.xml
- external/flume-sink/src/main/avro/sparkflume.avdl 40 additions, 0 deletionsexternal/flume-sink/src/main/avro/sparkflume.avdl
- external/flume-sink/src/main/scala/org/apache/spark/streaming/flume/sink/Logging.scala 127 additions, 0 deletions...scala/org/apache/spark/streaming/flume/sink/Logging.scala
- external/flume-sink/src/main/scala/org/apache/spark/streaming/flume/sink/SparkAvroCallbackHandler.scala 166 additions, 0 deletions...spark/streaming/flume/sink/SparkAvroCallbackHandler.scala
- external/flume-sink/src/main/scala/org/apache/spark/streaming/flume/sink/SparkSink.scala 171 additions, 0 deletions...ala/org/apache/spark/streaming/flume/sink/SparkSink.scala
- external/flume-sink/src/main/scala/org/apache/spark/streaming/flume/sink/SparkSinkThreadFactory.scala 35 additions, 0 deletions...e/spark/streaming/flume/sink/SparkSinkThreadFactory.scala
- external/flume-sink/src/main/scala/org/apache/spark/streaming/flume/sink/SparkSinkUtils.scala 28 additions, 0 deletions...rg/apache/spark/streaming/flume/sink/SparkSinkUtils.scala
- external/flume-sink/src/main/scala/org/apache/spark/streaming/flume/sink/TransactionProcessor.scala 252 additions, 0 deletions...che/spark/streaming/flume/sink/TransactionProcessor.scala
- external/flume-sink/src/test/resources/log4j.properties 28 additions, 0 deletionsexternal/flume-sink/src/test/resources/log4j.properties
- external/flume-sink/src/test/scala/org/apache/spark/streaming/flume/sink/SparkSinkSuite.scala 218 additions, 0 deletions...rg/apache/spark/streaming/flume/sink/SparkSinkSuite.scala
- external/flume/pom.xml 78 additions, 0 deletionsexternal/flume/pom.xml
- external/flume/src/main/scala/org/apache/spark/streaming/flume/EventTransformer.scala 72 additions, 0 deletions...a/org/apache/spark/streaming/flume/EventTransformer.scala
Loading
Please register or sign in to comment