Uses of Interface
org.apache.hadoop.chukwa.datacollection.ChunkReceiver

Packages that use ChunkReceiver

Package	Description
org.apache.hadoop.chukwa.datacollection
org.apache.hadoop.chukwa.datacollection.adaptor
org.apache.hadoop.chukwa.datacollection.adaptor.filetailer
org.apache.hadoop.chukwa.datacollection.agent
org.apache.hadoop.chukwa.util

Uses of ChunkReceiver in org.apache.hadoop.chukwa.datacollection

Subinterfaces of ChunkReceiver in org.apache.hadoop.chukwa.datacollection

Modifier and Type	Interface and Description
interface	ChunkQueue A generic interface for queues of Chunks.

Uses of ChunkReceiver in org.apache.hadoop.chukwa.datacollection.adaptor

Fields in org.apache.hadoop.chukwa.datacollection.adaptor declared as ChunkReceiver

Modifier and Type	Field and Description
protected ChunkReceiver	FileAdaptor.dest

Methods in org.apache.hadoop.chukwa.datacollection.adaptor with parameters of type ChunkReceiver

Modifier and Type	Method and Description
protected int	FileAdaptor.extractRecords(ChunkReceiver eq, long buffOffsetInFile, byte[] buf, long fileTime) Extract records from a byte sequence
void	FileAdaptor.start(long adaptorID, String type, String params, long bytes, ChunkReceiver dest)
void	ExecAdaptor.start(long adaptorID, String type, String status, long offset, ChunkReceiver dest)
void	Adaptor.start(long adaptorID, String type, String status, long offset, ChunkReceiver dest) Start this adaptor

Uses of ChunkReceiver in org.apache.hadoop.chukwa.datacollection.adaptor.filetailer

Methods in org.apache.hadoop.chukwa.datacollection.adaptor.filetailer with parameters of type ChunkReceiver

Modifier and Type	Method and Description
protected int	FileTailingAdaptor.extractRecords(ChunkReceiver eq, long buffOffsetInFile, byte[] buf) Extract records from a byte sequence
protected int	CharFileTailingAdaptorUTF8NewLineEscaped.extractRecords(ChunkReceiver eq, long buffOffsetInFile, byte[] buf) Note: this method uses a temporary ArrayList (shared across instances).
protected int	CharFileTailingAdaptorUTF8.extractRecords(ChunkReceiver eq, long buffOffsetInFile, byte[] buf) Note: this method uses a temporary ArrayList (shared across instances).
void	FileTailingAdaptor.start(long adaptorID, String type, String params, long bytes, ChunkReceiver dest)
boolean	FileTailingAdaptor.tailFile(ChunkReceiver eq) Looks at the tail of the associated file, adds some of it to event queue This method is not thread safe.

Constructors in org.apache.hadoop.chukwa.datacollection.adaptor.filetailer with parameters of type ChunkReceiver

Constructor and Description
TerminatorThread(FileTailingAdaptor adaptor, ChunkReceiver eq)

Uses of ChunkReceiver in org.apache.hadoop.chukwa.datacollection.agent

Classes in org.apache.hadoop.chukwa.datacollection.agent that implement ChunkReceiver

Modifier and Type	Class and Description
class	MemLimitQueue An event queue that blocks once a fixed upper limit of data is enqueued.
class	WaitingQueue

Uses of ChunkReceiver in org.apache.hadoop.chukwa.util

Methods in org.apache.hadoop.chukwa.util with parameters of type ChunkReceiver

Modifier and Type	Method and Description
void	MaxRateSender.start(long adaptor, String type, String status, long offset, ChunkReceiver dest)
void	ConstRateAdaptor.start(long adaptor, String type, String bytesPerSecParam, long offset, ChunkReceiver dest)