1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.chukwa.extraction.engine;
20
21
22 import java.util.List;
23 import java.util.TreeMap;
24 import org.apache.hadoop.chukwa.extraction.engine.datasource.DataSource;
25 import org.apache.hadoop.chukwa.extraction.engine.datasource.DataSourceException;
26 import org.apache.hadoop.chukwa.extraction.engine.datasource.DataSourceFactory;
27
28 public class ChukwaSearchService implements SearchService {
29 private DataSourceFactory dataSourceFactory = DataSourceFactory.getInstance();
30
31 public SearchResult search(String cluster, String[] dataSources, long t0,
32 long t1, String filter, Token token) throws DataSourceException {
33 SearchResult result = new ChukwaSearchResult();
34
35 TreeMap<Long, List<Record>> records = new TreeMap<Long, List<Record>>();
36 result.setRecords(records);
37
38 for (int i = 0; i < dataSources.length; i++) {
39 DataSource ds = dataSourceFactory.getDataSource(dataSources[i]);
40 ds.search(result, cluster, dataSources[i], t0, t1, filter, token);
41 }
42 return result;
43 }
44 }