commit | ab1013cb90d3ebaba0b55821215eb927fb0b5478 | [log] [tgz] |
---|---|---|
author | Murtadha Hubail <mhubail@apache.org> | Sun Jan 07 15:56:28 2018 +0300 |
committer | Murtadha Hubail <mhubail@apache.org> | Mon Jan 08 10:01:40 2018 -0800 |
tree | 1af294b05a1c3748eea96018e39c84a6329008ab | |
parent | 60be06537a45cfbc13229229ac64c707ea826134 [diff] |
[ASTERIXDB-2207][CLUS] Add Delete API to ICoordinationService - user model changes: no - storage format changes: no - interface changes: yes - Add delete to ICoordinationService Change-Id: Ie3a17fb1cec9350025cdf0ee340c80d7e0f1a9f0 Reviewed-on: https://asterix-gerrit.ics.uci.edu/2267 Sonar-Qube: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Reviewed-by: Michael Blow <mblow@apache.org>
diff --git a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/api/ICoordinationService.java b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/api/ICoordinationService.java index 6f929b1..6146084 100644 --- a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/api/ICoordinationService.java +++ b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/api/ICoordinationService.java
@@ -42,4 +42,12 @@ * @throws HyracksDataException */ Optional<byte[]> get(String key) throws HyracksDataException; -} + + /** + * Deletes the property with name {@code key} if exists. + * + * @param key + * @throws HyracksDataException + */ + void delete(String key) throws HyracksDataException; +} \ No newline at end of file
diff --git a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/NoOpCoordinationService.java b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/NoOpCoordinationService.java index ed29f4b..6f9a8d2 100644 --- a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/NoOpCoordinationService.java +++ b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/NoOpCoordinationService.java
@@ -38,4 +38,9 @@ public Optional<byte[]> get(String key) { throw new UnsupportedOperationException(); } + + @Override + public void delete(String key) { + throw new UnsupportedOperationException(); + } }