org.apache.hadoop.chukwa.extraction.demux.processor.mapper

Interface ChunkProcessor

public interface ChunkProcessor

Method Summary

Modifier and Type	Method and Description
String	getDataType()
void	process(Chunk chunk, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,ChukwaRecord> output, org.apache.hadoop.mapred.Reporter reporter)

Method Detail

getDataType

String getDataType()

process

void process(Chunk chunk,
             org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,ChukwaRecord> output,
             org.apache.hadoop.mapred.Reporter reporter)