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

Class Ps

java.lang.Object

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

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

All Implemented Interfaces:

MapProcessor

public class Ps
extends AbstractProcessor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Ps.InvalidPsRecord
static class	Ps.PsOutput

Field Summary

Fields

Modifier and Type	Field and Description
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
Ps()

Method Summary

Methods

Modifier and Type	Method and Description
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, 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

Constructor Detail

Ps

public Ps()

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