Commit d6fa3aa

committed

SPARK-1729. New Flume-Spark integration.

Made the Flume Sink considerably simpler. Added a lot of documentation.

1 parent e7da512 commit d6fa3aaCopy full SHA for d6fa3aa

2 files changed

+323

-231

lines changed

external
- flume-sink/src/main/scala/org/apache/spark/flume/sink
  - SparkSink.scala
- flume/src/main/scala/org/apache/spark/streaming/flume
  - FlumePollingInputDStream.scala

+323

-231

lines changed

Comments

(0)