org.apache.hadoop.chukwa.datacollection.connector

Class ChunkCatcherConnector

java.lang.Object

org.apache.hadoop.chukwa.datacollection.connector.ChunkCatcherConnector

All Implemented Interfaces:

Connector

public class ChunkCatcherConnector
extends Object
implements Connector

Field Summary

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
ChunkCatcherConnector()

Method Summary

Methods

Modifier and Type	Method and Description
void	clear()
void	reloadConfiguration()
void	shutdown()
void	start()
Chunk	waitForAChunk()
Chunk	waitForAChunk(long ms)

Methods inherited from class java.lang.Object

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

Constructor Detail

ChunkCatcherConnector

public ChunkCatcherConnector()

Method Detail

start

public void start()

Specified by:

start in interface Connector

waitForAChunk

public Chunk waitForAChunk(long ms)

waitForAChunk

public Chunk waitForAChunk()
                    throws InterruptedException

Throws:

InterruptedException

shutdown

public void shutdown()

Specified by:

shutdown in interface Connector

reloadConfiguration

public void reloadConfiguration()

Specified by:

reloadConfiguration in interface Connector

clear

public void clear()
           throws InterruptedException

Throws:

InterruptedException