1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.hadoop.chukwa.datacollection.collector;
19
20
21 import java.util.ArrayList;
22 import java.util.List;
23 import org.apache.hadoop.chukwa.Chunk;
24 import org.apache.hadoop.chukwa.datacollection.writer.ChukwaWriter;
25 import org.apache.hadoop.chukwa.datacollection.writer.WriterException;
26 import org.apache.hadoop.conf.Configuration;
27
28
29
30
31 public class CaptureWriter implements ChukwaWriter {
32 public static ArrayList<Chunk> outputs = new ArrayList<Chunk>();
33
34 @Override
35 public CommitStatus add(List<Chunk> chunks) throws WriterException {
36
37 synchronized (outputs) {
38 for (Chunk c : chunks)
39 outputs.add(c);
40 }
41 return COMMIT_OK;
42 }
43
44 @Override
45 public void close() throws WriterException {
46 }
47
48 @Override
49 public void init(Configuration c) throws WriterException {
50 }
51
52 }