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.connector
org.apache.hadoop.chukwa.datacollection.sender
org.apache.hadoop.chukwa.datacollection.writer
org.apache.hadoop.chukwa.datacollection.writer.localfs
org.apache.hadoop.chukwa.extraction.demux.processor.mapper
org.apache.hadoop.chukwa.extraction.engine
org.apache.hadoop.chukwa.util

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

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

Modifier and Type	Method and Description
Chunk	ChunkCatcherConnector.waitForAChunk()
Chunk	ChunkCatcherConnector.waitForAChunk(long ms)

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	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
ChukwaWriter.CommitStatus	SocketTeeWriter.add(List<Chunk> chunks)
ChukwaWriter.CommitStatus	SeqFileWriter.add(List<Chunk> chunks)
ChukwaWriter.CommitStatus	PipelineStageWriter.add(List<Chunk> chunks)
ChukwaWriter.CommitStatus	NullWriter.add(List<Chunk> chunks)
ChukwaWriter.CommitStatus	InMemoryWriter.add(List<Chunk> chunks)
ChukwaWriter.CommitStatus	Dedup.add(List<Chunk> chunks)
ChukwaWriter.CommitStatus	ConsoleWriter.add(List<Chunk> chunks)
ChukwaWriter.CommitStatus	ChukwaWriter.add(List<Chunk> chunks) Called repeatedly with data that should be serialized.

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

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

Modifier and Type	Method and Description
ChukwaWriter.CommitStatus	LocalWriter.add(List<Chunk> chunks) Best effort, there's no guarantee that chunks have really been written to disk

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

Fields in org.apache.hadoop.chukwa.extraction.demux.processor.mapper declared as Chunk

Modifier and Type	Field and Description
protected Chunk	AbstractProcessor.chunk

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)

Uses of Chunk in org.apache.hadoop.chukwa.extraction.engine

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

Modifier and Type	Method and Description
static String	RecordUtil.getClusterName(Chunk chunk) Uses a precompiled pattern, so theoretically faster than Chunk.getTag().

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

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

Modifier and Type	Method and Description
static boolean	ConstRateAdaptor.checkChunk(Chunk chunk)
boolean	Filter.matches(Chunk chunk)