Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- void deleteAll(String entityId) {
- try {
- if (transactionState != null) {
- transactionalTable.deleteAll(transactionState, Bytes.toBytes(entityId), HConstants.LATEST_TIMESTAMP);
- } else {
- table.deleteAll(entityId);
- }
- } catch (IOException e) {
- throw new DbException(e);
- }
- }
- New Syntax
- void deleteAll(String entityId) {
- try {
- Delete delete = new Delete(entityId.getBytes());
- if (transactionState != null) {
- transactionalTable.delete(transactionState, delete);
- } else {
- table.delete(delete);
- }
- } catch (IOException e) {
- throw new DbException(e);
- }
- }
Add Comment
Please, Sign In to add comment