Package io.weaviate.client.v1.async.batch.api

Class ObjectsBatcher

java.lang.Object

io.weaviate.client.base.AsyncBaseClient<ObjectGetResponse[]>

io.weaviate.client.v1.async.batch.api.ObjectsBatcher

All Implemented Interfaces:

AsyncClientResult<ObjectGetResponse[]>

public class ObjectsBatcher
extends AsyncBaseClient<ObjectGetResponse[]>
implements AsyncClientResult<ObjectGetResponse[]>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ObjectsBatcher.AutoBatchConfig
static class	ObjectsBatcher.BatchRetriesConfig

Field Summary

Fields inherited from class io.weaviate.client.base.AsyncBaseClient

client

Method Summary

Modifier and Type	Method	Description
static ObjectsBatcher	create(org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient client, Config config, Data data, ObjectsPath objectsPath, AccessTokenProvider tokenProvider, GrpcVersionSupport grpcVersionSupport, ObjectsBatcher.BatchRetriesConfig batchRetriesConfig, Executor executor)
static ObjectsBatcher	createAuto(org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient client, Config config, Data data, ObjectsPath objectsPath, AccessTokenProvider tokenProvider, GrpcVersionSupport grpcVersionSupport, ObjectsBatcher.BatchRetriesConfig batchRetriesConfig, ObjectsBatcher.AutoBatchConfig autoBatchConfig, Executor executor)
Future<Result<ObjectGetResponse[]>>	run(org.apache.hc.core5.concurrent.FutureCallback<Result<ObjectGetResponse[]>> callback)
ObjectsBatcher	withConsistencyLevel(String consistencyLevel)
ObjectsBatcher	withObject(WeaviateObject object)
ObjectsBatcher	withObjects(WeaviateObject... objects)

Methods inherited from class io.weaviate.client.base.AsyncBaseClient

getRequest, sendDeleteRequest, sendDeleteRequest, sendGetRequest, sendGetRequest, sendHeadRequest, sendHeadRequest, sendPatchRequest, sendPatchRequest, sendPostRequest, sendPostRequest, sendPutRequest, sendPutRequest

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.weaviate.client.base.AsyncClientResult

run

Method Details

create

public static ObjectsBatcher create(org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient client,
 Config config,
 Data data,
 ObjectsPath objectsPath,
 AccessTokenProvider tokenProvider,
 GrpcVersionSupport grpcVersionSupport,
 ObjectsBatcher.BatchRetriesConfig batchRetriesConfig,
 Executor executor)

createAuto

public static ObjectsBatcher createAuto(org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient client,
 Config config,
 Data data,
 ObjectsPath objectsPath,
 AccessTokenProvider tokenProvider,
 GrpcVersionSupport grpcVersionSupport,
 ObjectsBatcher.BatchRetriesConfig batchRetriesConfig,
 ObjectsBatcher.AutoBatchConfig autoBatchConfig,
 Executor executor)

withObject

public ObjectsBatcher withObject(WeaviateObject object)

withObjects

public ObjectsBatcher withObjects(WeaviateObject... objects)

withConsistencyLevel

public ObjectsBatcher withConsistencyLevel(String consistencyLevel)

run

public Future<Result<ObjectGetResponse[]>> run(org.apache.hc.core5.concurrent.FutureCallback<Result<ObjectGetResponse[]>> callback)

Specified by:

run in interface AsyncClientResult<ObjectGetResponse[]>