hey @ibrahim,here is part of the code I used to write data to Dgraph
return Task.fromCompletionStage("do_write",() -> {
AsyncTransaction txn = dgraphClient.newTransaction();
DgraphProto.Mutation.Builder builder = DgraphProto.Mutation.newBuilder().setCommitNow(true);
if (RLStringUtils.hasText(set)) {
builder.setSetNquads(ByteString.copyFromUtf8(set));
}
if (RLStringUtils.hasText(del)) {
builder.setDelNquads(ByteString.copyFromUtf8(del));
}
return txn.mutate(builder.build()).thenApply(response -> {
txn.discard();
return response.getUidsCount();
});
})