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

java.lang.Object
  org.apache.hadoop.chukwa.extraction.demux.processor.mapper.AbstractProcessor
      org.apache.hadoop.chukwa.extraction.demux.processor.mapper.HadoopMetricsProcessor

All Implemented Interfaces:

MapProcessor

Direct Known Subclasses:

ChukwaMetricsProcessor

public class HadoopMetricsProcessor
extends AbstractProcessor

Field Summary

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

archiveKey, chunk, key

Constructor Summary

HadoopMetricsProcessor()

Method Summary

protected void	buildJVMRecord(ChukwaRecord record, long timestamp, String dataSource)
String	getDataType()
protected 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

HadoopMetricsProcessor

public HadoopMetricsProcessor()

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

buildJVMRecord

protected void buildJVMRecord(ChukwaRecord record,
                              long timestamp,
                              String dataSource)

getDataType

public String getDataType()