Class DashboardComponentQueryResultMapperService

java.lang.Object

com.flowable.platform.service.dashboard.resultmapper.DashboardComponentQueryResultMapperService

public class DashboardComponentQueryResultMapperService
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected Map<String, DashboardComponentQueryResultMapper>	queryResultMappers

Constructor Summary

Constructors

Constructor	Description
DashboardComponentQueryResultMapperService(AgentModelPricingService agentModelPricingService, AgentCostTokenService agentCostTokenService, StandardDataQueryInputValuesTransformer inputValuesTransformer)

Method Summary

Modifier and Type	Method	Description
DashboardComponentData	applyQueryResultMapping(DashboardComponentDefinitionModel dashboardComponentDefinitionModel, QueryDefinitionModel queryDefinitionModel, Map<String, tools.jackson.databind.JsonNode> queryPayload, tools.jackson.databind.JsonNode result, String tenantId)
protected String	createJsonPointerExpressionForAggregation(String aggregationDefinitionName, String aggregationDefinitionType)
protected String	createJsonPointerExpressionForAggregation(String aggregationDefinitionName, String aggregationDefinitionType, Double percent)
protected List<org.apache.commons.lang3.tuple.Pair<String,String>>	extractAggregationNamesAndTypes(QueryDefinitionModel queryDefinitionModel)
protected Double	extractAggregationPercent(QueryDefinitionModel queryDefinitionModel, String aggregationName)	Reads the percent property of a named aggregation from the query model's JSON configuration.
protected String	formatPercent(double percent)
protected String	getAggregationType(List<org.apache.commons.lang3.tuple.Pair<String,String>> aggregationNamesToTypesList, String aggregationDefinitionName)
protected DashboardComponentData	handleBarChartDashboardComponent(tools.jackson.databind.JsonNode queryResult, List<DashboardComponentDefinitionModel.DashboardComponentAggregationDefinition> componentAggregationDefinitions, List<org.apache.commons.lang3.tuple.Pair<String,String>> queryAggregationNamesToTypesList, QueryDefinitionModel queryDefinitionModel)
protected DashboardComponentData	handleLineChartDashboardComponent(tools.jackson.databind.JsonNode queryResult, List<DashboardComponentDefinitionModel.DashboardComponentAggregationDefinition> componentAggregationDefinitions, List<org.apache.commons.lang3.tuple.Pair<String,String>> queryAggregationNamesToTypesList, QueryDefinitionModel queryDefinitionModel)
protected DashboardComponentData	handleMultiSeriesBarChart(tools.jackson.databind.JsonNode queryResult, List<DashboardComponentDefinitionModel.DashboardComponentAggregationDefinition> componentAggregationDefinitions, List<org.apache.commons.lang3.tuple.Pair<String,String>> queryAggregationNamesToTypesList, QueryDefinitionModel queryDefinitionModel)	Multi-series bar chart: each component aggregation contributes a series.
protected DashboardComponentData	handlePieChartDashboardComponent(tools.jackson.databind.JsonNode queryResult, List<DashboardComponentDefinitionModel.DashboardComponentAggregationDefinition> componentAggregationDefinitions, List<org.apache.commons.lang3.tuple.Pair<String,String>> queryAggregationNamesToTypesList)
protected DashboardComponentData	handleTableDashboardComponent(DashboardComponentDefinitionModel dashboardComponentDefinitionModel, tools.jackson.databind.JsonNode queryResult, List<DashboardComponentDefinitionModel.DashboardComponentAggregationDefinition> componentAggregationDefinitions, List<org.apache.commons.lang3.tuple.Pair<String,String>> queryAggregationNamesToTypesList)
protected DashboardComponentData	handleValueDashboardComponent(tools.jackson.databind.JsonNode queryResult, List<DashboardComponentDefinitionModel.DashboardComponentAggregationDefinition> componentAggregationDefinitions, List<org.apache.commons.lang3.tuple.Pair<String,String>> queryAggregationNamesToTypesList, QueryDefinitionModel queryDefinitionModel)
protected MultipleValuesKeyValueListDashboardComponentData	harmonize(MultipleValuesKeyValueListDashboardComponentData processedQueryResult)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

queryResultMappers

protected Map<String, DashboardComponentQueryResultMapper> queryResultMappers

Constructor Details

DashboardComponentQueryResultMapperService

public DashboardComponentQueryResultMapperService(AgentModelPricingService agentModelPricingService,
 AgentCostTokenService agentCostTokenService,
 StandardDataQueryInputValuesTransformer inputValuesTransformer)

Method Details

applyQueryResultMapping

public DashboardComponentData applyQueryResultMapping(DashboardComponentDefinitionModel dashboardComponentDefinitionModel,
 QueryDefinitionModel queryDefinitionModel,
 Map<String, tools.jackson.databind.JsonNode> queryPayload,
 tools.jackson.databind.JsonNode result,
 String tenantId)

extractAggregationNamesAndTypes

protected List<org.apache.commons.lang3.tuple.Pair<String,String>> extractAggregationNamesAndTypes(QueryDefinitionModel queryDefinitionModel)

handleValueDashboardComponent

protected DashboardComponentData handleValueDashboardComponent(tools.jackson.databind.JsonNode queryResult,
 List<DashboardComponentDefinitionModel.DashboardComponentAggregationDefinition> componentAggregationDefinitions,
 List<org.apache.commons.lang3.tuple.Pair<String,String>> queryAggregationNamesToTypesList,
 QueryDefinitionModel queryDefinitionModel)

extractAggregationPercent

protected Double extractAggregationPercent(QueryDefinitionModel queryDefinitionModel,
 String aggregationName)

Reads the percent property of a named aggregation from the query model's JSON configuration. Used by percentile-based aggregations to know which values.<percent> key to extract from the Elasticsearch result.

handlePieChartDashboardComponent

protected DashboardComponentData handlePieChartDashboardComponent(tools.jackson.databind.JsonNode queryResult,
 List<DashboardComponentDefinitionModel.DashboardComponentAggregationDefinition> componentAggregationDefinitions,
 List<org.apache.commons.lang3.tuple.Pair<String,String>> queryAggregationNamesToTypesList)

handleBarChartDashboardComponent

protected DashboardComponentData handleBarChartDashboardComponent(tools.jackson.databind.JsonNode queryResult,
 List<DashboardComponentDefinitionModel.DashboardComponentAggregationDefinition> componentAggregationDefinitions,
 List<org.apache.commons.lang3.tuple.Pair<String,String>> queryAggregationNamesToTypesList,
 QueryDefinitionModel queryDefinitionModel)

handleMultiSeriesBarChart

protected DashboardComponentData handleMultiSeriesBarChart(tools.jackson.databind.JsonNode queryResult,
 List<DashboardComponentDefinitionModel.DashboardComponentAggregationDefinition> componentAggregationDefinitions,
 List<org.apache.commons.lang3.tuple.Pair<String,String>> queryAggregationNamesToTypesList,
 QueryDefinitionModel queryDefinitionModel)

Multi-series bar chart: each component aggregation contributes a series. The X axis (bucket key) is shared across series. Currently supports nested-filtered terms with a sum/avg sub-agg (e.g., input vs. output tokens by model).

handleLineChartDashboardComponent

protected DashboardComponentData handleLineChartDashboardComponent(tools.jackson.databind.JsonNode queryResult,
 List<DashboardComponentDefinitionModel.DashboardComponentAggregationDefinition> componentAggregationDefinitions,
 List<org.apache.commons.lang3.tuple.Pair<String,String>> queryAggregationNamesToTypesList,
 QueryDefinitionModel queryDefinitionModel)

handleTableDashboardComponent

protected DashboardComponentData handleTableDashboardComponent(DashboardComponentDefinitionModel dashboardComponentDefinitionModel,
 tools.jackson.databind.JsonNode queryResult,
 List<DashboardComponentDefinitionModel.DashboardComponentAggregationDefinition> componentAggregationDefinitions,
 List<org.apache.commons.lang3.tuple.Pair<String,String>> queryAggregationNamesToTypesList)

getAggregationType

protected String getAggregationType(List<org.apache.commons.lang3.tuple.Pair<String,String>> aggregationNamesToTypesList,
 String aggregationDefinitionName)

createJsonPointerExpressionForAggregation

protected String createJsonPointerExpressionForAggregation(String aggregationDefinitionName,
 String aggregationDefinitionType)

createJsonPointerExpressionForAggregation

protected String createJsonPointerExpressionForAggregation(String aggregationDefinitionName,
 String aggregationDefinitionType,
 Double percent)

formatPercent

protected String formatPercent(double percent)

harmonize

protected MultipleValuesKeyValueListDashboardComponentData harmonize(MultipleValuesKeyValueListDashboardComponentData processedQueryResult)