public class ClearSubkeysCmd extends CmdBase implements Cmd<Boolean>
An Usage Example:
This example adds a subkey to a key and retrieves it, then clears it.
package com.example;
import ax.antpick.k2hdkc.*;
import com.sun.jna.*;
import com.sun.jna.ptr.*;
import java.io.IOException;
import java.util.*;
import java.util.stream.*;
public class App {
public static void main(String[] args) {
try (Cluster c = Cluster.of("cluster/slave.yaml");
Session s = Session.of(c); ) {
// 1. add a subkey
AddSubkeyCmd cmd = AddSubkeyCmd.of("key", "subkey");
System.out.println(cmd.execute(s).get().getValue()); // true
// 2. get subkeys
GetSubkeysCmd get = GetSubkeysCmd.of("key");
List<String> list = (List<String>) get.execute(s).get().getValue(); // subkey
System.out.println(list.get(0)); // subkey
// 3. clear subkeys
ClearSubkeysCmd clear = ClearSubkeysCmd.of("key");
System.out.println(clear.execute(s).get().getValue()); // true
} catch (IOException ex) {
System.out.println(ex.getMessage());
assert (false);
}
}
}
Before running the code above, You should run three processes.
The following commands in this repository will run all processes you need in localhost.
$ cd cluster
$ sh start_server.sh
Cmd.DataType
DEFAULT_CHECK_PARENT_ATTRS, DEFAULT_EXPIRATION_DURATION, DEFAULT_IS_CHECK_PARENT_ATTRS, DEFAULT_IS_CLEAR_SUBKEYS, DEFAULT_IS_FIFO, DEFAULT_IS_INCREMENT, DEFAULT_NEED_RETURN_VALUE, DEFAULT_PARENT_KEY, DEFAULT_PASS, DEFAULT_REMOVE_ELEMENT_SIZE, DEFAULT_REMOVE_RECURSIVELY, DEFAULT_SUBKEYS
Modifier and Type | Method and Description |
---|---|
<T> Optional<Result<T>> |
execute(Session session)
Clear subkeys of a key.
|
static ClearSubkeysCmd |
of(String key)
Constructs a ClearSubkeysCmd instance.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
bytesToInt, getValusAsInt
public static ClearSubkeysCmd of(String key)
key
- a key stringIllegalArgumentException
- if a key string is null or emptypublic <T> Optional<Result<T>> execute(Session session) throws IOException
execute
in interface Cmd<Boolean>
session
- a Session
objectIllegalArgumentException
- if an illegal augment existsIOException
- if underlying library errors occur.Copyright © 2020. All rights reserved.