1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.chukwa.datacollection.adaptor;
20
21
22 import org.apache.hadoop.chukwa.datacollection.ChunkReceiver;
23
24 public class ChukwaTestAdaptor extends AbstractAdaptor {
25
26 private String params = null;
27 private long startOffset = 0l;
28
29 @Override
30 public String getCurrentStatus() {
31
32 return type + " " + params + " " + startOffset;
33 }
34
35 @Override
36 public String parseArgs(String s) {
37 params = s;
38 return s;
39 }
40
41 @Override
42 public void start(long offset) throws AdaptorException {
43 this.startOffset = offset;
44 System.out.println("adaptorId [" + adaptorID + "]");
45 System.out.println("type [" + type + "]");
46 System.out.println("params [" + params + "]");
47 System.out.println("startOffset [" + startOffset + "]");
48
49 }
50
51 public String getParams() {
52 return params;
53 }
54
55 public void setParams(String params) {
56 this.params = params;
57 }
58
59 public long getStartOffset() {
60 return startOffset;
61 }
62
63
64 @Override
65 public long shutdown(AdaptorShutdownPolicy shutdownPolicy)
66 throws AdaptorException {
67 return 0;
68 }
69
70 }