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

Packages that use ChunkReceiver

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

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

class	AbstractWrapper
class	MemBuffered
class	WriteaheadBuffered

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

protected ChunkReceiver

AbstractAdaptor.dest

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

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)

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

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).

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

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

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

void	MaxRateSender.start(String adaptorID, String type, long offset, ChunkReceiver dest)