Revision 42201
Added by Claudio Atzori about 8 years ago
| HBaseActionManagerCore.java | ||
|---|---|---|
| 13 | 13 |
import eu.dnetlib.actionmanager.rmi.ActionManagerException; |
| 14 | 14 |
import eu.dnetlib.actionmanager.set.ActionManagerSet; |
| 15 | 15 |
import eu.dnetlib.actionmanager.set.RawSet; |
| 16 |
import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpException; |
|
| 17 |
import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService; |
|
| 16 | 18 |
import eu.dnetlib.miscutils.datetime.DateUtils; |
| 17 | 19 |
import org.apache.hadoop.hbase.client.Delete; |
| 18 | 20 |
import org.apache.hadoop.hbase.client.Put; |
| ... | ... | |
| 103 | 105 |
hbaseClient.delete(deletes); |
| 104 | 106 |
} |
| 105 | 107 |
|
| 108 |
public String getBasePathHDFS() throws ISLookUpException {
|
|
| 109 |
return informationServiceClient.getBasePathHDFS(); |
|
| 110 |
} |
|
| 111 |
|
|
| 106 | 112 |
public ActionFactory getActionFactory() {
|
| 107 | 113 |
return actionFactory; |
| 108 | 114 |
} |
Also available in: Unified diff
introduced creation/deletion of ActionSet directory on HDFS