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

Class ObjectsBatcher

java.lang.Object

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

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

All Implemented Interfaces:

ClientResult<ObjectGetResponse[]>, Closeable, AutoCloseable

public class ObjectsBatcher
extends BaseClient<ObjectGetResponse[]>
implements ClientResult<ObjectGetResponse[]>, Closeable

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.BaseClient

serializer

Method Summary

Modifier and Type	Method	Description
void	close()
static ObjectsBatcher	create(HttpClient httpClient, Config config, Data data, ObjectsPath objectsPath, AccessTokenProvider tokenProvider, GrpcVersionSupport grpcVersionSupport, ObjectsBatcher.BatchRetriesConfig batchRetriesConfig)
static ObjectsBatcher	createAuto(HttpClient httpClient, Config config, Data data, ObjectsPath objectsPath, AccessTokenProvider tokenProvider, GrpcVersionSupport grpcVersionSupport, ObjectsBatcher.BatchRetriesConfig batchRetriesConfig, ObjectsBatcher.AutoBatchConfig autoBatchConfig)
void	flush()
static Result<ObjectGetResponse[]>	resultFromBatchObjectsReply(WeaviateProtoBatch.BatchObjectsReply reply, List<WeaviateObject> batch)
Result<ObjectGetResponse[]>	run()
ObjectsBatcher	withConsistencyLevel(String consistencyLevel)
ObjectsBatcher	withObject(WeaviateObject object)
ObjectsBatcher	withObjects(WeaviateObject... objects)

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

getWeaviateErrorResponse, sendDeleteRequest, sendGetRequest, sendHeadRequest, sendHttpRequest, sendPatchRequest, sendPostRequest, sendPutRequest, toResponse

Methods inherited from class java.lang.Object

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

Method Details

create

public static ObjectsBatcher create(HttpClient httpClient,
 Config config,
 Data data,
 ObjectsPath objectsPath,
 AccessTokenProvider tokenProvider,
 GrpcVersionSupport grpcVersionSupport,
 ObjectsBatcher.BatchRetriesConfig batchRetriesConfig)

createAuto

public static ObjectsBatcher createAuto(HttpClient httpClient,
 Config config,
 Data data,
 ObjectsPath objectsPath,
 AccessTokenProvider tokenProvider,
 GrpcVersionSupport grpcVersionSupport,
 ObjectsBatcher.BatchRetriesConfig batchRetriesConfig,
 ObjectsBatcher.AutoBatchConfig autoBatchConfig)

withObject

public ObjectsBatcher withObject(WeaviateObject object)

withObjects

public ObjectsBatcher withObjects(WeaviateObject... objects)

withConsistencyLevel

public ObjectsBatcher withConsistencyLevel(String consistencyLevel)

run

public Result<ObjectGetResponse[]> run()

Specified by:

run in interface ClientResult<ObjectGetResponse[]>

flush

public void flush()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

resultFromBatchObjectsReply

public static Result<ObjectGetResponse[]> resultFromBatchObjectsReply(WeaviateProtoBatch.BatchObjectsReply reply,
 List<WeaviateObject> batch)