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

Class Sar

java.lang.Object

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

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

All Implemented Interfaces:

MapProcessor

public class Sar
extends AbstractProcessor

Field Summary

Fields

Modifier and Type	Field and Description
String	recordType
static 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
Sar()

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)
String[]	parseData(String dataLine)
String[]	parseHeader(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 static final String reduceType

See Also:

Constant Field Values

recordType

public final String recordType

Constructor Detail

Sar

public Sar()

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

parseHeader

public String[] parseHeader(String header)

parseData

public String[] parseData(String dataLine)

getDataType

public String getDataType()