krzysztof/landing_page
1
0
Fork 0
mirror of https://github.com/qdrant/landing_page.git synced 2026-10-04 10:28:29 +02:00
Code Issues Packages Projects Releases Wiki Activity

docs: Go, Java, C# snippets

Browse Source 
Signed-off-by: Anush008 <anushshetty90@gmail.com>
This commit is contained in:
Anush008
2025-11-17 12:45:26 +05:30
parent 31c7db602b
commit 2d2cb57abe
4 changed files with 47 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files
qdrant-landing/content/documentation/headless/snippets/insert-points/with-tenant-group-id-and-fallback-shard-key/java.md
+9 -12
View File
@@ -2,21 +2,17 @@
import java.util.List;
import java.util.Map;
import static io.qdrant.client.ShardKeyFactory.shardKey;
import io.qdrant.client.QdrantClient;
import io.qdrant.client.QdrantGrpcClient;
import io.qdrant.client.grpc.Points.PointStruct;
import io.qdrant.client.ShardKeyFactory.shardKey;
import io.qdrant.client.grpc.Points.ShardKeySelector;
QdrantClient client =
new QdrantClient(QdrantGrpcClient.newBuilder("localhost", 6334, false).build());
ShardKeySelector.Builder shardkeySelectorBuilder = ShardKeySelector.newBuilder();
shardkeySelectorBuilder.addShardKeys(shardKey("user_1"));
shardkeySelectorBuilder.setFallback(shardKey("default"));
ShardKeySelector shardKeySelector = shardkeySelectorBuilder.build();
client
.upsertAsync(
UpsertPoints.newBuilder()
@@ -27,11 +23,12 @@ client
.setId(id(1))
.setVectors(vectors(0.9f, 0.1f, 0.1f))
.putAllPayload(Map.of("group_id", value("user_1")))
.build()
)
)
.setShardKeySelector(shardKeySelector)
.build()
)
.build()))
.setShardKeySelector(
ShardKeySelector.newBuilder()
.addShardKeys(shardKey("user_1"))
.setFallback(shardKey("default"))
.build())
.build())
.get();
```
qdrant-landing/content/documentation/headless/snippets/shard-transfer/with-filter/csharp.md
+10 -3
View File
@@ -5,7 +5,14 @@ using static Qdrant.Client.Grpc.Conditions;
var client = new QdrantClient("localhost", 6334);
TODO!
await client.UpdateCollectionClusterSetupAsync(new()
{
CollectionName = "{collection_name}",
ReplicatePoints = new()
{
FromShardKey = "default",
ToShardKey = "user_1",
Filter = MatchKeyword("group_id", "user_1")
}
});
```
qdrant-landing/content/documentation/headless/snippets/shard-transfer/with-filter/go.md
+11 -1
View File
@@ -10,5 +10,15 @@ client, err := qdrant.NewClient(&qdrant.Config{
Port: 6334,
})
TODO!
client.UpdateClusterCollectionSetup(ctx, qdrant.NewUpdateCollectionClusterReplicatePoints(
"{collection_name}", &qdrant.ReplicatePoints{
FromShardKey: qdrant.NewShardKey("default"),
ToShardKey: qdrant.NewShardKey("user_1"),
Filter: &qdrant.Filter{
Must: []*qdrant.Condition{
qdrant.NewMatch("group_id", "user_1"),
},
},
},
))
```
qdrant-landing/content/documentation/headless/snippets/shard-transfer/with-filter/java.md
+17 -8
View File
@@ -1,20 +1,29 @@
```java
import java.util.List;
import static io.qdrant.client.ConditionFactory.matchKeyword;
import static io.qdrant.client.QueryFactory.nearest;
import static io.qdrant.client.ShardKeyFactory.shardKey;
import io.qdrant.client.grpc.Collections.ReplicatePoints;
import io.qdrant.client.grpc.Collections.UpdateCollectionClusterSetupRequest;
import io.qdrant.client.grpc.Points.Filter;
import io.qdrant.client.QdrantClient;
import io.qdrant.client.QdrantGrpcClient;
import io.qdrant.client.grpc.Points.Filter;
QdrantClient client =
new QdrantClient(QdrantGrpcClient.newBuilder("localhost", 6334, false).build());
// .setFilter(Filter.newBuilder().addMust(matchKeyword("group_id", "user_1")).build())
TODO!
client
.updateCollectionClusterSetupAsync(
UpdateCollectionClusterSetupRequest.newBuilder()
.setCollectionName("{collection_name}")
.setReplicatePoints(
ReplicatePoints.newBuilder()
.setFromShardKey(shardKey("default"))
.setToShardKey(shardKey("user_1"))
.setFilter(
Filter.newBuilder().addMust(matchKeyword("group_id", "user_1")).build())
.build())
.build())
.get();
```