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:

ConstRateAdaptor, DirTailingAdaptor, ExecAdaptor, FileAdaptor, HeartbeatAdaptor, JMSAdaptor, JMXAdaptor, LWFTAdaptor, OozieAdaptor, RestAdaptor, SocketAdaptor, SystemMetrics, UDPAdaptor

public abstract class AbstractAdaptor
extends Object
implements Adaptor

Constructor Summary

Constructors

Constructor and Description
AbstractAdaptor()

Method Summary

Modifier and Type	Method and Description
void	deregisterAndStop()
String	getType()
void	hardStop() Deprecated.
abstract String	parseArgs(String s)
String	parseArgs(String d, String s, AdaptorManager c) Parse args, return stream name.
long	shutdown() Deprecated.
abstract void	start(long offset)
void	start(String adaptorID, String type, long offset, ChunkReceiver dest) Start this adaptor

Methods inherited from class java.lang.Object

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

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

getCurrentStatus, shutdown

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)
                 throws AdaptorException

Description copied from interface: Adaptor

Start this adaptor

Specified by:

start in interface Adaptor

Parameters:

adaptorID - Adaptor ID

type - the application type, who is starting this adaptor

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

dest - Chunk receiving destination

Throws:

AdaptorException - if adaptor can not be started

start

public abstract void start(long offset)
                    throws AdaptorException

Throws:

AdaptorException

parseArgs

public abstract String parseArgs(String s)

deregisterAndStop

public void deregisterAndStop()

parseArgs

public String parseArgs(String d,
                        String s,
                        AdaptorManager c)

Description copied from interface: Adaptor

Parse args, return stream name. Do not start running. Return the stream name, given params. The stream name is the part of the Adaptor status that's used to determine uniqueness.

Specified by:

parseArgs in interface Adaptor

Parameters:

d - Data type

s - Adaptor parameters

c - Adaptor Manager

Returns:

Stream name as a string, null if params are malformed

hardStop

@Deprecated
public void hardStop()
                          throws AdaptorException

Deprecated.

Throws:

AdaptorException

shutdown

@Deprecated
public long shutdown()
                          throws AdaptorException

Deprecated.

Throws:

AdaptorException