Skip to content

Commit 7fea23a

Browse files
chore: rename attribute expression association
1 parent 08d7619 commit 7fea23a

File tree

17 files changed

+63
-52
lines changed

17 files changed

+63
-52
lines changed

hypertrace-core-graphql

hypertrace-graphql-entity-schema/src/main/java/org/hypertrace/graphql/entity/dao/GatewayServiceEntityConverter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@ private Single<Entity> convertEntity(
129129
entityRequest
130130
.resultSetRequest()
131131
.idAttribute()
132-
.attributeExpression()
132+
.attributeExpressionAssociation()
133133
.value())
134134
.toString(),
135135
entityRequest.entityType(),

hypertrace-graphql-entity-schema/src/main/java/org/hypertrace/graphql/entity/dao/GatewayServiceEntityInteractionRequestBuilder.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -72,9 +72,9 @@ private Single<Filter> buildEntityTypeFilter(EdgeSetGroupRequest request) {
7272
.map(
7373
entityTypes ->
7474
AttributeAssociation.<FilterArgument>of(
75-
request.neighborTypeAttribute().attributeExpression().attribute(),
75+
request.neighborTypeAttribute().attributeExpressionAssociation().attribute(),
7676
new EntityNeighborTypeFilter(
77-
request.neighborTypeAttribute().attributeExpression().value(),
77+
request.neighborTypeAttribute().attributeExpressionAssociation().value(),
7878
entityTypes)))
7979
.flatMap(filterAssociation -> this.filterConverter.convert(Set.of(filterAssociation)));
8080
}

hypertrace-graphql-explorer-schema/src/main/java/org/hypertrace/graphql/explorer/dao/GatewayServiceSelectionMapConverter.java

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -69,11 +69,14 @@ private Single<Entry<ExploreResultMapKey, Selection>> buildAttributeMapEntry(
6969
return this.valueConverter
7070
.convert(row.getColumnsOrThrow(attributeRequest.asMapKey()))
7171
.flatMap(
72-
value -> this.buildSelection(attributeRequest.attributeExpression().attribute(), value))
72+
value ->
73+
this.buildSelection(
74+
attributeRequest.attributeExpressionAssociation().attribute(), value))
7375
.map(
7476
selection ->
7577
Map.entry(
76-
ExploreResultMapKey.attribute(attributeRequest.attributeExpression().value()),
78+
ExploreResultMapKey.attribute(
79+
attributeRequest.attributeExpressionAssociation().value()),
7780
selection));
7881
}
7982

@@ -90,7 +93,8 @@ private Single<Entry<ExploreResultMapKey, Selection>> buildAggregationMapEntry(
9093
.convert(row.getColumnsOrThrow(aggregationRequest.alias()))
9194
.flatMap(
9295
value ->
93-
this.buildSelection(aggregationRequest.attributeExpression().attribute(), value))
96+
this.buildSelection(
97+
aggregationRequest.attributeExpressionAssociation().attribute(), value))
9498
.zipWith(
9599
this.aggregationTypeConverter.convert(aggregationRequest.aggregation()),
96100
(selection, aggregation) ->

hypertrace-graphql-explorer-schema/src/main/java/org/hypertrace/graphql/explorer/fetcher/ExploreResultMapKey.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ public static ExploreResultMapKey attribute(AttributeExpression attributeExpress
3030
public static ExploreResultMapKey forAggregationRequest(
3131
MetricAggregationRequest aggregationRequest, MetricAggregationType aggregationType) {
3232
return new ExploreResultMapKey(
33-
aggregationRequest.attributeExpression().value(),
33+
aggregationRequest.attributeExpressionAssociation().value(),
3434
aggregationType,
3535
aggregationRequest.arguments());
3636
}

hypertrace-graphql-gateway-service-metric-utils/src/main/java/org/hypertrace/graphql/utils/metrics/gateway/AggregatableOrderByExpressionListConverter.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -64,23 +64,23 @@ private Single<OrderByExpression> buildOrderByExpression(
6464

6565
private Single<Expression> buildSelectionExpression(
6666
AttributeAssociation<AggregatableOrderArgument> orderArgument) {
67-
AttributeAssociation<AttributeExpression> attributeExpression =
68-
this.buildAttributeExpression(orderArgument);
67+
AttributeAssociation<AttributeExpression> attributeExpressionAssociation =
68+
this.buildAttributeExpressionAssociation(orderArgument);
6969
return Maybe.fromOptional(Optional.ofNullable(orderArgument.value().aggregation()))
7070
.flatMapSingle(this.aggregationTypeConverter::convert)
7171
.flatMapSingle(
7272
aggregationType ->
7373
orderArgument.value().size() == null
7474
? this.metricAggregationExpressionConverter.convertForNoArgsOrAlias(
75-
attributeExpression, aggregationType)
75+
attributeExpressionAssociation, aggregationType)
7676
: this.metricAggregationExpressionConverter.convertForArgsButNoAlias(
77-
attributeExpression,
77+
attributeExpressionAssociation,
7878
aggregationType,
7979
List.of(Objects.requireNonNull(orderArgument.value().size()))))
80-
.switchIfEmpty(this.columnExpressionConverter.convert(attributeExpression));
80+
.switchIfEmpty(this.columnExpressionConverter.convert(attributeExpressionAssociation));
8181
}
8282

83-
private AttributeAssociation<AttributeExpression> buildAttributeExpression(
83+
private AttributeAssociation<AttributeExpression> buildAttributeExpressionAssociation(
8484
AttributeAssociation<AggregatableOrderArgument> orderArgumentAttributeAssociation) {
8585
return AttributeAssociation.of(
8686
orderArgumentAttributeAssociation.attribute(),

hypertrace-graphql-gateway-service-metric-utils/src/main/java/org/hypertrace/graphql/utils/metrics/gateway/MetricAggregationContainerMapConverter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ public Single<Map<AttributeExpression, BaselinedMetricAggregationContainer>> con
3636
Map<String, AggregatedMetricValue> metricResponses) {
3737
return Observable.fromIterable(metricRequests)
3838
.distinct()
39-
.groupBy(request -> request.attributeExpression().value())
39+
.groupBy(request -> request.attributeExpressionAssociation().value())
4040
.flatMapSingle(requests -> this.buildMetricContainerEntry(requests, metricResponses))
4141
.collect(immutableMapEntryCollector());
4242
}

hypertrace-graphql-gateway-service-metric-utils/src/main/java/org/hypertrace/graphql/utils/metrics/gateway/MetricAggregationExpressionConverter.java

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -45,39 +45,40 @@ public Single<Set<Expression>> convert(Collection<MetricAggregationRequest> metr
4545

4646
Single<Expression> convert(MetricAggregationRequest metricAggregation, String alias) {
4747
return this.buildAggregationFunctionExpression(
48-
metricAggregation.attributeExpression(),
48+
metricAggregation.attributeExpressionAssociation(),
4949
metricAggregation.aggregation(),
5050
metricAggregation.arguments(),
5151
alias)
5252
.map(functionExpression -> Expression.newBuilder().setFunction(functionExpression).build());
5353
}
5454

5555
Single<Expression> convertForNoArgsOrAlias(
56-
AttributeAssociation<AttributeExpression> attributeExpression,
56+
AttributeAssociation<AttributeExpression> attributeExpressionAssociation,
5757
AttributeModelMetricAggregationType aggregationType) {
58-
return convertForArgsButNoAlias(attributeExpression, aggregationType, Collections.emptyList());
58+
return convertForArgsButNoAlias(
59+
attributeExpressionAssociation, aggregationType, Collections.emptyList());
5960
}
6061

6162
Single<Expression> convertForArgsButNoAlias(
62-
AttributeAssociation<AttributeExpression> attributeExpression,
63+
AttributeAssociation<AttributeExpression> attributeExpressionAssociation,
6364
AttributeModelMetricAggregationType aggregationType,
6465
List<Object> arguments) {
6566
return this.buildAggregationFunctionExpression(
66-
attributeExpression,
67+
attributeExpressionAssociation,
6768
aggregationType,
6869
arguments,
6970
StringValue.getDefaultInstance().getValue())
7071
.map(functionExpression -> Expression.newBuilder().setFunction(functionExpression).build());
7172
}
7273

7374
private Single<FunctionExpression> buildAggregationFunctionExpression(
74-
AttributeAssociation<AttributeExpression> attributeExpression,
75+
AttributeAssociation<AttributeExpression> attributeExpressionAssociation,
7576
AttributeModelMetricAggregationType aggregationType,
7677
List<Object> arguments,
7778
String alias) {
7879
return zip(
7980
functionTypeConverter.convert(aggregationType),
80-
this.columnExpressionConverter.convert(attributeExpression),
81+
this.columnExpressionConverter.convert(attributeExpressionAssociation),
8182
this.convertArguments(arguments),
8283
(functionType, columnExpression, argumentExpressionList) ->
8384
FunctionExpression.newBuilder()

hypertrace-graphql-gateway-service-metric-utils/src/main/java/org/hypertrace/graphql/utils/metrics/gateway/MetricContainerMapConverter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ public Single<Map<AttributeExpression, MetricContainer>> convert(
5353
Collection<MetricRequest> metricRequests, Entity entity, BaselineEntity baselineEntity) {
5454
return Observable.fromIterable(metricRequests)
5555
.distinct()
56-
.groupBy(request -> request.attributeExpression().value())
56+
.groupBy(request -> request.attributeExpressionAssociation().value())
5757
.flatMapSingle(requests -> this.buildMetricContainerEntry(requests, entity, baselineEntity))
5858
.collect(immutableMapEntryCollector());
5959
}

hypertrace-graphql-metric-schema/src/main/java/org/hypertrace/graphql/metric/request/DefaultMetricAggregationRequestBuilder.java

Lines changed: 15 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -53,15 +53,17 @@ class DefaultMetricAggregationRequestBuilder implements MetricAggregationRequest
5353

5454
@Override
5555
public Observable<MetricAggregationRequest> build(
56-
AttributeAssociation<AttributeExpression> attributeExpression,
56+
AttributeAssociation<AttributeExpression> attributeExpressionAssociation,
5757
SelectedField metricAggregationContainerField) {
5858
return Observable.fromStream(
5959
this.selectionFinder.findSelections(
6060
metricAggregationContainerField.getSelectionSet(),
6161
SelectionQuery.builder()
6262
.matchesPredicate(field -> this.getAggregationTypeForField(field).isPresent())
6363
.build()))
64-
.map(selectedField -> this.requestForAggregationField(attributeExpression, selectedField));
64+
.map(
65+
selectedField ->
66+
this.requestForAggregationField(attributeExpressionAssociation, selectedField));
6567
}
6668

6769
@Override
@@ -74,27 +76,28 @@ public Single<List<MetricAggregationRequest>> build(
7476
}
7577

7678
public MetricAggregationRequest build(
77-
AttributeAssociation<AttributeExpression> attributeExpression,
79+
AttributeAssociation<AttributeExpression> attributeExpressionAssociation,
7880
AttributeModelMetricAggregationType aggregationType,
7981
List<Object> arguments) {
80-
return this.build(attributeExpression, aggregationType, arguments, false);
82+
return this.build(attributeExpressionAssociation, aggregationType, arguments, false);
8183
}
8284

8385
private MetricAggregationRequest build(
84-
AttributeAssociation<AttributeExpression> attributeExpression,
86+
AttributeAssociation<AttributeExpression> attributeExpressionAssociation,
8587
AttributeModelMetricAggregationType aggregationType,
8688
List<Object> arguments,
8789
boolean baseline) {
8890
return new DefaultMetricAggregationRequest(
89-
attributeExpression, aggregationType, arguments, baseline);
91+
attributeExpressionAssociation, aggregationType, arguments, baseline);
9092
}
9193

9294
private MetricAggregationRequest requestForAggregationField(
93-
AttributeAssociation<AttributeExpression> attributeExpression, SelectedField field) {
95+
AttributeAssociation<AttributeExpression> attributeExpressionAssociation,
96+
SelectedField field) {
9497
AttributeModelMetricAggregationType aggregationType =
9598
this.getAggregationTypeForField(field).orElseThrow();
9699
return this.build(
97-
attributeExpression,
100+
attributeExpressionAssociation,
98101
aggregationType,
99102
this.getArgumentsForAggregation(aggregationType, field.getArguments()),
100103
this.selectionFinder
@@ -170,7 +173,7 @@ private Integer percentileSize(Map<String, Object> arguments) {
170173
@Value
171174
@Accessors(fluent = true)
172175
private static class DefaultMetricAggregationRequest implements MetricAggregationRequest {
173-
AttributeAssociation<AttributeExpression> attributeExpression;
176+
AttributeAssociation<AttributeExpression> attributeExpressionAssociation;
174177
AttributeModelMetricAggregationType aggregation;
175178
List<Object> arguments;
176179
boolean baseline;
@@ -179,7 +182,9 @@ private static class DefaultMetricAggregationRequest implements MetricAggregatio
179182
public String alias() {
180183
return String.format(
181184
"%s_%s_%s",
182-
this.aggregation.name(), this.attributeExpression.attribute().id(), this.arguments);
185+
this.aggregation.name(),
186+
this.attributeExpressionAssociation.attribute().id(),
187+
this.arguments);
183188
}
184189

185190
@Override

0 commit comments

Comments
 (0)