test: order-by in scroll (#42)

Co-authored-by: Anush <[email protected]>

Author: generall

.idea/gradle.xml

@@ -1,8 +1,8 @@
 # The version of qdrant to use to download protos
-qdrantProtosVersion=v1.9.2
+qdrantProtosVersion=v1.9.5
 
 # The version of qdrant docker image to run integration tests against
-qdrantVersion=v1.9.2
+qdrantVersion=v1.9.5
 
 # The version of the client to generate
 packageVersion=1.9.1

.idea/misc.xml

@@ -15,6 +15,8 @@
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeUnit;
 
+import io.qdrant.client.grpc.Collections;
+import io.qdrant.client.grpc.Points;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
@@ -381,6 +383,44 @@ public void scroll() throws ExecutionException, InterruptedException {
 		assertFalse(scrollResponse.hasNextPageOffset());
 	}
 
+	@Test
+	public void scrollWithOrdering() throws ExecutionException, InterruptedException {
+		createAndSeedCollection(testName);
+
+		Collections.PayloadIndexParams params = Collections.PayloadIndexParams.newBuilder()
+			.setIntegerIndexParams(
+				Collections.IntegerIndexParams.newBuilder().setLookup(false).setRange(true).build())
+			.build();
+
+		UpdateResult resultIndex = client.createPayloadIndexAsync(
+			testName,
+			"bar",
+			PayloadSchemaType.Integer,
+			params,
+			true,
+			null,
+			null).get();
+
+		assertEquals(UpdateStatus.Completed, resultIndex.getStatus());
+
+		CollectionInfo collectionInfo = client.getCollectionInfoAsync(testName).get();
+		assertEquals(ImmutableSet.of("bar"), collectionInfo.getPayloadSchemaMap().keySet());
+
+		ScrollResponse scrollResponse = client.scrollAsync(ScrollPoints.newBuilder()
+			.setCollectionName(testName)
+			.setLimit(1)
+			.setOrderBy(Points.OrderBy.newBuilder()
+				.setDirection(Points.Direction.Desc)
+				.setKey("bar").build())
+			.build()
+		).get();
+
+		
+		assertEquals(1, scrollResponse.getResultCount());
+		assertFalse(scrollResponse.hasNextPageOffset());
+		assertEquals(scrollResponse.getResult(0).getId(), id(9));
+	}
+
 	@Test
 	public void recommend() throws ExecutionException, InterruptedException {
 		createAndSeedCollection(testName);
@@ -458,10 +498,10 @@ public void discover() throws ExecutionException, InterruptedException {
 		createAndSeedCollection(testName);
 
 		List<ScoredPoint> points = client.discoverAsync(DiscoverPoints.newBuilder()
-				.setCollectionName(testName)
-				.setTarget(targetVector(vector(ImmutableList.of(10.4f, 11.4f))))
-				.setLimit(1)
-				.build()).get();
+			.setCollectionName(testName)
+			.setTarget(targetVector(vector(ImmutableList.of(10.4f, 11.4f))))
+			.setLimit(1)
+			.build()).get();
 
 		assertEquals(1, points.size());
 		assertEquals(id(9), points.get(0).getId());
@@ -472,19 +512,19 @@ public void discoverBatch() throws ExecutionException, InterruptedException {
 		createAndSeedCollection(testName);
 
 		List<BatchResult> batchResults = client.discoverBatchAsync(
-				testName,
-				ImmutableList.of(
-						DiscoverPoints.newBuilder()
-								.setCollectionName(testName)
-								.setTarget(targetVector(vector(ImmutableList.of(10.4f, 11.4f))))
-								.setLimit(1)
-								.build(),
-						DiscoverPoints.newBuilder()
-								.setCollectionName(testName)
-								.setTarget(targetVector(vector(ImmutableList.of(3.5f, 4.5f))))
-								.setLimit(1)
-								.build()),
-				null).get();
+			testName,
+			ImmutableList.of(
+				DiscoverPoints.newBuilder()
+					.setCollectionName(testName)
+					.setTarget(targetVector(vector(ImmutableList.of(10.4f, 11.4f))))
+					.setLimit(1)
+					.build(),
+				DiscoverPoints.newBuilder()
+					.setCollectionName(testName)
+					.setTarget(targetVector(vector(ImmutableList.of(3.5f, 4.5f))))
+					.setLimit(1)
+					.build()),
+			null).get();
 
 		assertEquals(2, batchResults.size());
 		BatchResult result = batchResults.get(0);
@@ -573,17 +613,17 @@ public void batchPointUpdate() throws ExecutionException, InterruptedException {
 		createAndSeedCollection(testName);
 
 		List<PointsUpdateOperation> operations = List.of(
-				PointsUpdateOperation.newBuilder()
-						.setClearPayload(ClearPayload.newBuilder().setPoints(
-								PointsSelector.newBuilder().setPoints(PointsIdsList.newBuilder().addIds(id(9))))
-								.build())
-						.build(),
-				PointsUpdateOperation.newBuilder()
-						.setUpdateVectors(UpdateVectors.newBuilder()
-								.addPoints(PointVectors.newBuilder()
-										.setId(id(9))
-										.setVectors(vectors(0.6f, 0.7f))))
-						.build());
+			PointsUpdateOperation.newBuilder()
+				.setClearPayload(ClearPayload.newBuilder().setPoints(
+						PointsSelector.newBuilder().setPoints(PointsIdsList.newBuilder().addIds(id(9))))
+					.build())
+				.build(),
+			PointsUpdateOperation.newBuilder()
+				.setUpdateVectors(UpdateVectors.newBuilder()
+					.addPoints(PointVectors.newBuilder()
+						.setId(id(9))
+						.setVectors(vectors(0.6f, 0.7f))))
+				.build());
 
 		List<UpdateResult> response = client.batchUpdateAsync(testName, operations).get();