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

Class PbsNodes

java.lang.Object

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

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

All Implemented Interfaces:

MapProcessor

public class PbsNodes
extends AbstractProcessor

Field Summary

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

archiveKey, chunk, currentPos, key, startOffset

Constructor Summary

Constructors

Constructor and Description
PbsNodes()

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)
protected static void	parsePbsRecord(String recordLine, ChukwaRecord record)
protected static void	parseStatusField(String statusField, ChukwaRecord record)

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

Constructor Detail

PbsNodes

public PbsNodes()

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

parsePbsRecord

protected static void parsePbsRecord(String recordLine,
                  ChukwaRecord record)

parseStatusField

protected static void parseStatusField(String statusField,
                    ChukwaRecord record)

getDataType

public String getDataType()