public class BatchExecutorClient extends Object implements Closeable
| Modifier and Type | Class and Description |
|---|---|
static class |
BatchExecutorClient.Builder
Builder
|
| Modifier and Type | Method and Description |
|---|---|
void |
add(Query<?> query,
Keyspace keyspace)
Will block until there is space for the query to be submitted
|
void |
close()
Will block until all submitted queries have executed
|
static BatchExecutorClient.Builder |
newBuilder() |
static BatchExecutorClient.Builder |
newBuilderforURI(SimpleURI simpleURI) |
void |
onError(java.util.function.Consumer<? super Exception> exceptionHandler) |
void |
onNext(java.util.function.Consumer<? super QueryResponse> queryResponseHandler) |
public void add(Query<?> query, Keyspace keyspace)
public void onNext(java.util.function.Consumer<? super QueryResponse> queryResponseHandler)
public void onError(java.util.function.Consumer<? super Exception> exceptionHandler)
public void close()
close in interface Closeableclose in interface AutoCloseablepublic static BatchExecutorClient.Builder newBuilder()
public static BatchExecutorClient.Builder newBuilderforURI(SimpleURI simpleURI)
Copyright © 2018 Grakn Labs Ltd. All rights reserved.