|
6 | 6 | import static java.util.Objects.isNull; |
7 | 7 | import static java.util.stream.Collectors.joining; |
8 | 8 | import static java.util.stream.Collectors.toUnmodifiableList; |
| 9 | +import static org.hypertrace.core.documentstore.expression.operators.RelationalOperator.EQ; |
9 | 10 | import static org.hypertrace.core.documentstore.expression.operators.RelationalOperator.IN; |
10 | 11 | import static org.hypertrace.core.documentstore.model.options.ReturnDocumentType.NONE; |
11 | 12 | import static org.hypertrace.entity.data.service.v1.AttributeValue.VALUE_LIST_FIELD_NUMBER; |
@@ -343,7 +344,10 @@ public void update(EntityUpdateRequest request, StreamObserver<ResultSetChunk> r |
343 | 344 | // Finally, return the selections |
344 | 345 | List<Document> documents = |
345 | 346 | getProjectedDocuments( |
346 | | - request.getEntityIdsList(), request.getSelectionList(), requestContext); |
| 347 | + maybeTenantId.get(), |
| 348 | + request.getEntityIdsList(), |
| 349 | + request.getSelectionList(), |
| 350 | + requestContext); |
347 | 351 |
|
348 | 352 | responseObserver.onNext( |
349 | 353 | convertDocumentsToResultSetChunk(documents, request.getSelectionList())); |
@@ -532,6 +536,7 @@ private JSONDocument convertToJsonDocument(LiteralConstant literalConstant) { |
532 | 536 | } |
533 | 537 |
|
534 | 538 | private List<Document> getProjectedDocuments( |
| 539 | + final String tenantId, |
535 | 540 | final Iterable<String> entityIds, |
536 | 541 | final List<Expression> selectionList, |
537 | 542 | final RequestContext requestContext) |
|
0 commit comments