@Test public void testCloseConnection() throws Exception { hbaseDataStore.closeConnection((HTable) null); hbaseDataStore.closeConnection((String) null); hbaseDataStore.closeConnection(htable); hbaseDataStore.closeConnection("tableName"); }
public void closeConnection(String tableName) { LOG.debug("Entering closeConnection(String tableName)"); HTableInterface htableResult = removeFromHtableMap(tableName); if (htableResult != null) { try { htableResult.close(); } catch (IOException e) { LOG.error("Cannot close connection:", e); } } LOG.debug("Exiting closeConnection(String tableName)"); }
HBaseDataStore { public void closeConnection(String tableName) { LOG.debug("Entering closeConnection(String tableName)"); HTableInterface htableResult = removeFromHtableMap(tableName); if (htableResult != null) { try { htableResult.close(); } catch (IOException e) { LOG.error("Cannot close connection:", e); } } LOG.debug("Exiting closeConnection(String tableName)"); } }
HBaseDataStore { public void closeConnection(String tableName) { LOG.debug("Entering closeConnection(String tableName)"); HTableInterface htableResult = removeFromHtableMap(tableName); if (htableResult != null) { try { htableResult.close(); } catch (IOException e) { LOG.error("Cannot close connection:", e); } } LOG.debug("Exiting closeConnection(String tableName)"); } HBaseDataStore();  HBaseDataStore(HBaseDataStoreContext context); }
HBaseDataStore { public void closeConnection(String tableName) { LOG.debug("Entering closeConnection(String tableName)"); HTableInterface htableResult = removeFromHtableMap(tableName); if (htableResult != null) { try { htableResult.close(); } catch (IOException e) { LOG.error("Cannot close connection:", e); } } LOG.debug("Exiting closeConnection(String tableName)"); } HBaseDataStore();  HBaseDataStore(HBaseDataStoreContext context); HTableInterface getConnection(String tableName); void createTable(String tableName); HBaseEntity create(final HBaseEntity entity); List<HBaseEntity> create(List<HBaseEntity> entityList); List<HBaseEntity> getDataByRowFamilyQualifier(String tableName, String startRow, String endRow,
            String family, String qualifier); List<HBaseEntity> getDataByRowFamilyQualifier(String tableName, String startRow, String endRow,
            String family, String qualifier, long pageSize); List<HBaseEntity> getDataByRowFamilyQualifier(String tableName, String startRow, String endRow,
            String family, List<String> qualifierList); List<HBaseEntity> getDataByRowFamilyQualifier(String tableName, String startRow, String endRow,
            String family, List<String> qualifierList, long pageSize); List<HBaseEntity> getDataByTimeRange(String tableName, long startTime, long endTime); List<HBaseEntity> getDataByTimeRange(String tableName, List<String> filters, long startTime, long endTime); void deleteByTimestamp(String tableName, long timestamp); HBaseEntity convertResultToEntity(String tableName, Result result); void flushCommit(String tableName); void closeConnection(String tableName); void closeConnection(HTable htable); }
HBaseDataStore { public void closeConnection(String tableName) { LOG.debug("Entering closeConnection(String tableName)"); HTableInterface htableResult = removeFromHtableMap(tableName); if (htableResult != null) { try { htableResult.close(); } catch (IOException e) { LOG.error("Cannot close connection:", e); } } LOG.debug("Exiting closeConnection(String tableName)"); } HBaseDataStore();  HBaseDataStore(HBaseDataStoreContext context); HTableInterface getConnection(String tableName); void createTable(String tableName); HBaseEntity create(final HBaseEntity entity); List<HBaseEntity> create(List<HBaseEntity> entityList); List<HBaseEntity> getDataByRowFamilyQualifier(String tableName, String startRow, String endRow,
            String family, String qualifier); List<HBaseEntity> getDataByRowFamilyQualifier(String tableName, String startRow, String endRow,
            String family, String qualifier, long pageSize); List<HBaseEntity> getDataByRowFamilyQualifier(String tableName, String startRow, String endRow,
            String family, List<String> qualifierList); List<HBaseEntity> getDataByRowFamilyQualifier(String tableName, String startRow, String endRow,
            String family, List<String> qualifierList, long pageSize); List<HBaseEntity> getDataByTimeRange(String tableName, long startTime, long endTime); List<HBaseEntity> getDataByTimeRange(String tableName, List<String> filters, long startTime, long endTime); void deleteByTimestamp(String tableName, long timestamp); HBaseEntity convertResultToEntity(String tableName, Result result); void flushCommit(String tableName); void closeConnection(String tableName); void closeConnection(HTable htable);  }