Skip to content
This repository was archived by the owner on Jun 26, 2024. It is now read-only.
Open
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -493,6 +493,10 @@ public static Filter addTimeSpaceAndIdFiltersAndConvertToQueryFilter(
List<String> entityIdAttributes,
org.hypertrace.gateway.service.v1.common.Filter providedFilter) {

if (entityIds.isEmpty()) {
Comment thread
aaron-steinfeld marked this conversation as resolved.
Outdated
return Filter.getDefaultInstance();
}

Filter.Builder compositeFilter = Filter.newBuilder().setOperator(Operator.AND);
Filter convertedProvidedFilter =
isNonDefaultFilter(providedFilter)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -88,16 +88,21 @@ public RequestHandler(
@Override
public ExploreResponse.Builder handleRequest(
ExploreRequestContext requestContext, ExploreRequest request) {
QueryRequest queryRequest =
Optional<QueryRequest> maybeQueryRequest =
buildQueryRequest(requestContext, request, attributeMetadataProvider);

if (maybeQueryRequest.isEmpty()) {
return ExploreResponse.newBuilder();
}

QueryRequest queryRequest = maybeQueryRequest.get();
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

nit - prefer .orElseThrow over .get (or move code around to avoid the direct access)

Iterator<ResultSetChunk> resultSetChunkIterator = executeQuery(requestContext, queryRequest);

return handleQueryServiceResponse(
request, requestContext, resultSetChunkIterator, requestContext, attributeMetadataProvider);
}

QueryRequest buildQueryRequest(
Optional<QueryRequest> buildQueryRequest(
ExploreRequestContext requestContext,
ExploreRequest request,
AttributeMetadataProvider attributeMetadataProvider) {
Expand All @@ -118,7 +123,13 @@ QueryRequest buildQueryRequest(
.orElse(request.getFilter());
}

if (entityIds.isEmpty()) {
Comment thread
aaron-steinfeld marked this conversation as resolved.
Outdated
return Optional.empty();
}

QueryRequest.Builder builder = QueryRequest.newBuilder();


// 1. Add selections. All selections should either be only column or only function, never both.
// The validator should catch this.
List<Expression> aggregatedSelections =
Expand Down Expand Up @@ -160,7 +171,7 @@ QueryRequest buildQueryRequest(
// 4. Add order by along with setting limit, offset
addSortLimitAndOffset(request, requestContext, builder);

return builder.build();
return Optional.of(builder.build());
}

// This is to get all the entity Ids for the EDS source filter.
Expand Down