Skip to content

Commit 764e704

Browse files
author
Ajay Kannan
committed
---
yaml --- r: 2165 b: refs/heads/pubsub-alpha c: 461f375 h: refs/heads/master i: 2163: ca692fd
1 parent 3e0f40d commit 764e704

3 files changed

Lines changed: 38 additions & 44 deletions

File tree

‎[refs]‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ refs/heads/master: 689bbb466df4b2d5d2483d6edb8ac5c7c7f7c6fa
33
refs/heads/travis: e21ee7b88a5edc3f3d8c71f90c3fc32abf7e8dd6
44
refs/heads/gh-pages: 4e0561bb4504bf647db669a14417b2b2c87ba45d
55
refs/heads/bigquery: 762fa5830e6c398c0396177e3e7fd243bd62cfc3
6-
refs/heads/pubsub-alpha: e4113c47155b73d5be62e387a224ac43d1b6a43a
6+
refs/heads/pubsub-alpha: 461f37529d3f6efd8d183e611ebbbd086f453f1e
77
refs/heads/resource-manager: ebf4adc5ee835cd2086c4ac5b4e78d01a5a005a7
88
refs/heads/update-datastore: 482954f2c5055231e5b3122ea91d2ba00ce8187c
99
refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444

‎branches/pubsub-alpha/gcloud-java-datastore/src/main/java/com/google/gcloud/datastore/StructuredQuery.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -972,7 +972,7 @@ public Integer limit() {
972972
}
973973

974974
public Builder<V> toBuilder() {
975-
return new Builder<V>(this);
975+
return new Builder<>(this);
976976
}
977977

978978
@Override

‎branches/pubsub-alpha/gcloud-java-datastore/src/test/java/com/google/gcloud/datastore/DatastoreTest.java‎

Lines changed: 36 additions & 42 deletions
Original file line numberDiff line numberDiff line change
@@ -477,12 +477,11 @@ public void testQueryPaginationWithLimit() throws DatastoreRpcException {
477477
.andReturn(responses.get(i));
478478
}
479479
EasyMock.replay(rpcFactoryMock, rpcMock);
480-
Datastore mockDatastore =
481-
options.toBuilder()
482-
.retryParams(RetryParams.defaultInstance())
483-
.serviceRpcFactory(rpcFactoryMock)
484-
.build()
485-
.service();
480+
Datastore mockDatastore = options.toBuilder()
481+
.retryParams(RetryParams.defaultInstance())
482+
.serviceRpcFactory(rpcFactoryMock)
483+
.build()
484+
.service();
486485
int limit = 2;
487486
int totalCount = 0;
488487
StructuredQuery<Entity> query = Query.entityQueryBuilder().limit(limit).build();
@@ -511,45 +510,40 @@ private List<RunQueryResponse> buildResponsesForQueryPaginationWithLimit() {
511510
Query<Entity> query = Query.entityQueryBuilder().build();
512511
RunQueryRequest.Builder requestPb = RunQueryRequest.newBuilder();
513512
query.populatePb(requestPb);
514-
QueryResultBatch queryResultBatchPb =
515-
RunQueryResponse.newBuilder()
516-
.mergeFrom(((DatastoreImpl) datastore).runQuery(requestPb.build()))
517-
.getBatch();
518-
QueryResultBatch queryResultBatchPb1 =
519-
QueryResultBatch.newBuilder()
520-
.mergeFrom(queryResultBatchPb)
521-
.setMoreResults(QueryResultBatch.MoreResultsType.NOT_FINISHED)
522-
.clearEntityResult()
523-
.addAllEntityResult(queryResultBatchPb.getEntityResultList().subList(0, 1))
524-
.setEndCursor(queryResultBatchPb.getEntityResultList().get(0).getCursor())
525-
.build();
513+
QueryResultBatch queryResultBatchPb = RunQueryResponse.newBuilder()
514+
.mergeFrom(((DatastoreImpl) datastore).runQuery(requestPb.build()))
515+
.getBatch();
516+
QueryResultBatch queryResultBatchPb1 = QueryResultBatch.newBuilder()
517+
.mergeFrom(queryResultBatchPb)
518+
.setMoreResults(QueryResultBatch.MoreResultsType.NOT_FINISHED)
519+
.clearEntityResult()
520+
.addAllEntityResult(queryResultBatchPb.getEntityResultList().subList(0, 1))
521+
.setEndCursor(queryResultBatchPb.getEntityResultList().get(0).getCursor())
522+
.build();
526523
responses.add(RunQueryResponse.newBuilder().setBatch(queryResultBatchPb1).build());
527-
QueryResultBatch queryResultBatchPb2 =
528-
QueryResultBatch.newBuilder()
529-
.mergeFrom(queryResultBatchPb)
530-
.setMoreResults(QueryResultBatch.MoreResultsType.MORE_RESULTS_AFTER_LIMIT)
531-
.clearEntityResult()
532-
.addAllEntityResult(queryResultBatchPb.getEntityResultList().subList(1, 2))
533-
.setEndCursor(queryResultBatchPb.getEntityResultList().get(1).getCursor())
534-
.build();
524+
QueryResultBatch queryResultBatchPb2 = QueryResultBatch.newBuilder()
525+
.mergeFrom(queryResultBatchPb)
526+
.setMoreResults(QueryResultBatch.MoreResultsType.MORE_RESULTS_AFTER_LIMIT)
527+
.clearEntityResult()
528+
.addAllEntityResult(queryResultBatchPb.getEntityResultList().subList(1, 2))
529+
.setEndCursor(queryResultBatchPb.getEntityResultList().get(1).getCursor())
530+
.build();
535531
responses.add(RunQueryResponse.newBuilder().setBatch(queryResultBatchPb2).build());
536-
QueryResultBatch queryResultBatchPb3 =
537-
QueryResultBatch.newBuilder()
538-
.mergeFrom(queryResultBatchPb)
539-
.setMoreResults(QueryResultBatch.MoreResultsType.MORE_RESULTS_AFTER_LIMIT)
540-
.clearEntityResult()
541-
.addAllEntityResult(queryResultBatchPb.getEntityResultList().subList(2, 4))
542-
.setEndCursor(queryResultBatchPb.getEntityResultList().get(3).getCursor())
543-
.build();
532+
QueryResultBatch queryResultBatchPb3 = QueryResultBatch.newBuilder()
533+
.mergeFrom(queryResultBatchPb)
534+
.setMoreResults(QueryResultBatch.MoreResultsType.MORE_RESULTS_AFTER_LIMIT)
535+
.clearEntityResult()
536+
.addAllEntityResult(queryResultBatchPb.getEntityResultList().subList(2, 4))
537+
.setEndCursor(queryResultBatchPb.getEntityResultList().get(3).getCursor())
538+
.build();
544539
responses.add(RunQueryResponse.newBuilder().setBatch(queryResultBatchPb3).build());
545-
QueryResultBatch queryResultBatchPb4 =
546-
QueryResultBatch.newBuilder()
547-
.mergeFrom(queryResultBatchPb)
548-
.setMoreResults(QueryResultBatch.MoreResultsType.NO_MORE_RESULTS)
549-
.clearEntityResult()
550-
.addAllEntityResult(queryResultBatchPb.getEntityResultList().subList(4, 5))
551-
.setEndCursor(queryResultBatchPb.getEntityResultList().get(4).getCursor())
552-
.build();
540+
QueryResultBatch queryResultBatchPb4 = QueryResultBatch.newBuilder()
541+
.mergeFrom(queryResultBatchPb)
542+
.setMoreResults(QueryResultBatch.MoreResultsType.NO_MORE_RESULTS)
543+
.clearEntityResult()
544+
.addAllEntityResult(queryResultBatchPb.getEntityResultList().subList(4, 5))
545+
.setEndCursor(queryResultBatchPb.getEntityResultList().get(4).getCursor())
546+
.build();
553547
responses.add(RunQueryResponse.newBuilder().setBatch(queryResultBatchPb4).build());
554548
return responses;
555549
}

0 commit comments

Comments
 (0)