Uses of Interface
org.apache.hadoop.chukwa.Chunk

Packages that use Chunk

Package	Description
org.apache.hadoop.chukwa
org.apache.hadoop.chukwa.datacollection
org.apache.hadoop.chukwa.datacollection.agent
org.apache.hadoop.chukwa.datacollection.protocol
org.apache.hadoop.chukwa.datacollection.sender
org.apache.hadoop.chukwa.datacollection.writer
org.apache.hadoop.chukwa.extraction.demux.processor.mapper

Uses of Chunk in org.apache.hadoop.chukwa

Classes in org.apache.hadoop.chukwa that implement Chunk

Modifier and Type	Class and Description
class	ChunkImpl

Methods in org.apache.hadoop.chukwa that return Chunk

Modifier and Type	Method and Description
Chunk	ChunkBuilder.getChunk()

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

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

Modifier and Type	Method and Description
void	ChunkReceiver.add(Chunk event) Add a chunk to the queue, potentially blocking.
void	ChunkQueue.add(Chunk chunk) Add a chunk to the queue, blocking if queue is full.

Method parameters in org.apache.hadoop.chukwa.datacollection with type arguments of type Chunk

Modifier and Type	Method and Description
void	ChunkQueue.collect(List<Chunk> chunks, int count) Return at least one, and no more than count, Chunks into chunks.

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

Methods in org.apache.hadoop.chukwa.datacollection.agent with parameters of type Chunk

Modifier and Type	Method and Description
void	WaitingQueue.add(Chunk event)
void	MemLimitQueue.add(Chunk chunk)

Method parameters in org.apache.hadoop.chukwa.datacollection.agent with type arguments of type Chunk

Modifier and Type	Method and Description
void	WaitingQueue.add(List<Chunk> events)
void	WaitingQueue.collect(List<Chunk> events, int maxCount)
void	MemLimitQueue.collect(List<Chunk> events, int maxSize)

Uses of Chunk in org.apache.hadoop.chukwa.datacollection.protocol

Methods in org.apache.hadoop.chukwa.datacollection.protocol that return types with arguments of type Chunk

Modifier and Type	Method and Description
List<Chunk>	Protocol.parseFrom(byte[] bytes)
List<Chunk>	Protocol.parseFrom(InputStream input)

Method parameters in org.apache.hadoop.chukwa.datacollection.protocol with type arguments of type Chunk

Modifier and Type	Method and Description
byte[]	Protocol.toByteArray(List<Chunk> chunks)

Uses of Chunk in org.apache.hadoop.chukwa.datacollection.sender

Method parameters in org.apache.hadoop.chukwa.datacollection.sender with type arguments of type Chunk

Modifier and Type	Method and Description
List<ChukwaHttpSender.CommitListEntry>	ChukwaSender.send(List<Chunk> chunksToSend)
List<ChukwaHttpSender.CommitListEntry>	ChukwaHttpSender.send(List<Chunk> toSend) grab all of the chunks currently in the chunkQueue, stores a copy of them locally, calculates their size, sets them up

Uses of Chunk in org.apache.hadoop.chukwa.datacollection.writer

Methods in org.apache.hadoop.chukwa.datacollection.writer that return Chunk

Modifier and Type	Method and Description
Chunk	InMemoryWriter.readOutChunk(int bytes, int ms) Try to read bytes, waiting up to ms

Methods in org.apache.hadoop.chukwa.datacollection.writer with parameters of type Chunk

Modifier and Type	Method and Description
void	SeqFileWriter.add(Chunk chunk)
void	InMemoryWriter.add(Chunk data)
void	ConsoleWriter.add(Chunk data)

Method parameters in org.apache.hadoop.chukwa.datacollection.writer with type arguments of type Chunk

Modifier and Type	Method and Description
void	SeqFileWriter.add(List<Chunk> chunks)
void	PipelineStageWriter.add(List<Chunk> chunks)
void	InMemoryWriter.add(List<Chunk> chunks)
void	Dedup.add(List<Chunk> chunks)
void	ConsoleWriter.add(List<Chunk> chunks)
void	ChukwaWriter.add(List<Chunk> chunks)

Uses of Chunk in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

Methods in org.apache.hadoop.chukwa.extraction.demux.processor.mapper with parameters of type Chunk

Modifier and Type	Method and Description
void	MapProcessor.process(ChukwaArchiveKey archiveKey, Chunk chunk, org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output, org.apache.hadoop.mapred.Reporter reporter)
void	AbstractProcessor.process(ChukwaArchiveKey archiveKey, Chunk chunk, org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output, org.apache.hadoop.mapred.Reporter reporter)
void	ChunkProcessor.process(Chunk chunk, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,ChukwaRecord> output, org.apache.hadoop.mapred.Reporter reporter)
protected void	AbstractProcessor.reset(Chunk chunk)
static ChukwaRecord	ChunkSaver.saveChunk(Chunk chunk, Throwable throwable, org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output, org.apache.hadoop.mapred.Reporter reporter)