| Modifier and Type | Field and Description |
|---|---|
protected PlannerContext |
AbstractStatement.plannerContext |
| Modifier and Type | Method and Description |
|---|---|
static List<DruidExpression> |
Aggregations.getArgumentsForSimpleAggregator(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rel.core.AggregateCall call,
org.apache.calcite.rel.core.Project project)
Get Druid expressions that correspond to "simple" aggregator inputs.
|
Aggregation |
SqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations)
Returns a Druid Aggregation corresponding to a SQL
AggregateCall. |
Aggregation |
ApproxCountDistinctSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
static DruidExpression |
Aggregations.toDruidExpressionForNumericAggregator(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode)
Translate a Calcite
RexNode to a Druid expression for the aggregators that require numeric type inputs. |
| Modifier and Type | Method and Description |
|---|---|
Aggregation |
ArrayConcatSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
BuiltinApproxCountDistinctSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
EarliestLatestBySqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
MultiColumnSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
AvgSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
SimpleSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
ArraySqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
CountSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
GroupingSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
StringSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
EarliestLatestAnySqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
Aggregation |
BitwiseSqlAggregator.toDruidAggregation(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
String name,
org.apache.calcite.rel.core.AggregateCall aggregateCall,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
boolean finalizeAggregations) |
| Modifier and Type | Method and Description |
|---|---|
static DruidExpression |
OperatorConversions.convertCall(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode,
DruidExpression.DruidExpressionCreator expressionFunction) |
static DruidExpression |
OperatorConversions.convertCall(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode,
String functionName)
Deprecated.
|
static DruidExpression |
OperatorConversions.convertCall(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode,
String functionName,
Function<List<DruidExpression>,SimpleExtraction> simpleExtractionFunction)
Deprecated.
|
static DruidExpression |
OperatorConversions.convertCallBuilder(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode,
DruidExpression.ExpressionGenerator expressionGenerator) |
static DruidExpression |
OperatorConversions.convertCallWithPostAggOperands(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode,
DruidExpression.DruidExpressionCreator expressionFunction,
PostAggregatorVisitor postAggregatorVisitor) |
static DruidExpression |
OperatorConversions.convertDirectCall(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode,
String functionName) |
static DruidExpression |
OperatorConversions.convertDirectCallWithExtraction(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode,
String functionName,
Function<List<DruidExpression>,SimpleExtraction> simpleExtractionFunction) |
static DruidExpression |
Expressions.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode)
Translate a Calcite
RexNode to a Druid expression for projections or the aggregators that don't
require numeric inputs. |
DruidExpression |
AliasedOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
UnaryFunctionOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
DirectOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
BinaryOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
UnarySuffixOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
UnaryPrefixOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
SqlOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode)
Translate a Calcite
RexNode to a Druid expression. |
static List<DruidExpression> |
Expressions.toDruidExpressions(PlannerContext plannerContext,
RowSignature rowSignature,
List<org.apache.calcite.rex.RexNode> rexNodes)
Translate a list of Calcite
RexNode to Druid expressions. |
static List<DruidExpression> |
Expressions.toDruidExpressionsWithPostAggOperands(PlannerContext plannerContext,
RowSignature rowSignature,
List<org.apache.calcite.rex.RexNode> rexNodes,
PostAggregatorVisitor postAggregatorVisitor)
Translate a list of Calcite
RexNode to Druid expressions, with the possibility of having postagg operands. |
static DruidExpression |
Expressions.toDruidExpressionWithPostAggOperands(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode,
PostAggregatorVisitor postAggregatorVisitor) |
DruidExpression |
AliasedOperatorConversion.toDruidExpressionWithPostAggOperands(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode,
PostAggregatorVisitor postAggregatorVisitor) |
DruidExpression |
DirectOperatorConversion.toDruidExpressionWithPostAggOperands(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode,
PostAggregatorVisitor postAggregatorVisitor) |
DruidExpression |
BinaryOperatorConversion.toDruidExpressionWithPostAggOperands(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode,
PostAggregatorVisitor postAggregatorVisitor) |
default DruidExpression |
SqlOperatorConversion.toDruidExpressionWithPostAggOperands(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode,
PostAggregatorVisitor postAggregatorVisitor)
Translate a Calcite
RexNode to a Druid expression, with the possibility of having postagg operands. |
DimFilter |
AliasedOperatorConversion.toDruidFilter(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexNode rexNode) |
default DimFilter |
SqlOperatorConversion.toDruidFilter(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexNode rexNode)
Returns a Druid filter corresponding to a Calcite
RexNode used as a filter condition. |
static DimFilter |
Expressions.toFilter(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexNode expression)
Translates "condition" to a Druid filter, or returns null if we cannot translate the condition.
|
static PostAggregator |
OperatorConversions.toPostAggregator(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode,
PostAggregatorVisitor postAggregatorVisitor)
Translate a Calcite
RexNode to a Druid PostAggregator |
PostAggregator |
AliasedOperatorConversion.toPostAggregator(PlannerContext plannerContext,
RowSignature querySignature,
org.apache.calcite.rex.RexNode rexNode,
PostAggregatorVisitor postAggregatorVisitor) |
default PostAggregator |
SqlOperatorConversion.toPostAggregator(PlannerContext plannerContext,
RowSignature querySignature,
org.apache.calcite.rex.RexNode rexNode,
PostAggregatorVisitor postAggregatorVisitor)
Returns a Druid PostAggregator corresponding to a Calcite
RexNode used to transform a row after
aggregation has occurred. |
| Modifier and Type | Method and Description |
|---|---|
org.apache.calcite.sql2rel.SqlRexConvertlet |
NestedDataOperatorConversions.DruidJsonValueConvertletFactory.createConvertlet(PlannerContext plannerContext) |
DruidExpression |
TimestampToMillisOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
LTrimOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
StrposOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
NestedDataOperatorConversions.JsonPathsOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
NestedDataOperatorConversions.JsonKeysOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
NestedDataOperatorConversions.JsonQueryOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
NestedDataOperatorConversions.JsonValueReturningTypeOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
NestedDataOperatorConversions.JsonValueAnyOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
NestedDataOperatorConversions.JsonObjectOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
NestedDataOperatorConversions.ToJsonStringOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
NestedDataOperatorConversions.ParseJsonOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
NestedDataOperatorConversions.TryParseJsonOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
RoundOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
TimeShiftOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
TimeParseOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
TimeFloorOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
ParseLongOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
TimeExtractOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
TimeFormatOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
MillisToTimestampOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
TimeArithmeticOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
RightOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
DateTruncOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
CastOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
LeftOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
TruncateOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
CeilOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
RPadOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
RegexpLikeOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
FloorOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
RegexpExtractOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
StringFormatOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
TimeCeilOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
RepeatOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
BTrimOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
QueryLookupOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
SubstringOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
ExtractOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
HumanReadableFormatOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
RTrimOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
LPadOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
TrimOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DruidExpression |
PositionOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
DimFilter |
LikeOperatorConversion.toDruidFilter(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexNode rexNode) |
DimFilter |
ContainsOperatorConversion.toDruidFilter(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexNode rexNode) |
DimFilter |
RegexpLikeOperatorConversion.toDruidFilter(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexNode rexNode) |
DimFilter |
ArrayContainsOperatorConversion.toDruidFilter(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexNode rexNode) |
DimFilter |
ArrayOverlapOperatorConversion.toDruidFilter(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexNode rexNode) |
protected static DimFilter |
BaseExpressionDimFilterOperatorConversion.toExpressionFilter(PlannerContext plannerContext,
String druidFunctionName,
List<DruidExpression> druidExpressions) |
static List<DruidExpression> |
TimeFloorOperatorConversion.toTimestampFloorOrCeilArgs(PlannerContext plannerContext,
RowSignature rowSignature,
List<org.apache.calcite.rex.RexNode> operands)
Function that converts SQL TIME_FLOOR or TIME_CEIL args to Druid expression "timestamp_floor" or "timestamp_ceil"
args.
|
| Modifier and Type | Method and Description |
|---|---|
DruidExpression |
ExternalOperatorConversion.toDruidExpression(PlannerContext plannerContext,
RowSignature rowSignature,
org.apache.calcite.rex.RexNode rexNode) |
| Constructor and Description |
|---|
ExternalTableScanRule(PlannerContext plannerContext) |
| Modifier and Type | Method and Description |
|---|---|
static PlannerContext |
PlannerContext.create(String sql,
DruidOperatorTable operatorTable,
ExprMacroTable macroTable,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
PlannerConfig plannerConfig,
DruidSchemaCatalog rootSchema,
SqlEngine engine,
QueryContext queryContext) |
PlannerContext |
DruidPlanner.getPlannerContext() |
| Modifier and Type | Method and Description |
|---|---|
List<org.apache.calcite.plan.RelOptRule> |
CalciteRulesManager.baseRuleSet(PlannerContext plannerContext) |
List<org.apache.calcite.plan.RelOptRule> |
CalciteRulesManager.bindableConventionRuleSet(PlannerContext plannerContext) |
List<org.apache.calcite.plan.RelOptRule> |
CalciteRulesManager.druidConventionRuleSet(PlannerContext plannerContext) |
List<org.apache.calcite.tools.Program> |
CalciteRulesManager.programs(PlannerContext plannerContext) |
| Constructor and Description |
|---|
DruidRexExecutor(PlannerContext plannerContext) |
RelParameterizerShuttle(PlannerContext plannerContext) |
SqlParameterizerShuttle(PlannerContext plannerContext) |
SqlResourceCollectorShuttle(org.apache.calcite.sql.validate.SqlValidator validator,
PlannerContext plannerContext) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.calcite.sql2rel.SqlRexConvertlet |
TimeInIntervalConvertletFactory.createConvertlet(PlannerContext plannerContext) |
org.apache.calcite.sql2rel.SqlRexConvertlet |
DruidConvertletFactory.createConvertlet(PlannerContext plannerContext) |
org.apache.calcite.sql2rel.SqlRexConvertlet |
CurrentTimestampAndFriendsConvertletFactory.createConvertlet(PlannerContext plannerContext) |
| Constructor and Description |
|---|
DruidConvertletTable(PlannerContext plannerContext) |
| Modifier and Type | Method and Description |
|---|---|
PlannerContext |
DruidRel.getPlannerContext() |
| Modifier and Type | Method and Description |
|---|---|
Grouping |
Grouping.applyProject(PlannerContext plannerContext,
org.apache.calcite.rel.core.Project project)
Applies a post-grouping projection.
|
DruidQuery |
PartialDruidQuery.build(DataSource dataSource,
RowSignature sourceRowSignature,
PlannerContext plannerContext,
org.apache.calcite.rex.RexBuilder rexBuilder,
boolean finalizeAggregations) |
DruidQuery |
PartialDruidQuery.build(DataSource dataSource,
RowSignature sourceRowSignature,
PlannerContext plannerContext,
org.apache.calcite.rex.RexBuilder rexBuilder,
boolean finalizeAggregations,
VirtualColumnRegistry virtualColumnRegistry) |
static DruidJoinQueryRel |
DruidJoinQueryRel.create(org.apache.calcite.rel.core.Join joinRel,
org.apache.calcite.rel.core.Filter leftFilter,
PlannerContext plannerContext)
Create an instance from a Join that is based on two
DruidRel inputs. |
static DruidUnionRel |
DruidUnionRel.create(PlannerContext plannerContext,
org.apache.calcite.rel.type.RelDataType rowType,
List<org.apache.calcite.rel.RelNode> rels,
int limit) |
static DruidUnionDataSourceRel |
DruidUnionDataSourceRel.create(org.apache.calcite.rel.core.Union unionRel,
List<String> unionColumnNames,
PlannerContext plannerContext) |
static DruidQuery |
DruidQuery.fromPartialQuery(PartialDruidQuery partialQuery,
DataSource dataSource,
RowSignature sourceRowSignature,
PlannerContext plannerContext,
org.apache.calcite.rex.RexBuilder rexBuilder,
boolean finalizeAggregations,
VirtualColumnRegistry virtualColumnRegistry) |
VirtualColumn |
VirtualColumnRegistry.getOrCreateVirtualColumnForExpression(PlannerContext plannerContext,
DruidExpression expression,
ColumnType valueType)
Deprecated.
|
VirtualColumn |
VirtualColumnRegistry.getOrCreateVirtualColumnForExpression(PlannerContext plannerContext,
DruidExpression expression,
org.apache.calcite.rel.type.RelDataType dataType)
Deprecated.
|
static Projection |
Projection.postAggregation(org.apache.calcite.rel.core.Project project,
PlannerContext plannerContext,
RowSignature inputRowSignature,
String basePrefix) |
static Projection |
Projection.preAggregation(org.apache.calcite.rel.core.Project project,
PlannerContext plannerContext,
RowSignature inputRowSignature,
VirtualColumnRegistry virtualColumnRegistry) |
static DruidQueryRel |
DruidQueryRel.scanExternal(ExternalTableScan scanRel,
PlannerContext plannerContext)
Create a DruidQueryRel representing a full scan of external data.
|
static DruidQueryRel |
DruidQueryRel.scanTable(org.apache.calcite.rel.logical.LogicalTableScan scanRel,
org.apache.calcite.plan.RelOptTable table,
DruidTable druidTable,
PlannerContext plannerContext)
Create a DruidQueryRel representing a full scan of a builtin table or lookup.
|
static DruidQueryRel |
DruidQueryRel.scanValues(org.apache.calcite.rel.logical.LogicalValues valuesRel,
DruidTable druidTable,
PlannerContext plannerContext)
Create a DruidQueryRel representing a full scan of inline, literal values.
|
| Constructor and Description |
|---|
DruidRel(org.apache.calcite.plan.RelOptCluster cluster,
org.apache.calcite.plan.RelTraitSet traitSet,
PlannerContext plannerContext) |
| Modifier and Type | Method and Description |
|---|---|
org.apache.calcite.plan.RelOptRule |
ExtensionCalciteRuleProvider.getRule(PlannerContext plannerContext) |
static DruidJoinRule |
DruidJoinRule.instance(PlannerContext plannerContext) |
static boolean |
DruidUnionDataSourceRule.isCompatible(org.apache.calcite.rel.core.Union unionRel,
DruidRel<?> first,
DruidRel<?> second,
PlannerContext plannerContext) |
static List<org.apache.calcite.plan.RelOptRule> |
DruidRules.rules(PlannerContext plannerContext) |
static Aggregation |
GroupByRules.translateAggregateCall(PlannerContext plannerContext,
RowSignature rowSignature,
VirtualColumnRegistry virtualColumnRegistry,
org.apache.calcite.rex.RexBuilder rexBuilder,
org.apache.calcite.rel.core.Project project,
List<Aggregation> existingAggregations,
String name,
org.apache.calcite.rel.core.AggregateCall call,
boolean finalizeAggregations)
Translate an AggregateCall to Druid equivalents.
|
| Constructor and Description |
|---|
DruidLogicalValuesRule(PlannerContext plannerContext) |
DruidTableScanRule(PlannerContext plannerContext) |
DruidUnionDataSourceRule(PlannerContext plannerContext) |
DruidUnionRule(PlannerContext plannerContext) |
| Modifier and Type | Method and Description |
|---|---|
QueryMaker |
SqlEngine.buildQueryMakerForInsert(String targetDataSource,
org.apache.calcite.rel.RelRoot relRoot,
PlannerContext plannerContext)
Create a
QueryMaker for an INSERT ... |
QueryMaker |
NativeSqlEngine.buildQueryMakerForInsert(String targetDataSource,
org.apache.calcite.rel.RelRoot relRoot,
PlannerContext plannerContext) |
QueryMaker |
SqlEngine.buildQueryMakerForSelect(org.apache.calcite.rel.RelRoot relRoot,
PlannerContext plannerContext)
Create a
QueryMaker for a SELECT query. |
QueryMaker |
NativeSqlEngine.buildQueryMakerForSelect(org.apache.calcite.rel.RelRoot relRoot,
PlannerContext plannerContext) |
boolean |
SqlEngine.feature(EngineFeature feature,
PlannerContext plannerContext)
Whether a feature applies to this engine or not.
|
boolean |
NativeSqlEngine.feature(EngineFeature feature,
PlannerContext plannerContext) |
| Constructor and Description |
|---|
NativeQueryMaker(QueryLifecycleFactory queryLifecycleFactory,
PlannerContext plannerContext,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
List<org.apache.calcite.util.Pair<Integer,String>> fieldMapping) |
| Modifier and Type | Method and Description |
|---|---|
QueryMaker |
ViewSqlEngine.buildQueryMakerForInsert(String targetDataSource,
org.apache.calcite.rel.RelRoot relRoot,
PlannerContext plannerContext) |
QueryMaker |
ViewSqlEngine.buildQueryMakerForSelect(org.apache.calcite.rel.RelRoot relRoot,
PlannerContext plannerContext) |
boolean |
ViewSqlEngine.feature(EngineFeature feature,
PlannerContext plannerContext) |
Copyright © 2011–2022 The Apache Software Foundation. All rights reserved.