文件名称:spark-streaming-flume-sink_2.11-2.1.0.jar
文件大小:85KB
文件格式:JAR
更新时间:2020-05-04 08:34:02
Spark flume
使用spark集成flume,由于flume默认只支持pull消息的方式,不过它可以自定义消息拉取方式,现要使用poll方式,可以使用spark-streaming-flume-sink_2.11-2.1.0.jar包下的org.apache.spark.streaming.flume.sink.SparkSink