ai.grakn.batch

Class BatchExecutorClient

java.lang.Object

ai.grakn.batch.BatchExecutorClient

All Implemented Interfaces:

Closeable, AutoCloseable

public class BatchExecutorClient
extends Object
implements Closeable

Client to batch load qraql queries into Grakn that mutate the graph. Provides methods to batch load queries. Optionally can provide a consumer that will execute when a batch finishes loading. BatchExecutorClient will block when the configured resources are being used to execute tasks.

Author:

Domenico Corapi

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BatchExecutorClient.Builder Builder

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

add

public void add(Query<?> query,
                Keyspace keyspace)

Will block until there is space for the query to be submitted

onNext

public void onNext(java.util.function.Consumer<? super QueryResponse> queryResponseHandler)

onError

public void onError(java.util.function.Consumer<? super Exception> exceptionHandler)

close

public void close()

Will block until all submitted queries have executed

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

newBuilder

public static BatchExecutorClient.Builder newBuilder()

newBuilderforURI

public static BatchExecutorClient.Builder newBuilderforURI(SimpleURI simpleURI)