DataStream<Object> |
DataStreamUnion.translateToPlan(StreamTableEnvironment tableEnv,
scala.Option<TypeInformation<Object>> expectedType) |
DataStream<Object> |
DataStreamScan.translateToPlan(StreamTableEnvironment tableEnv,
scala.Option<TypeInformation<Object>> expectedType) |
DataStream<Object> |
DataStreamCalc.translateToPlan(StreamTableEnvironment tableEnv,
scala.Option<TypeInformation<Object>> expectedType) |
DataStream<Object> |
DataStreamRel.translateToPlan(StreamTableEnvironment tableEnv,
scala.Option<TypeInformation<Object>> expectedType)
Translates the FlinkRelNode into a Flink operator.
|
DataStream<Object> |
StreamTableSourceScan.translateToPlan(StreamTableEnvironment tableEnv,
scala.Option<TypeInformation<Object>> expectedType) |
DataStream<Object> |
DataStreamValues.translateToPlan(StreamTableEnvironment tableEnv,
scala.Option<TypeInformation<Object>> expectedType) |