org.apache.spark.streaming.flume

Class FlumeConnection

Object

org.apache.spark.streaming.flume.FlumeConnection

public class FlumeConnection
extends Object

A wrapper around the transceiver and the Avro IPC API.

Constructor Summary

Constructors

Constructor and Description
FlumeConnection(org.apache.avro.ipc.NettyTransceiver transceiver, org.apache.spark.streaming.flume.sink.SparkFlumeProtocol.Callback client)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.spark.streaming.flume.sink.SparkFlumeProtocol.Callback	client()
org.apache.avro.ipc.NettyTransceiver	transceiver()

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlumeConnection

public FlumeConnection(org.apache.avro.ipc.NettyTransceiver transceiver,
               org.apache.spark.streaming.flume.sink.SparkFlumeProtocol.Callback client)

Method Detail

transceiver

public org.apache.avro.ipc.NettyTransceiver transceiver()

client

public org.apache.spark.streaming.flume.sink.SparkFlumeProtocol.Callback client()