DataStream<CRow> |
DataStreamUnion.translateToPlan(StreamTableEnvironment tableEnv,
StreamQueryConfig queryConfig) |
DataStream<CRow> |
DataStreamGroupAggregate.translateToPlan(StreamTableEnvironment tableEnv,
StreamQueryConfig queryConfig) |
DataStream<CRow> |
DataStreamOverAggregate.translateToPlan(StreamTableEnvironment tableEnv,
StreamQueryConfig queryConfig) |
DataStream<CRow> |
DataStreamGroupWindowAggregate.translateToPlan(StreamTableEnvironment tableEnv,
StreamQueryConfig queryConfig) |
DataStream<CRow> |
DataStreamCorrelate.translateToPlan(StreamTableEnvironment tableEnv,
StreamQueryConfig queryConfig) |
DataStream<CRow> |
DataStreamScan.translateToPlan(StreamTableEnvironment tableEnv,
StreamQueryConfig queryConfig) |
DataStream<CRow> |
DataStreamCalc.translateToPlan(StreamTableEnvironment tableEnv,
StreamQueryConfig queryConfig) |
DataStream<CRow> |
DataStreamRel.translateToPlan(StreamTableEnvironment tableEnv,
StreamQueryConfig queryConfig)
Translates the FlinkRelNode into a Flink operator.
|
DataStream<CRow> |
StreamTableSourceScan.translateToPlan(StreamTableEnvironment tableEnv,
StreamQueryConfig queryConfig) |
DataStream<CRow> |
DataStreamValues.translateToPlan(StreamTableEnvironment tableEnv,
StreamQueryConfig queryConfig) |