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.adaptor.sigar
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

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

Modifier and Type	Class and Description
class	AbstractWrapper
class	MemBuffered
class	WriteaheadBuffered

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	WriteaheadBuffered.start(String adaptorID, String type, long offset, ChunkReceiver dest)
void	MemBuffered.start(String adaptorID, String type, long offset, ChunkReceiver dest)
void	Adaptor.start(String adaptorID, String type, long offset, ChunkReceiver dest) Start this adaptor
void	AbstractWrapper.start(String adaptorID, String type, long offset, ChunkReceiver dest) Note that the name of the inner class will get parsed out as a type
void	AbstractAdaptor.start(String adaptorID, String type, long offset, ChunkReceiver dest)

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

Constructor and Description
JMXAdaptor.JMXTimer(ChunkReceiver receiver, JMXAdaptor adaptor, MBeanServerConnection mbsc)

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	FileTailingAdaptorPreserveLines.extractRecords(ChunkReceiver eq, long buffOffsetInFile, byte[] buf)
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).

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

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

Constructor and Description
SigarRunner(ChunkReceiver dest, SystemMetrics systemMetrics)

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	NonBlockingMemLimitQueue An event queue that discards incoming chunks 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)