Skip to content

Commit a111a44

Browse files
authored
Merge pull request #10 from datastax/1.x
1.x
2 parents 3f29702 + c71c3e9 commit a111a44

File tree

8 files changed

+25
-9
lines changed

8 files changed

+25
-9
lines changed

astra-db-java/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
<parent>
99
<groupId>com.datastax.astra</groupId>
1010
<artifactId>astra-db-java-parent</artifactId>
11-
<version>1.5.1-SNAPSHOT</version>
11+
<version>1.5.3-SNAPSHOT</version>
1212
</parent>
1313

1414
<properties>

astra-db-java/src/main/java/com/datastax/astra/client/DataAPIClients.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,7 @@ public static DataAPIClient createForLocal() {
7878
new UsernamePasswordTokenProvider().getToken(),
7979
DataAPIOptions.builder()
8080
.withDestination(DataAPIOptions.DataAPIDestination.CASSANDRA)
81+
.logRequests()
8182
.withObserver(new LoggingCommandObserver(DataAPIClient.class))
8283
.build());
8384
}

astra-db-java/src/main/java/com/datastax/astra/internal/command/AbstractCommandRunner.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -158,7 +158,7 @@ public ApiResponse runCommand(Command command, CommandOptions<?> overridingOptio
158158
throw new DataApiResponseException(Collections.singletonList(executionInfo.build()));
159159
}
160160
// Trace All Warning
161-
if (jsonRes.getStatus().containsKey("warnings")) {
161+
if (jsonRes.getStatus()!= null && jsonRes.getStatus().containsKey("warnings")) {
162162
jsonRes.getStatusKeyAsStringStream("warnings").forEach(log::warn);
163163
}
164164
return jsonRes;

examples/pom.xml

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,19 +3,20 @@
33

44
<modelVersion>4.0.0</modelVersion>
55
<artifactId>astra-db-java-examples</artifactId>
6+
<version>1.5.0</version>
67
<name>Data API Client Samples</name>
78

89
<parent>
910
<groupId>com.datastax.astra</groupId>
1011
<artifactId>astra-db-java-parent</artifactId>
11-
<version>1.5.0</version>
12+
<version>1.5.3-SNAPSHOT</version>
1213
</parent>
1314

1415
<dependencies>
1516
<dependency>
1617
<groupId>com.datastax.astra</groupId>
1718
<artifactId>astra-db-java</artifactId>
18-
<version>${project.version}</version>
19+
<version>1.5.3-SNAPSHOT</version>
1920
</dependency>
2021
<dependency>
2122
<groupId>ch.qos.logback</groupId>

langchain4j-astradb/pom.xml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,11 +8,11 @@
88
<parent>
99
<groupId>com.datastax.astra</groupId>
1010
<artifactId>astra-db-java-parent</artifactId>
11-
<version>1.5.1-SNAPSHOT</version>
11+
<version>1.5.3-SNAPSHOT</version>
1212
</parent>
1313

1414
<properties>
15-
<langchain4j.version>0.34.0</langchain4j.version>
15+
<langchain4j.version>0.35.0</langchain4j.version>
1616
</properties>
1717

1818
<dependencyManagement>

langchain4j-astradb/src/main/java/com/datastax/astra/langchain4j/store/embedding/AstraDbEmbeddingStore.java

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@
3232
import dev.langchain4j.data.embedding.Embedding;
3333
import dev.langchain4j.data.segment.TextSegment;
3434
import dev.langchain4j.store.embedding.EmbeddingMatch;
35+
import dev.langchain4j.store.embedding.EmbeddingSearchRequest;
3536
import dev.langchain4j.store.embedding.EmbeddingSearchResult;
3637
import dev.langchain4j.store.embedding.EmbeddingStore;
3738
import lombok.Getter;
@@ -215,6 +216,18 @@ public List<EmbeddingMatch<TextSegment>> findRelevant(Embedding referenceEmbeddi
215216
return findRelevant(referenceEmbedding, (Filter) null, maxResults, minScore);
216217
}
217218

219+
public EmbeddingSearchResult<TextSegment> search(EmbeddingSearchRequest request) {
220+
dev.langchain4j.store.embedding.filter.Filter lc4jFilter = request.filter();
221+
if (lc4jFilter != null) {
222+
// Map Filter
223+
Filter astraFilter = AstraDbFilterMapper.map(lc4jFilter);
224+
List<EmbeddingMatch<TextSegment>> matches = this.findRelevant(request.queryEmbedding(), astraFilter, request.maxResults(), request.minScore());
225+
return new EmbeddingSearchResult(matches);
226+
}
227+
List<EmbeddingMatch<TextSegment>> matches2 = this.findRelevant(request.queryEmbedding(), request.maxResults(), request.minScore());
228+
return new EmbeddingSearchResult(matches2);
229+
}
230+
218231
/**
219232
* Implementation of the Search to add the metadata Filtering.
220233
*

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
<groupId>com.datastax.astra</groupId>
55
<artifactId>astra-db-java-parent</artifactId>
66
<name>Data API Client</name>
7-
<version>1.5.1-SNAPSHOT</version>
7+
<version>1.5.3-SNAPSHOT</version>
88
<packaging>pom</packaging>
99
<url>https://github.com/datastax/astra-db-java</url>
1010
<inceptionYear>2024</inceptionYear>

tools/pom.xml

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,19 +3,20 @@
33

44
<modelVersion>4.0.0</modelVersion>
55
<artifactId>astra-db-java-tools</artifactId>
6+
<version>1.5.0</version>
67
<name>Data API Client Tools</name>
78

89
<parent>
910
<groupId>com.datastax.astra</groupId>
1011
<artifactId>astra-db-java-parent</artifactId>
11-
<version>1.5.0</version>
12+
<version>1.5.3-SNAPSHOT</version>
1213
</parent>
1314

1415
<dependencies>
1516
<dependency>
1617
<groupId>com.datastax.astra</groupId>
1718
<artifactId>astra-db-java</artifactId>
18-
<version>${project.version}</version>
19+
<version>1.5.3-SNAPSHOT</version>
1920
</dependency>
2021
<dependency>
2122
<groupId>ch.qos.logback</groupId>

0 commit comments

Comments
 (0)