Project

General

Profile

« Previous | Next » 

Revision 39676

implemented methods describeHBaseColumn, describeHBaseColumns

View differences:

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