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

Class ClientTraceProcessor

java.lang.Object

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

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

All Implemented Interfaces:

MapProcessor

public class ClientTraceProcessor
extends AbstractProcessor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ClientTraceProcessor.Locality

Constructor Summary

Constructors

Constructor and Description
ClientTraceProcessor()

Method Summary

Modifier and Type	Method and Description
String	getDataType()
void	parse(String recordEntry, org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output, org.apache.hadoop.mapred.Reporter reporter)

Methods inherited from class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.AbstractProcessor

getCurrentPos, getStartOffset, process, setCurrentPos, setStartOffset

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClientTraceProcessor

public ClientTraceProcessor()

Method Detail

parse

public void parse(String recordEntry,
                  org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
                  org.apache.hadoop.mapred.Reporter reporter)
           throws Throwable

Throws:

Throwable

getDataType

public String getDataType()