| 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 © 2021 The Apache Software Foundation. All rights reserved.