Revision 39575
Added by Claudio Atzori over 8 years ago
| HadoopService.java | ||
|---|---|---|
| 3 | 3 |
import java.util.List; |
| 4 | 4 |
import java.util.Map; |
| 5 | 5 |
import java.util.Set; |
| 6 |
|
|
| 7 | 6 |
import javax.jws.WebParam; |
| 8 | 7 |
import javax.jws.WebService; |
| 9 | 8 |
|
| ... | ... | |
| 157 | 156 |
Map<String, String> getClusterConfiguration(@WebParam(name = "clusterName") String clusterName) throws HadoopServiceException; |
| 158 | 157 |
|
| 159 | 158 |
/** |
| 159 |
* Deletes a path on HDFS |
|
| 160 |
* |
|
| 161 |
* @param clusterName |
|
| 162 |
* the cluster name |
|
| 163 |
* @param path |
|
| 164 |
* the path to be deleted |
|
| 165 |
* @return true in case of success |
|
| 166 |
* |
|
| 167 |
* @throws HadoopServiceException |
|
| 168 |
*/ |
|
| 169 |
boolean deleteHdfsPath(@WebParam(name = "clusterName") String clusterName, @WebParam(name = "path") String path) |
|
| 170 |
throws HadoopServiceException; |
|
| 171 |
|
|
| 172 |
/** |
|
| 173 |
* Creates a directory on HDFS, eventually deleteing its content. |
|
| 174 |
* |
|
| 175 |
* @param clusterName |
|
| 176 |
* the cluster name |
|
| 177 |
* @param path |
|
| 178 |
* the path to be created |
|
| 179 |
* @param force |
|
| 180 |
* force delete before create |
|
| 181 |
* @return |
|
| 182 |
* true in case of success |
|
| 183 |
* @throws HadoopServiceException |
|
| 184 |
*/ |
|
| 185 |
boolean createHdfsDirectory(@WebParam(name = "clusterName") String clusterName, @WebParam(name = "path") String path, @WebParam(name = "force") boolean force) |
|
| 186 |
throws HadoopServiceException; |
|
| 187 |
|
|
| 188 |
/** |
|
| 160 | 189 |
* List the configured cluster names. |
| 161 | 190 |
* |
| 162 | 191 |
* @return the list of configured cluster names. |
Also available in: Unified diff
added new rmi methods: deleteHdfsPath, createHdfsDirectory
added blackboard action: DELETE_HDFS_PATH