1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.hadoop.chukwa.datacollection.writer;
19
20 import java.util.List;
21 import org.apache.hadoop.chukwa.Chunk;
22 import org.apache.hadoop.chukwa.datacollection.collector.servlet.LogDisplayServlet;
23 import org.apache.hadoop.conf.Configuration;
24
25 public class ExtractorWriter extends PipelineableWriter {
26
27 public static LogDisplayServlet recipient;
28
29 @Override
30 public void close() throws WriterException {
31 next.close();
32 }
33
34 @Override
35 public void init(Configuration c) throws WriterException {
36 }
37
38 public CommitStatus add(List<Chunk> chunks) throws WriterException {
39 if(recipient != null)
40 recipient.add(chunks);
41 if (next != null)
42 return next.add(chunks);
43 else
44 return ChukwaWriter.COMMIT_OK;
45 }
46
47 }