org.apache.hadoop.chukwa.tools.backfilling

Class QueueToWriterConnector

java.lang.Object

org.apache.hadoop.chukwa.tools.backfilling.QueueToWriterConnector

All Implemented Interfaces:

Runnable, Connector

public class QueueToWriterConnector
extends Object
implements Connector, Runnable

Field Summary

Fields

Modifier and Type	Field and Description
protected ChunkQueue	chunkQueue
protected org.apache.hadoop.conf.Configuration	conf
protected boolean	isBackfilling
protected boolean	isRunning
protected Thread	runner
protected ChukwaWriter	writer

Fields inherited from interface org.apache.hadoop.chukwa.datacollection.connector.Connector

adaptorTimestampField, adaptorURIField, logApplicationField, logEventField, logSourceField, logTimestampField, proxyRetryField, proxyTimestampField, proxyURIField

Constructor Summary

Constructors

Constructor and Description
QueueToWriterConnector(org.apache.hadoop.conf.Configuration conf, boolean isBackfilling)

Method Summary

Modifier and Type	Method and Description
protected boolean	isAlive()
void	reloadConfiguration()
void	run()
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

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

Field Detail

conf

protected org.apache.hadoop.conf.Configuration conf

isRunning

protected volatile boolean isRunning

chunkQueue

protected ChunkQueue chunkQueue

writer

protected ChukwaWriter writer

runner

protected Thread runner

isBackfilling

protected boolean isBackfilling

Constructor Detail

QueueToWriterConnector

public QueueToWriterConnector(org.apache.hadoop.conf.Configuration conf,
                              boolean isBackfilling)

Method Detail

reloadConfiguration

public void reloadConfiguration()

Specified by:

reloadConfiguration in interface Connector

shutdown

public void shutdown()

Specified by:

shutdown in interface Connector

start

public void start()

Specified by:

start in interface Connector

isAlive

protected boolean isAlive()

run

public void run()

Specified by:

run in interface Runnable