我正在处理数据库突变流,即更改日志流。我希望能够使用SQL查询转换值。我很难将以下三个概念( RowTypeInfo、Row和DataStream )组合在一起。val mutationStream: DataStream[Mutation] = ...
// toRows returns an object of type org.apache.flink.types.Row
FLINK流:,我有来自kafkaconsumer的DataStreamString,这是JSON .addSource(new FlinkKafkaConsumer[topic", new SimpleStringSchema(), properties))
... 7 more
在mapper中初始化<