Method get

ZezeJava/ZezeJava/src/main/java/Zeze/Dbh2/Dbh2Agent.java:65–81

(String databaseName, String tableName, Binary key)

	}

	public KV<Boolean, ByteBuffer> get(String databaseName, String tableName, Binary key) {
		var r = new Get();
		r.Argument.setDatabase(databaseName);
		r.Argument.setTable(tableName);
		r.Argument.setKey(key);
		r.setTimeout(config.getRpcTimeout());
		raftClient.sendForWait(r).await();

		if (r.getResultCode() == errorCode(eBucketMismatch))
			return KV.create(false, null);

		if (r.getResultCode() != 0 && r.getResultCode() != Procedure.RaftApplied)
			throw new RuntimeException("fail! code=" + r.getResultCode());

		var bb = r.Result.isNull() ? null : ByteBuffer.Wrap(r.Result.getValue());
		return KV.create(true, bb);
	}

	public TaskCompletionSourceX<RaftRpc<BPrepareBatch.Data, BRefused.Data>> prepareBatch(BPrepareBatch.Data batch) {
		var r = new PrepareBatch();