Revision 39676
Added by Claudio Atzori over 8 years ago
HadoopServiceImpl.java | ||
---|---|---|
12 | 12 |
import eu.dnetlib.data.hadoop.rmi.HadoopJobDescriptor; |
13 | 13 |
import eu.dnetlib.data.hadoop.rmi.HadoopService; |
14 | 14 |
import eu.dnetlib.data.hadoop.rmi.HadoopServiceException; |
15 |
import eu.dnetlib.data.hadoop.rmi.hbase.HBaseRowDescriptor; |
|
15 | 16 |
import eu.dnetlib.enabling.tools.AbstractBaseService; |
16 | 17 |
import eu.dnetlib.enabling.tools.blackboard.NotificationHandler; |
17 | 18 |
import org.apache.hadoop.conf.Configuration; |
... | ... | |
211 | 212 |
} |
212 | 213 |
} |
213 | 214 |
|
214 |
// ///////////////// |
|
215 |
@Override |
|
216 |
public HBaseRowDescriptor describeHBaseColumn(final String clusterName, final String tableName, final String rowKey) throws HadoopServiceException { |
|
217 |
try { |
|
218 |
return hadoopServiceCore.describeRow(checkExists(clusterName), tableName, rowKey); |
|
219 |
} catch (IOException e) { |
|
220 |
throw new HadoopServiceException(e); |
|
221 |
} |
|
222 |
} |
|
215 | 223 |
|
224 |
@Override |
|
225 |
public Map<String, HBaseRowDescriptor> describeHBaseColumns(final String clusterName, final String tableName, final List<String> rowKeys) throws HadoopServiceException { |
|
226 |
try { |
|
227 |
return hadoopServiceCore.describeRows(checkExists(clusterName), tableName, rowKeys); |
|
228 |
} catch (IOException e) { |
|
229 |
throw new HadoopServiceException(e); |
|
230 |
} |
|
231 |
} |
|
232 |
|
|
233 |
/////////////////// |
|
234 |
|
|
216 | 235 |
/** |
217 | 236 |
* Check exists. |
218 | 237 |
* |
Also available in: Unified diff
implemented methods describeHBaseColumn, describeHBaseColumns