Revision 31254
Added by Claudio Atzori over 9 years ago
HadoopServiceImpl.java | ||
---|---|---|
40 | 40 |
|
41 | 41 |
/* |
42 | 42 |
* (non-Javadoc) |
43 |
*
|
|
43 |
* |
|
44 | 44 |
* @see eu.dnetlib.data.hadoop.rmi.HadoopService#listAvailableJobs() |
45 | 45 |
*/ |
46 | 46 |
@Override |
... | ... | |
51 | 51 |
|
52 | 52 |
/* |
53 | 53 |
* (non-Javadoc) |
54 |
*
|
|
54 |
* |
|
55 | 55 |
* @see eu.dnetlib.data.hadoop.rmi.HadoopService#listJobs(java.lang.String) |
56 | 56 |
*/ |
57 | 57 |
@Override |
... | ... | |
61 | 61 |
|
62 | 62 |
/* |
63 | 63 |
* (non-Javadoc) |
64 |
*
|
|
64 |
* |
|
65 | 65 |
* @see eu.dnetlib.data.hadoop.rmi.HadoopService#killJob(java.lang.String) |
66 | 66 |
*/ |
67 | 67 |
@Override |
... | ... | |
72 | 72 |
|
73 | 73 |
/* |
74 | 74 |
* (non-Javadoc) |
75 |
*
|
|
75 |
* |
|
76 | 76 |
* @see eu.dnetlib.enabling.tools.AbstractBaseService#notify(java.lang.String, java.lang.String, java.lang.String, java.lang.String) |
77 | 77 |
*/ |
78 | 78 |
@Override |
... | ... | |
82 | 82 |
|
83 | 83 |
/* |
84 | 84 |
* (non-Javadoc) |
85 |
*
|
|
85 |
* |
|
86 | 86 |
* @see eu.dnetlib.data.hadoop.rmi.HadoopService#listHbaseTables(java.lang.String) |
87 | 87 |
*/ |
88 | 88 |
@Override |
... | ... | |
96 | 96 |
|
97 | 97 |
/* |
98 | 98 |
* (non-Javadoc) |
99 |
*
|
|
99 |
* |
|
100 | 100 |
* @see eu.dnetlib.data.hadoop.rmi.HadoopService#ensureHbaseTable(java.lang.String, java.lang.String, java.util.Set) |
101 | 101 |
*/ |
102 | 102 |
@Override |
... | ... | |
111 | 111 |
|
112 | 112 |
/* |
113 | 113 |
* (non-Javadoc) |
114 |
*
|
|
114 |
* |
|
115 | 115 |
* @see eu.dnetlib.data.hadoop.rmi.HadoopService#createHbaseTable(java.lang.String, java.lang.String, java.util.Set) |
116 | 116 |
*/ |
117 | 117 |
@Override |
... | ... | |
126 | 126 |
|
127 | 127 |
/* |
128 | 128 |
* (non-Javadoc) |
129 |
*
|
|
129 |
* |
|
130 | 130 |
* @see eu.dnetlib.data.hadoop.rmi.HadoopService#truncateHbaseTable(java.lang.String, java.lang.String) |
131 | 131 |
*/ |
132 | 132 |
@Override |
... | ... | |
141 | 141 |
|
142 | 142 |
/* |
143 | 143 |
* (non-Javadoc) |
144 |
*
|
|
144 |
* |
|
145 | 145 |
* @see eu.dnetlib.data.hadoop.rmi.HadoopService#dropHbaseTable(java.lang.String, java.lang.String) |
146 | 146 |
*/ |
147 | 147 |
@Override |
... | ... | |
156 | 156 |
|
157 | 157 |
/* |
158 | 158 |
* (non-Javadoc) |
159 |
*
|
|
159 |
* |
|
160 | 160 |
* @see eu.dnetlib.data.hadoop.rmi.HadoopService#existHbaseTable(java.lang.String, java.lang.String) |
161 | 161 |
*/ |
162 | 162 |
@Override |
... | ... | |
170 | 170 |
|
171 | 171 |
/* |
172 | 172 |
* (non-Javadoc) |
173 |
*
|
|
173 |
* |
|
174 | 174 |
* @see eu.dnetlib.data.hadoop.rmi.HadoopService#getClusterConfiguration(java.lang.String) |
175 | 175 |
*/ |
176 | 176 |
@Override |
... | ... | |
185 | 185 |
return res; |
186 | 186 |
} |
187 | 187 |
|
188 |
@Override |
|
189 |
public List<String> listClusters() throws HadoopServiceException { |
|
190 |
try { |
|
191 |
return ClusterName.asStringList(); |
|
192 |
} catch (Throwable e) { |
|
193 |
throw new HadoopServiceException(e); |
|
194 |
} |
|
195 |
} |
|
196 |
|
|
188 | 197 |
// ///////////////// |
189 | 198 |
|
190 | 199 |
/** |
191 | 200 |
* Check exists. |
192 |
*
|
|
201 |
* |
|
193 | 202 |
* @param clusterName |
194 | 203 |
* the cluster name |
195 | 204 |
* @return the cluster name |
... | ... | |
206 | 215 |
|
207 | 216 |
/** |
208 | 217 |
* Gets the notification handler. |
209 |
*
|
|
218 |
* |
|
210 | 219 |
* @return the notification handler |
211 | 220 |
*/ |
212 | 221 |
public NotificationHandler getNotificationHandler() { |
... | ... | |
215 | 224 |
|
216 | 225 |
/** |
217 | 226 |
* Sets the notification handler. |
218 |
*
|
|
227 |
* |
|
219 | 228 |
* @param notificationHandler |
220 | 229 |
* the new notification handler |
221 | 230 |
*/ |
Also available in: Unified diff
added listClusters soap method