1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.hadoop.chukwa.extraction.demux.processor.mapper;
19
20
21 import java.io.IOException;
22 import org.apache.hadoop.chukwa.extraction.engine.ChukwaRecord;
23 import org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey;
24 import org.apache.hadoop.mapred.OutputCollector;
25 import org.apache.hadoop.mapred.Reporter;
26 import org.apache.log4j.Logger;
27
28 public class DefaultProcessor extends AbstractProcessor {
29 static Logger log = Logger.getLogger(DefaultProcessor.class);
30
31 @Override
32 protected void parse(String recordEntry,
33 OutputCollector<ChukwaRecordKey, ChukwaRecord> output, Reporter reporter) {
34 try {
35 ChukwaRecord record = new ChukwaRecord();
36 this.buildGenericRecord(record, recordEntry, archiveKey
37 .getTimePartition(), chunk.getDataType());
38 output.collect(key, record);
39 } catch (IOException e) {
40 log.warn("Unable to collect output in DefaultProcessor [" + recordEntry
41 + "]", e);
42 e.printStackTrace();
43 }
44 }
45 }