Runs a DQL query or mutation using the RunDQL RPC. @param request a fully-built RunDQLRequest @return CompletableFuture with the Response
(DgraphProto.RunDQLRequest request)
| 260 | * @return CompletableFuture with the Response |
| 261 | */ |
| 262 | public CompletableFuture<DgraphProto.Response> runDQL(DgraphProto.RunDQLRequest request) { |
| 263 | final DgraphGrpc.DgraphStub stub = anyClient(); |
| 264 | |
| 265 | return runWithRetries( |
| 266 | "runDQL", |
| 267 | () -> { |
| 268 | StreamObserverBridge<DgraphProto.Response> bridge = new StreamObserverBridge<>(); |
| 269 | DgraphGrpc.DgraphStub localStub = getStubWithJwt(stub); |
| 270 | localStub.runDQL(request, bridge); |
| 271 | return bridge.getDelegate(); |
| 272 | }); |
| 273 | } |
| 274 | |
| 275 | /** |
| 276 | * Runs a DQL query or mutation with default options. |
nothing calls this directly
no test coverage detected