org.apache.hadoop.chukwa.datacollection.agent

Interface AdaptorManager

All Known Implementing Classes:

ChukwaAgent

public interface AdaptorManager

The interface to the agent that is exposed to adaptors.

Field Summary

Fields

Modifier and Type	Field and Description
static AdaptorManager	NULL

Method Summary

Methods

Modifier and Type	Method and Description
int	adaptorCount()
Adaptor	getAdaptor(String id)
Map<String,String>	getAdaptorList()
org.apache.hadoop.conf.Configuration	getConfiguration()
String	processAddCommand(String cmd)
String	reportCommit(Adaptor src, long uuid) Called to update the Agent status table.
long	stopAdaptor(String id, boolean gracefully)

Field Detail

NULL

static final AdaptorManager NULL

Method Detail

getConfiguration

org.apache.hadoop.conf.Configuration getConfiguration()

adaptorCount

int adaptorCount()

stopAdaptor

long stopAdaptor(String id,
               boolean gracefully)

getAdaptor

Adaptor getAdaptor(String id)

processAddCommand

String processAddCommand(String cmd)

getAdaptorList

Map<String,String> getAdaptorList()

reportCommit

String reportCommit(Adaptor src,
                  long uuid)

Called to update the Agent status table. Most adaptors should not call this. It is designed for adaptors that do some sort of local operation that needs checkpointing, but that doesn't emit chunks. For instance, DirTailingAdaptor uses it to track sweeps.

Parameters:

src - the adaptor in question

uuid - the number to record as checkpoint. Must be monotonically increasing.

Returns:

the adaptor ID of the associated adaptor, or null if not running.