org.apache.spark.streaming.flume

Class FlumeBatchFetcher

Object

org.apache.spark.streaming.flume.FlumeBatchFetcher

All Implemented Interfaces:

Runnable, Logging

public class FlumeBatchFetcher
extends Object
implements Runnable, Logging

This class implements the core functionality of FlumePollingReceiver. When started it pulls data from Flume, stores it to Spark and then sends an Ack or Nack. This class should be run via an Executor as this implements Runnable

Constructor Summary

Constructors

Constructor and Description
FlumeBatchFetcher(FlumePollingReceiver receiver)

Method Summary

Methods

Modifier and Type	Method and Description
void	run()

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

FlumeBatchFetcher

public FlumeBatchFetcher(FlumePollingReceiver receiver)

Method Detail

run

public void run()

Specified by:

run in interface Runnable