Revision 50077
Added by Claudio Atzori over 6 years ago
| modules/dnet-hadoop-service/trunk/src/main/java/eu/dnetlib/data/hadoop/HadoopClientMap.java | ||
|---|---|---|
| 15 | 15 |
import org.apache.hadoop.hbase.client.HBaseAdmin; |
| 16 | 16 |
import org.apache.hadoop.mapred.JobClient; |
| 17 | 17 |
import org.apache.oozie.client.OozieClient; |
| 18 |
import org.springframework.beans.factory.annotation.Autowired; |
|
| 19 | 18 |
import org.springframework.beans.factory.annotation.Required; |
| 20 | 19 |
|
| 21 | 20 |
|
| ... | ... | |
| 23 | 22 |
|
| 24 | 23 |
private static final Log log = LogFactory.getLog(HadoopClientMap.class); // NOPMD by marko on 11/24/08 5:02 PM |
| 25 | 24 |
|
| 26 |
@Autowired |
|
| 27 | 25 |
private JobClientFactory jobClientFactory; |
| 28 | 26 |
|
| 29 |
@Autowired |
|
| 30 | 27 |
private OozieClientFactory oozieClientFactory; |
| 31 | 28 |
|
| 32 |
@Autowired |
|
| 33 | 29 |
private HBaseAdminFactory hbaseAdminFactory; |
| 34 | 30 |
|
| 35 | 31 |
private Map<String, Map<String, String>> enabledClients = Maps.newHashMap(); |
| ... | ... | |
| 95 | 91 |
return jobClientFactory; |
| 96 | 92 |
} |
| 97 | 93 |
|
| 98 |
public void setJobClientFactory(JobClientFactory jobClientFactory) {
|
|
| 94 |
@Required |
|
| 95 |
public void setJobClientFactory(final JobClientFactory jobClientFactory) {
|
|
| 99 | 96 |
this.jobClientFactory = jobClientFactory; |
| 100 | 97 |
} |
| 101 | 98 |
|
| ... | ... | |
| 103 | 100 |
return oozieClientFactory; |
| 104 | 101 |
} |
| 105 | 102 |
|
| 106 |
public void setOozieClientFactory(OozieClientFactory oozieClientFactory) {
|
|
| 103 |
@Required |
|
| 104 |
public void setOozieClientFactory(final OozieClientFactory oozieClientFactory) {
|
|
| 107 | 105 |
this.oozieClientFactory = oozieClientFactory; |
| 108 | 106 |
} |
| 109 | 107 |
|
| ... | ... | |
| 111 | 109 |
return hbaseAdminFactory; |
| 112 | 110 |
} |
| 113 | 111 |
|
| 114 |
public void setHbaseAdminFactory(HBaseAdminFactory hbaseAdminFactory) {
|
|
| 112 |
@Required |
|
| 113 |
public void setHbaseAdminFactory(final HBaseAdminFactory hbaseAdminFactory) {
|
|
| 115 | 114 |
this.hbaseAdminFactory = hbaseAdminFactory; |
| 116 | 115 |
} |
| 117 | 116 |
|
| modules/dnet-hadoop-service/trunk/src/main/resources/eu/dnetlib/data/hadoop/applicationContext-dnet-hadoop-service.xml | ||
|---|---|---|
| 79 | 79 |
<bean id="isClient" class="eu.dnetlib.data.hadoop.ISClient" /> |
| 80 | 80 |
|
| 81 | 81 |
<bean id="hadoopClientMap" class="eu.dnetlib.data.hadoop.HadoopClientMap" |
| 82 |
p:enabledClients="${services.hadoop.clients}" />
|
|
| 82 |
p:enabledClients="${services.hadoop.clients}"
|
|
| 83 |
p:jobClientFactory-ref="jobClientFactory" |
|
| 84 |
p:hbaseAdminFactory-ref="hbaseAdminFactory" |
|
| 85 |
p:oozieClientFactory-ref="oozieClientFactory" /> |
|
| 83 | 86 |
|
| 84 | 87 |
<bean id="oozieClientFactory" class="eu.dnetlib.data.hadoop.oozie.OozieClientFactory" /> |
| 85 | 88 |
|
Also available in: Unified diff
client factories injected via @Required