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.chukwa.datacollection.writer.ChukwaWriter.CommitStatus;
24 import org.apache.hadoop.conf.Configuration;
25
26 public class ExtractorWriter extends PipelineableWriter {
27
28 public static LogDisplayServlet recipient;
29
30 @Override
31 public void close() throws WriterException {
32 next.close();
33 }
34
35 @Override
36 public void init(Configuration c) throws WriterException {
37 }
38
39 public CommitStatus add(List<Chunk> chunks) throws WriterException {
40 if(recipient != null)
41 recipient.add(chunks);
42 if (next != null)
43 return next.add(chunks);
44 else
45 return ChukwaWriter.COMMIT_OK;
46 }
47
48 }