Package | Description |
---|---|
com.yahoo.bard.webservice.sql | |
com.yahoo.bard.webservice.sql.aggregation | |
com.yahoo.bard.webservice.sql.evaluator |
Modifier and Type | Method and Description |
---|---|
protected BiFunction<Aggregation,ApiToFieldMapper,Optional<SqlAggregation>> |
DruidQueryToSqlConverter.buildDruidSqlTypeConverter()
Builds a converter between druid and sql aggregations.
|
Modifier and Type | Method and Description |
---|---|
String |
DruidQueryToSqlConverter.buildSqlQuery(DruidAggregationQuery<?> druidQuery,
ApiToFieldMapper apiToFieldMapper)
Builds the druid query as sql and returns it as a string.
|
protected List<org.apache.calcite.rex.RexNode> |
DruidQueryToSqlConverter.getAllGroupByColumns(org.apache.calcite.tools.RelBuilder builder,
DruidAggregationQuery<?> druidQuery,
ApiToFieldMapper apiToFieldMapper,
String timestampColumn)
Collects all the time columns and dimensions to be grouped on.
|
protected List<org.apache.calcite.tools.RelBuilder.AggCall> |
DruidQueryToSqlConverter.getAllQueryAggregations(org.apache.calcite.tools.RelBuilder builder,
DruidAggregationQuery<?> druidQuery,
ApiToFieldMapper apiToFieldMapper)
Find all druid aggregations and convert them to
RelBuilder.AggCall . |
protected org.apache.calcite.rex.RexNode |
DruidQueryToSqlConverter.getAllWhereFilters(org.apache.calcite.tools.RelBuilder builder,
DruidAggregationQuery<?> druidQuery,
ApiToFieldMapper apiToFieldMapper,
String timestampColumn)
Returns the RexNode used to filter the druidQuery.
|
protected Collection<org.apache.calcite.rex.RexNode> |
DruidQueryToSqlConverter.getHavingFilter(org.apache.calcite.tools.RelBuilder builder,
DruidAggregationQuery<?> druidQuery,
ApiToFieldMapper apiToFieldMapper)
Gets the collection of having filters to be applied from the druid query.
|
protected List<org.apache.calcite.rex.RexNode> |
DruidQueryToSqlConverter.getSort(org.apache.calcite.tools.RelBuilder builder,
DruidAggregationQuery<?> druidQuery,
ApiToFieldMapper apiToFieldMapper,
String timestampColumn)
Finds the sorting for a druid query.
|
Constructor and Description |
---|
SqlResultSetProcessor(DruidAggregationQuery<?> druidQuery,
ApiToFieldMapper apiToFieldMapper,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
SqlTimeConverter sqlTimeConverter)
Builds something to process a set of sql results and return them as the
same format as a GroupBy query to Druid.
|
Modifier and Type | Method and Description |
---|---|
Optional<SqlAggregation> |
DruidSqlAggregationConverter.apply(Aggregation aggregation,
ApiToFieldMapper apiToFieldMapper)
Finds the corresponding
SqlAggregation from a druid aggregation. |
SqlAggregation |
DefaultSqlAggregationType.getSqlAggregation(Aggregation aggregation,
ApiToFieldMapper apiToFieldMapper) |
SqlAggregation |
SqlAggregationType.getSqlAggregation(Aggregation aggregation,
ApiToFieldMapper apiToFieldMapper)
Builds a
SqlAggregation which contains all the necessary information to build an aggregation in sql. |
Modifier and Type | Method and Description |
---|---|
org.apache.calcite.rex.RexNode |
FilterEvaluator.evaluate(AndFilter andFilter,
org.apache.calcite.tools.RelBuilder builder,
ApiToFieldMapper apiToFieldMapper)
Evaluates an
AndFilter . |
org.apache.calcite.rex.RexNode |
HavingEvaluator.evaluate(AndHaving andHaving,
org.apache.calcite.tools.RelBuilder builder,
ApiToFieldMapper apiToFieldMapper)
Evaluates a
AndHaving . |
org.apache.calcite.rex.RexNode |
FilterEvaluator.evaluate(Filter filter,
org.apache.calcite.tools.RelBuilder builder,
ApiToFieldMapper apiToFieldMapper)
Top level evaluate call meant to capture
Filter which could not be mapped
to a specific "evaluate" method. |
org.apache.calcite.rex.RexNode |
HavingEvaluator.evaluate(Having having,
org.apache.calcite.tools.RelBuilder builder,
ApiToFieldMapper apiToFieldMapper)
Top level evaluate function meant to capture
Having which could not be mapped
to a specific "evaluate" method. |
org.apache.calcite.rex.RexNode |
FilterEvaluator.evaluate(InFilter inFilter,
org.apache.calcite.tools.RelBuilder builder,
ApiToFieldMapper apiToFieldMapper)
Evaluates an Infilter filter.
|
org.apache.calcite.rex.RexNode |
FilterEvaluator.evaluate(NotFilter notFilter,
org.apache.calcite.tools.RelBuilder builder,
ApiToFieldMapper apiToFieldMapper)
Evaluates an
NotFilter . |
org.apache.calcite.rex.RexNode |
HavingEvaluator.evaluate(NotHaving notHaving,
org.apache.calcite.tools.RelBuilder builder,
ApiToFieldMapper apiToFieldMapper)
Evaluates a
NotHaving filter. |
org.apache.calcite.rex.RexNode |
HavingEvaluator.evaluate(NumericHaving having,
org.apache.calcite.tools.RelBuilder builder,
ApiToFieldMapper apiToFieldMapper)
Evaluates a
NumericHaving . |
org.apache.calcite.rex.RexNode |
FilterEvaluator.evaluate(OrFilter orFilter,
org.apache.calcite.tools.RelBuilder builder,
ApiToFieldMapper apiToFieldMapper)
Evaluates an
OrFilter . |
org.apache.calcite.rex.RexNode |
HavingEvaluator.evaluate(OrHaving orHaving,
org.apache.calcite.tools.RelBuilder builder,
ApiToFieldMapper apiToFieldMapper)
Evaluates a
OrHaving . |
org.apache.calcite.rex.RexNode |
FilterEvaluator.evaluate(RegularExpressionFilter regexFilter,
org.apache.calcite.tools.RelBuilder builder,
ApiToFieldMapper apiToFieldMapper)
Evaluates a regular expression filter.
|
org.apache.calcite.rex.RexNode |
FilterEvaluator.evaluate(SearchFilter searchFilter,
org.apache.calcite.tools.RelBuilder builder,
ApiToFieldMapper apiToFieldMapper)
Evaluates a SearchFilter filter.
|
org.apache.calcite.rex.RexNode |
FilterEvaluator.evaluate(SelectorFilter selectorFilter,
org.apache.calcite.tools.RelBuilder builder,
ApiToFieldMapper apiToFieldMapper)
Evaluates a Selector filter.
|
org.apache.calcite.rex.RexNode |
FilterEvaluator.evaluateFilter(Filter filter,
org.apache.calcite.tools.RelBuilder builder,
ApiToFieldMapper apiToFieldMapper)
Evaluates and builds a filter and finds all the dimension names used in all filters.
|
org.apache.calcite.rex.RexNode |
HavingEvaluator.evaluateHaving(Having having,
org.apache.calcite.tools.RelBuilder builder,
ApiToFieldMapper apiToFieldMapper)
Creates an
RexNode which contains the given Having . |
org.apache.calcite.rex.RexNode |
HavingEvaluator.listEvaluate(MultiClauseHaving multiClauseHaving,
org.apache.calcite.sql.SqlOperator operator,
org.apache.calcite.tools.RelBuilder builder,
ApiToFieldMapper apiToFieldMapper)
Evaluates a
MultiClauseHaving filter by performing it's operation over a list of other havings. |
Copyright © 2016–2018 Yahoo! Inc.. All rights reserved.