org.apache.hadoop.chukwa.datacollection.adaptor

Class AbstractAdaptor

java.lang.Object

org.apache.hadoop.chukwa.datacollection.adaptor.AbstractAdaptor

All Implemented Interfaces:

Adaptor

Direct Known Subclasses:

DirTailingAdaptor, ExecAdaptor, FileAdaptor, LWFTAdaptor

public abstract class AbstractAdaptor
extends Object
implements Adaptor

Field Summary

Fields

Modifier and Type	Field and Description
protected String	adaptorID
protected AdaptorManager	control
protected ChunkReceiver	dest
protected String	type

Constructor Summary

Constructors

Constructor and Description
AbstractAdaptor()

Method Summary

Methods

Modifier and Type	Method and Description
void	deregisterAndStop(boolean gracefully)
String	getType()
abstract void	start(long offset)
void	start(String adaptorID, String type, long offset, ChunkReceiver dest, AdaptorManager c) Start this adaptor

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.chukwa.datacollection.adaptor.Adaptor

getCurrentStatus, hardStop, parseArgs, shutdown, shutdown

Field Detail

type

protected String type

dest

protected ChunkReceiver dest

adaptorID

protected String adaptorID

control

protected AdaptorManager control

Constructor Detail

AbstractAdaptor

public AbstractAdaptor()

Method Detail

getType

public final String getType()

Specified by:

getType in interface Adaptor

start

public final void start(String adaptorID,
         String type,
         long offset,
         ChunkReceiver dest,
         AdaptorManager c)
                 throws AdaptorException

Description copied from interface: Adaptor

Start this adaptor

Specified by:

start in interface Adaptor

type - the application type, who is starting this adaptor

offset - the stream offset of the first byte sent by this adaptor

Throws:

AdaptorException

start

public abstract void start(long offset)
                    throws AdaptorException

Throws:

AdaptorException

deregisterAndStop

public void deregisterAndStop(boolean gracefully)