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

Field Summary

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

archiveKey, chunk, key

Constructor Summary

Constructors

Constructor and Description
ClientTraceProcessor()

Method Summary

Methods

Modifier and Type	Method and Description
String	getDataType()
protected ClientTraceProcessor.Locality	getLocality(String src, String dst)
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

buildGenericRecord, hasNext, nextLine, process, reset, saveChunkInError

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientTraceProcessor

public ClientTraceProcessor()

Method Detail

getLocality

protected ClientTraceProcessor.Locality getLocality(String src,
                                        String dst)
                                             throws Exception

Throws:

Exception

parse

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

Specified by:

parse in class AbstractProcessor

Throws:

Throwable

getDataType

public String getDataType()