Package | Description |
---|---|
org.apache.storm.sql.planner.streams | |
org.apache.storm.sql.runtime.calcite | |
org.apache.storm.sql.runtime.streams.functions |
Modifier and Type | Method and Description |
---|---|
ExecutableExpression |
StreamsPlanCreator.createScalarInstance(List<org.apache.calcite.rex.RexNode> nodes,
org.apache.calcite.rel.type.RelDataType inputRowType,
String className) |
ExecutableExpression |
StreamsPlanCreator.createScalarInstance(org.apache.calcite.rex.RexProgram program,
String className) |
Modifier and Type | Class and Description |
---|---|
class |
DebuggableExecutableExpression |
Constructor and Description |
---|
DebuggableExecutableExpression(ExecutableExpression delegate,
String delegateCode) |
Constructor and Description |
---|
EvaluationCalc(ExecutableExpression filterInstance,
ExecutableExpression projectionInstance,
int outputCount,
org.apache.calcite.DataContext dataContext)
EvaluationCalc Constructor.
|
EvaluationFilter(ExecutableExpression filterInstance,
org.apache.calcite.DataContext dataContext)
EvaluationFilter Constructor.
|
EvaluationFunction(ExecutableExpression projectionInstance,
int outputCount,
org.apache.calcite.DataContext dataContext)
EvaluationFunction Constructor.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.