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

Class Top

java.lang.Object

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

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

All Implemented Interfaces:

MapProcessor

public class Top
extends AbstractProcessor

Field Summary

Fields

Modifier and Type	Field and Description
String	recordType
String	reduceType

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

archiveKey, chunk, currentPos, key, startOffset

Constructor Summary

Constructors

Constructor and Description
Top()

Method Summary

Methods

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

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

buildGenericRecord, getCurrentPos, getStartOffset, hasNext, nextLine, process, reset, saveChunkInError, setCurrentPos, setStartOffset

Methods inherited from class java.lang.Object

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

Field Detail

reduceType

public final String reduceType

See Also:

Constant Field Values

recordType

public final String recordType

Constructor Detail

Top

public Top()

Method Detail

parse

protected 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

parseSummary

public void parseSummary(ChukwaRecord record,
                String header)

getDataType

public String getDataType()