public class FlumeConnection
extends Object
Constructor and Description |
---|
FlumeConnection(org.apache.avro.ipc.NettyTransceiver transceiver,
org.apache.spark.streaming.flume.sink.SparkFlumeProtocol.Callback client) |
Modifier and Type | Method and Description |
---|---|
org.apache.spark.streaming.flume.sink.SparkFlumeProtocol.Callback |
client() |
org.apache.avro.ipc.NettyTransceiver |
transceiver() |