public class dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore extends java.lang.Object implements dev.langchain4j.store.embedding.EmbeddingStore
{
private static final java.lang.String METADATA_TEXT_SEGMENT;
private static final java.lang.String ADDITIONALS;
private final io.weaviate.client.WeaviateClient client;
private final java.lang.String objectClass;
private final boolean avoidDups;
private final java.lang.String consistencyLevel;
public void <init>(java.lang.String, java.lang.String, java.lang.String, java.lang.Integer, java.lang.String, java.lang.Boolean, java.lang.String)
{
java.lang.Throwable v;
java.lang.Integer v;
java.lang.Boolean v, v;
dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore v;
io.weaviate.client.Config v;
java.lang.String v, v, v, v, v, v, v, v;
boolean v;
io.weaviate.client.WeaviateClient v;
java.lang.IllegalArgumentException v;
java.lang.Object v, v, v, v;
v := @this: dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Integer;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Boolean;
v := @parameter: java.lang.String;
specialinvoke v.<java.lang.Object: void <init>()>();
label:
v = new io.weaviate.client.Config;
v = staticinvoke <dev.langchain4j.internal.ValidationUtils: java.lang.String ensureNotBlank(java.lang.String,java.lang.String)>(v, "scheme");
v = staticinvoke <dev.langchain4j.internal.ValidationUtils: java.lang.String ensureNotBlank(java.lang.String,java.lang.String)>(v, "host");
v = staticinvoke <dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore: java.lang.String concatenate(java.lang.String,java.lang.Integer)>(v, v);
specialinvoke v.<io.weaviate.client.Config: void <init>(java.lang.String,java.lang.String)>(v, v);
v = staticinvoke <dev.langchain4j.internal.Utils: java.lang.Object getOrDefault(java.lang.Object,java.lang.Object)>(v, "");
v = staticinvoke <io.weaviate.client.WeaviateAuthClient: io.weaviate.client.WeaviateClient apiKey(io.weaviate.client.Config,java.lang.String)>(v, v);
v.<dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore: io.weaviate.client.WeaviateClient client> = v;
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = staticinvoke <dev.langchain4j.internal.Utils: java.lang.Object getOrDefault(java.lang.Object,java.lang.Object)>(v, "Default");
v.<dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore: java.lang.String objectClass> = v;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
v = staticinvoke <dev.langchain4j.internal.Utils: java.lang.Object getOrDefault(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v.<dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore: boolean avoidDups> = v;
v = staticinvoke <dev.langchain4j.internal.Utils: java.lang.Object getOrDefault(java.lang.Object,java.lang.Object)>(v, "QUORUM");
v.<dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore: java.lang.String consistencyLevel> = v;
return;
catch io.weaviate.client.v.auth.exception.AuthException from label to label with label;
}
private static java.lang.String concatenate(java.lang.String, java.lang.Integer)
{
java.lang.String v, v;
java.lang.Integer v;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Integer;
if v != null goto label;
return v;
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.Integer)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001:\u0001");
return v;
}
public java.lang.String add(dev.langchain4j.data.embedding.Embedding)
{
dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore v;
java.lang.String v;
dev.langchain4j.data.embedding.Embedding v;
v := @this: dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore;
v := @parameter: dev.langchain4j.data.embedding.Embedding;
v = staticinvoke <dev.langchain4j.internal.Utils: java.lang.String randomUUID()>();
virtualinvoke v.<dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore: void add(java.lang.String,dev.langchain4j.data.embedding.Embedding)>(v, v);
return v;
}
public void add(java.lang.String, dev.langchain4j.data.embedding.Embedding)
{
java.util.List v, v;
dev.langchain4j.data.embedding.Embedding v;
dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore v;
java.lang.String v;
v := @this: dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore;
v := @parameter: java.lang.String;
v := @parameter: dev.langchain4j.data.embedding.Embedding;
v = staticinvoke <java.util.Collections: java.util.List singletonList(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.List singletonList(java.lang.Object)>(v);
specialinvoke v.<dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore: java.util.List addAll(java.util.List,java.util.List,java.util.List)>(v, v, null);
return;
}
public java.lang.String add(dev.langchain4j.data.embedding.Embedding, dev.langchain4j.data.segment.TextSegment)
{
dev.langchain4j.data.embedding.Embedding v;
dev.langchain4j.data.segment.TextSegment v;
java.util.List v, v, v;
java.util.stream.Stream v;
java.util.Optional v;
dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore v;
java.lang.Object v;
v := @this: dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore;
v := @parameter: dev.langchain4j.data.embedding.Embedding;
v := @parameter: dev.langchain4j.data.segment.TextSegment;
v = staticinvoke <java.util.Collections: java.util.List singletonList(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.List singletonList(java.lang.Object)>(v);
v = virtualinvoke v.<dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore: java.util.List addAll(java.util.List,java.util.List)>(v, v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.Optional findFirst()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object orElse(java.lang.Object)>(null);
return v;
}
public java.util.List addAll(java.util.List)
{
dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore v;
java.util.List v, v;
v := @this: dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore;
v := @parameter: java.util.List;
v = virtualinvoke v.<dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore: java.util.List addAll(java.util.List,java.util.List)>(v, null);
return v;
}
public java.util.List addAll(java.util.List, java.util.List)
{
java.util.List v, v, v;
dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore v;
v := @this: dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
v = specialinvoke v.<dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore: java.util.List addAll(java.util.List,java.util.List,java.util.List)>(null, v, v);
return v;
}
public java.util.List findRelevant(dev.langchain4j.data.embedding.Embedding, int, double)
{
java.lang.Float v;
java.lang.Integer v;
java.util.stream.Collector v, v, v;
io.weaviate.client.v.graphql.query.Get v, v, v, v, v;
java.util.Set v, v;
java.util.stream.Stream v, v, v, v, v, v, v, v;
java.lang.Object[] v;
io.weaviate.client.v.graphql.query.fields.Field v, v, v, v, v;
java.lang.String v;
io.weaviate.client.base.Result v;
io.weaviate.client.v.graphql.query.argument.NearVectorArgument$NearVectorArgumentBuilder v, v, v;
java.lang.Float[] v;
boolean v, v, v;
io.weaviate.client.v.graphql.GraphQL v;
java.util.List v, v, v, v;
io.weaviate.client.v.graphql.query.argument.NearVectorArgument v;
java.util.Optional v, v;
io.weaviate.client.base.WeaviateError v;
io.weaviate.client.v.graphql.model.GraphQLError[] v;
java.util.function.Function v, v, v;
int v, v;
dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore v;
double v;
io.weaviate.client.WeaviateClient v;
io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder v, v, v, v, v, v, v, v, v, v, v;
dev.langchain4j.data.embedding.Embedding v;
java.lang.IllegalArgumentException v, v;
io.weaviate.client.v.graphql.query.fields.Field[] v, v;
java.lang.Object v, v, v, v, v, v, v, v, v, v;
v := @this: dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore;
v := @parameter: dev.langchain4j.data.embedding.Embedding;
v := @parameter: int;
v := @parameter: double;
v = v.<dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore: io.weaviate.client.WeaviateClient client>;
v = virtualinvoke v.<io.weaviate.client.WeaviateClient: io.weaviate.client.v.graphql.GraphQL graphQL()>();
v = virtualinvoke v.<io.weaviate.client.v.graphql.GraphQL: io.weaviate.client.v.graphql.query.Get get()>();
v = v.<dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore: java.lang.String objectClass>;
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.Get: io.weaviate.client.v.graphql.query.Get withClassName(java.lang.String)>(v);
v = newarray (io.weaviate.client.v.graphql.query.fields.Field)[2];
v = staticinvoke <io.weaviate.client.v.graphql.query.fields.Field: io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder builder()>();
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder: io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder name(java.lang.String)>("text");
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder: io.weaviate.client.v.graphql.query.fields.Field build()>();
v[0] = v;
v = staticinvoke <io.weaviate.client.v.graphql.query.fields.Field: io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder builder()>();
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder: io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder name(java.lang.String)>("_additional");
v = newarray (io.weaviate.client.v.graphql.query.fields.Field)[3];
v = staticinvoke <io.weaviate.client.v.graphql.query.fields.Field: io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder builder()>();
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder: io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder name(java.lang.String)>("id");
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder: io.weaviate.client.v.graphql.query.fields.Field build()>();
v[0] = v;
v = staticinvoke <io.weaviate.client.v.graphql.query.fields.Field: io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder builder()>();
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder: io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder name(java.lang.String)>("certainty");
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder: io.weaviate.client.v.graphql.query.fields.Field build()>();
v[1] = v;
v = staticinvoke <io.weaviate.client.v.graphql.query.fields.Field: io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder builder()>();
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder: io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder name(java.lang.String)>("vector");
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder: io.weaviate.client.v.graphql.query.fields.Field build()>();
v[2] = v;
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder: io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder fields(io.weaviate.client.v.graphql.query.fields.Field[])>(v);
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.fields.Field$FieldBuilder: io.weaviate.client.v.graphql.query.fields.Field build()>();
v[1] = v;
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.Get: io.weaviate.client.v.graphql.query.Get withFields(io.weaviate.client.v.graphql.query.fields.Field[])>(v);
v = staticinvoke <io.weaviate.client.v.graphql.query.argument.NearVectorArgument: io.weaviate.client.v.graphql.query.argument.NearVectorArgument$NearVectorArgumentBuilder builder()>();
v = virtualinvoke v.<dev.langchain4j.data.embedding.Embedding: java.util.List vectorAsList()>();
v = newarray (java.lang.Float)[0];
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray(java.lang.Object[])>(v);
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.argument.NearVectorArgument$NearVectorArgumentBuilder: io.weaviate.client.v.graphql.query.argument.NearVectorArgument$NearVectorArgumentBuilder vector(java.lang.Float[])>(v);
v = staticinvoke <java.lang.Float: java.lang.Float valueOf(float)>(v);
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.argument.NearVectorArgument$NearVectorArgumentBuilder: io.weaviate.client.v.graphql.query.argument.NearVectorArgument$NearVectorArgumentBuilder certainty(java.lang.Float)>(v);
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.argument.NearVectorArgument$NearVectorArgumentBuilder: io.weaviate.client.v.graphql.query.argument.NearVectorArgument build()>();
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.Get: io.weaviate.client.v.graphql.query.Get withNearVector(io.weaviate.client.v.graphql.query.argument.NearVectorArgument)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.Get: io.weaviate.client.v.graphql.query.Get withLimit(java.lang.Integer)>(v);
v = virtualinvoke v.<io.weaviate.client.v.graphql.query.Get: io.weaviate.client.base.Result run()>();
v = virtualinvoke v.<io.weaviate.client.base.Result: boolean hasErrors()>();
if v == 0 goto label;
v = new java.lang.IllegalArgumentException;
v = virtualinvoke v.<io.weaviate.client.base.Result: io.weaviate.client.base.WeaviateError getError()>();
v = virtualinvoke v.<io.weaviate.client.base.WeaviateError: java.util.List getMessages()>();
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore$getMessage__3: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector joining(java.lang.CharSequence)>("\n");
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<io.weaviate.client.base.Result: java.lang.Object getResult()>();
v = virtualinvoke v.<io.weaviate.client.v.graphql.model.GraphQLResponse: io.weaviate.client.v.graphql.model.GraphQLError[] getErrors()>();
if v == null goto label;
v = lengthof v;
if v <= 0 goto label;
v = new java.lang.IllegalArgumentException;
v = staticinvoke <java.util.Arrays: java.util.stream.Stream stream(java.lang.Object[])>(v);
v = staticinvoke <dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore$getMessage__2: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector joining(java.lang.CharSequence)>("\n");
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<io.weaviate.client.base.Result: java.lang.Object getResult()>();
v = virtualinvoke v.<io.weaviate.client.v.graphql.model.GraphQLResponse: java.lang.Object getData()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.stream.Stream stream()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.Optional findFirst()>();
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v != 0 goto label;
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
return v;
label:
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.stream.Stream stream()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.Optional findFirst()>();
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v != 0 goto label;
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
return v;
label:
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore$toEmbeddingMatch__1: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
return v;
}
private java.util.List addAll(java.util.List, java.util.List, java.util.List)
{
java.lang.Object[] v;
java.util.ArrayList v, v;
io.weaviate.client.v.batch.api.ObjectsBatcher v, v, v;
int v, v, v, v;
dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore v;
java.lang.String v, v, v, v;
boolean v;
io.weaviate.client.v.batch.Batch v;
io.weaviate.client.WeaviateClient v;
java.lang.IllegalArgumentException v;
io.weaviate.client.v.data.model.WeaviateObject[] v;
java.util.List v, v, v;
java.lang.Object v, v, v, v;
io.weaviate.client.v.data.model.WeaviateObject v;
v := @this: dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
if v == null goto label;
v = interfaceinvoke v.<java.util.List: int size()>();
v = interfaceinvoke v.<java.util.List: int size()>();
if v == v goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("The list of embeddings and embedded must have the same size");
throw v;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = 0;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
if v >= v goto label;
if v == null goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
goto label;
label:
v = v.<dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore: boolean avoidDups>;
if v == 0 goto label;
if v == null goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = virtualinvoke v.<dev.langchain4j.data.segment.TextSegment: java.lang.String text()>();
v = staticinvoke <dev.langchain4j.internal.Utils: java.lang.String generateUUIDFrom(java.lang.String)>(v);
goto label;
label:
v = staticinvoke <dev.langchain4j.internal.Utils: java.lang.String randomUUID()>();
label:
v = v;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
if v == null goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = virtualinvoke v.<dev.langchain4j.data.segment.TextSegment: java.lang.String text()>();
goto label;
label:
v = "";
label:
v = specialinvoke v.<dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore: io.weaviate.client.v.data.model.WeaviateObject buildObject(java.lang.String,dev.langchain4j.data.embedding.Embedding,java.lang.String)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = v.<dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore: io.weaviate.client.WeaviateClient client>;
v = virtualinvoke v.<io.weaviate.client.WeaviateClient: io.weaviate.client.v.batch.Batch batch()>();
v = virtualinvoke v.<io.weaviate.client.v.batch.Batch: io.weaviate.client.v.batch.api.ObjectsBatcher objectsBatcher()>();
v = newarray (io.weaviate.client.v.data.model.WeaviateObject)[0];
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray(java.lang.Object[])>(v);
v = virtualinvoke v.<io.weaviate.client.v.batch.api.ObjectsBatcher: io.weaviate.client.v.batch.api.ObjectsBatcher withObjects(io.weaviate.client.v.data.model.WeaviateObject[])>(v);
v = v.<dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore: java.lang.String consistencyLevel>;
v = virtualinvoke v.<io.weaviate.client.v.batch.api.ObjectsBatcher: io.weaviate.client.v.batch.api.ObjectsBatcher withConsistencyLevel(java.lang.String)>(v);
virtualinvoke v.<io.weaviate.client.v.batch.api.ObjectsBatcher: io.weaviate.client.base.Result run()>();
return v;
}
private io.weaviate.client.v.data.model.WeaviateObject buildObject(java.lang.String, dev.langchain4j.data.embedding.Embedding, java.lang.String)
{
java.lang.Object[] v;
io.weaviate.client.v.data.model.WeaviateObject$WeaviateObjectBuilder v, v, v, v, v;
dev.langchain4j.data.embedding.Embedding v;
java.util.HashMap v;
java.util.List v;
dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore v;
java.lang.String v, v, v;
io.weaviate.client.v.data.model.WeaviateObject v;
java.lang.Float[] v;
v := @this: dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore;
v := @parameter: java.lang.String;
v := @parameter: dev.langchain4j.data.embedding.Embedding;
v := @parameter: java.lang.String;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("text", v);
v = staticinvoke <io.weaviate.client.v.data.model.WeaviateObject: io.weaviate.client.v.data.model.WeaviateObject$WeaviateObjectBuilder builder()>();
v = v.<dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore: java.lang.String objectClass>;
v = virtualinvoke v.<io.weaviate.client.v.data.model.WeaviateObject$WeaviateObjectBuilder: io.weaviate.client.v.data.model.WeaviateObject$WeaviateObjectBuilder className(java.lang.String)>(v);
v = virtualinvoke v.<io.weaviate.client.v.data.model.WeaviateObject$WeaviateObjectBuilder: io.weaviate.client.v.data.model.WeaviateObject$WeaviateObjectBuilder id(java.lang.String)>(v);
v = virtualinvoke v.<dev.langchain4j.data.embedding.Embedding: java.util.List vectorAsList()>();
v = newarray (java.lang.Float)[0];
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray(java.lang.Object[])>(v);
v = virtualinvoke v.<io.weaviate.client.v.data.model.WeaviateObject$WeaviateObjectBuilder: io.weaviate.client.v.data.model.WeaviateObject$WeaviateObjectBuilder vector(java.lang.Float[])>(v);
v = virtualinvoke v.<io.weaviate.client.v.data.model.WeaviateObject$WeaviateObjectBuilder: io.weaviate.client.v.data.model.WeaviateObject$WeaviateObjectBuilder properties(java.util.Map)>(v);
v = virtualinvoke v.<io.weaviate.client.v.data.model.WeaviateObject$WeaviateObjectBuilder: io.weaviate.client.v.data.model.WeaviateObject build()>();
return v;
}
public static dev.langchain4j.store.embedding.EmbeddingMatch toEmbeddingMatch(java.util.Map)
{
dev.langchain4j.data.embedding.Embedding v;
dev.langchain4j.store.embedding.EmbeddingMatch v;
dev.langchain4j.data.segment.TextSegment v;
java.util.function.Function v;
java.util.stream.Stream v, v;
java.util.Map v;
java.lang.Object v, v, v, v, v, v;
java.util.stream.Collector v;
boolean v;
v := @parameter: java.util.Map;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("_additional");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("text");
v = new dev.langchain4j.store.embedding.EmbeddingMatch;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("certainty");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("id");
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("vector");
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore$floatValue__4: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v = staticinvoke <dev.langchain4j.data.embedding.Embedding: dev.langchain4j.data.embedding.Embedding 'from'(java.util.List)>(v);
v = staticinvoke <dev.langchain4j.internal.Utils: boolean isNullOrBlank(java.lang.String)>(v);
if v == 0 goto label;
v = null;
goto label;
label:
v = staticinvoke <dev.langchain4j.data.segment.TextSegment: dev.langchain4j.data.segment.TextSegment 'from'(java.lang.String)>(v);
label:
specialinvoke v.<dev.langchain4j.store.embedding.EmbeddingMatch: void <init>(java.lang.Double,java.lang.String,dev.langchain4j.data.embedding.Embedding,java.lang.Object)>(v, v, v, v);
return v;
}
public static dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore$WeaviateEmbeddingStoreBuilder builder()
{
dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore$WeaviateEmbeddingStoreBuilder v;
v = new dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore$WeaviateEmbeddingStoreBuilder;
specialinvoke v.<dev.langchain4j.store.embedding.weaviate.WeaviateEmbeddingStore$WeaviateEmbeddingStoreBuilder: void <init>()>();
return v;
}
}