Project

General

Profile

1
package eu.dnetlib.data.hadoop;
2

    
3
import org.apache.hadoop.hbase.client.HBaseAdmin;
4
import org.apache.hadoop.mapred.JobClient;
5
import org.apache.oozie.client.OozieClient;
6

    
7
public class HadoopClients {
8

    
9
	private final JobClient jtClient;
10

    
11
	private final OozieClient oozieClient;
12

    
13
	private final HBaseAdmin hbaseAdmin;
14

    
15
	public HadoopClients(JobClient jtClient, OozieClient oozieClient, HBaseAdmin hbaseAdmin) {
16
		super();
17
		this.jtClient = jtClient;
18
		this.oozieClient = oozieClient;
19
		this.hbaseAdmin = hbaseAdmin;
20
	}
21

    
22
	public JobClient getJtClient() {
23
		return jtClient;
24
	}
25

    
26
	public HBaseAdmin getHbaseAdmin() {
27
		return hbaseAdmin;
28
	}
29

    
30
	public OozieClient getOozieClient() {
31
		return oozieClient;
32
	}
33

    
34
	public boolean isOozieAvailable() {
35
		return getOozieClient() != null;
36
	}
37

    
38
	public boolean isHbaseAvailable() {
39
		return getHbaseAdmin() != null;
40
	}
41

    
42
	public boolean isMapredAvailable() {
43
		return getJtClient() != null;
44
	}
45

    
46
}
(2-2/7)