org.apache.hadoop.chukwa.datacollection.adaptor

Class OozieAdaptor

java.lang.Object

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

org.apache.hadoop.chukwa.datacollection.adaptor.OozieAdaptor

All Implemented Interfaces:

Adaptor

public class OozieAdaptor
extends AbstractAdaptor

Constructor Summary

Constructors

Constructor and Description
OozieAdaptor()

Method Summary

Modifier and Type	Method and Description
int	addChunkToReceiver(byte[] data)
org.apache.hadoop.conf.Configuration	getChukwaConfiguration()
String	getCurrentStatus() Return the adaptor's state Should not include class name or byte offset, which are written by caller.
String	parseArgs(String s)
void	setChukwaConfiguration(org.apache.hadoop.conf.Configuration chukwaConfiguration)
long	shutdown(AdaptorShutdownPolicy shutdownPolicy) Signals this adaptor to come to an orderly stop.
void	start(long offset)

Methods inherited from class org.apache.hadoop.chukwa.datacollection.adaptor.AbstractAdaptor

deregisterAndStop, getType, hardStop, parseArgs, shutdown, start

Methods inherited from class java.lang.Object

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

Constructor Detail

OozieAdaptor

public OozieAdaptor()

Method Detail

parseArgs

public String parseArgs(String s)

Specified by:

parseArgs in class AbstractAdaptor

start

public void start(long offset)
           throws AdaptorException

Specified by:

start in class AbstractAdaptor

Throws:

AdaptorException

getCurrentStatus

public String getCurrentStatus()

Description copied from interface: Adaptor

Return the adaptor's state Should not include class name or byte offset, which are written by caller. The datatype should, however, be written by this method.

Returns:

the adaptor state as a string

shutdown

public long shutdown(AdaptorShutdownPolicy shutdownPolicy)
              throws AdaptorException

Description copied from interface: Adaptor

Signals this adaptor to come to an orderly stop. The adaptor ought to push out all the data it can before exiting depending of the shutdown policy

Parameters:

shutdownPolicy - is defined as forcefully or gracefully

Returns:

the logical offset at which the adaptor was when the method return

Throws:

AdaptorException - Exception on shutdown

addChunkToReceiver

public int addChunkToReceiver(byte[] data)

getChukwaConfiguration

public org.apache.hadoop.conf.Configuration getChukwaConfiguration()

setChukwaConfiguration

public void setChukwaConfiguration(org.apache.hadoop.conf.Configuration chukwaConfiguration)