org.apache.spark.streaming.flume

Class FlumeEventServer

Object

org.apache.spark.streaming.flume.FlumeEventServer

All Implemented Interfaces:

org.apache.flume.source.avro.AvroSourceProtocol

public class FlumeEventServer
extends Object
implements org.apache.flume.source.avro.AvroSourceProtocol

A simple server that implements Flume's Avro protocol.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flume.source.avro.AvroSourceProtocol

org.apache.flume.source.avro.AvroSourceProtocol.Callback

Field Summary

Fields inherited from interface org.apache.flume.source.avro.AvroSourceProtocol

__PARANAMER_DATA, PROTOCOL

Constructor Summary

Constructors

Constructor and Description
FlumeEventServer(FlumeReceiver receiver)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.flume.source.avro.Status	append(org.apache.flume.source.avro.AvroFlumeEvent event)
org.apache.flume.source.avro.Status	appendBatch(java.util.List<org.apache.flume.source.avro.AvroFlumeEvent> events)

Methods inherited from class Object

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

Constructor Detail

FlumeEventServer

public FlumeEventServer(FlumeReceiver receiver)

Method Detail

append

public org.apache.flume.source.avro.Status append(org.apache.flume.source.avro.AvroFlumeEvent event)

Specified by:

append in interface org.apache.flume.source.avro.AvroSourceProtocol

appendBatch

public org.apache.flume.source.avro.Status appendBatch(java.util.List<org.apache.flume.source.avro.AvroFlumeEvent> events)

Specified by:

appendBatch in interface org.apache.flume.source.avro.AvroSourceProtocol