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	AbstractAdaptor.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	Adaptor.start(String adaptorID, String type, long offset, ChunkReceiver dest, AdaptorManager c) Start this adaptor
void	AbstractAdaptor.start(String adaptorID, String type, long offset, ChunkReceiver dest, AdaptorManager c)

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	LWFTAdaptor.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).
boolean	LWFTAdaptor.tailFile(ChunkReceiver eq)
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(String adaptorID, String type, long offset, ChunkReceiver dest, AdaptorManager c)
void	ConstRateAdaptor.start(String adaptorID, String type, long offset, ChunkReceiver dest, AdaptorManager c)