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

Class DebugOutputProcessor

java.lang.Object

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

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

All Implemented Interfaces:

MapProcessor

public class DebugOutputProcessor
extends AbstractProcessor

Field Summary

Fields

Modifier and Type	Field and Description
static String	recordType

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

archiveKey, chunk, key

Constructor Summary

Constructors

Constructor and Description
DebugOutputProcessor()

Method Summary

Methods

Modifier and Type	Method and Description
String	getDataType()
void	parse(String line, 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

Field Detail

recordType

public static final String recordType

See Also:

Constant Field Values

Constructor Detail

DebugOutputProcessor

public DebugOutputProcessor()

Method Detail

parse

public void parse(String line,
         org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
         org.apache.hadoop.mapred.Reporter reporter)

Specified by:

parse in class AbstractProcessor

getDataType

public String getDataType()