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;
19
20 import org.apache.hadoop.chukwa.datatrigger.TriggerAction;
21 import org.apache.hadoop.chukwa.datatrigger.TriggerEvent;
22 import org.apache.hadoop.fs.FileSystem;
23 import org.apache.hadoop.fs.FileStatus;
24 import org.apache.hadoop.conf.Configuration;
25
26 import java.io.IOException;
27 import java.util.Collection;
28 import java.util.ArrayList;
29
30 public class MockTriggerAction implements TriggerAction {
31
32 private static Collection<TriggerEvent> triggerEvents = new ArrayList<TriggerEvent>();
33
34 public void execute(Configuration conf, FileSystem fs,
35 FileStatus[] src, TriggerEvent event) throws IOException {
36 triggerEvents.add(event);
37 }
38
39 public static void reset() {
40 triggerEvents = new ArrayList<TriggerEvent>();
41 }
42
43 public static Collection<TriggerEvent> getTriggerEvents() {
44 return triggerEvents;
45 }
46 }