1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.chukwa.extraction.demux.processor.mapper;
20
21
22 import java.util.HashMap;
23 import org.apache.log4j.Logger;
24
25 public class MapProcessorFactory {
26 static Logger log = Logger.getLogger(MapProcessorFactory.class);
27
28 private static HashMap<String, MapProcessor> processors = new HashMap<String, MapProcessor>();
29
30 public MapProcessorFactory() {
31 }
32
33 public static MapProcessor getProcessor(String parserClass)
34 throws UnknownRecordTypeException {
35 if (processors.containsKey(parserClass)) {
36 return processors.get(parserClass);
37 } else {
38 MapProcessor processor = null;
39 try {
40 processor = (MapProcessor) Class.forName(parserClass).getConstructor()
41 .newInstance();
42 } catch (ClassNotFoundException e) {
43 throw new UnknownRecordTypeException("Unknown parserClass:"
44 + parserClass, e);
45 } catch (Exception e) {
46 throw new UnknownRecordTypeException("error constructing processor", e);
47 }
48
49
50
51 processors.put(parserClass, processor);
52 return processor;
53 }
54 }
55 }