如何在Flink行中按字段名获取值?


0

我有一个方法定义过程(行:org.apache.flink网站.类型。行,字段名:String):Unit=???

我要做的处理要求我用fieldName的名称提取一个字段。我可以看到rowapi允许按顺序提取,而不是按名称提取。

我想用户必须向我传递模式信息,因此方法看起来像def process(行:org.apache.flink网站.类型。行,行模式:???,字段名:String):Unit=???。

我已经调查过了org.apache.flink网站.table.types.logical表.RowType和TypeInformation获取 schema信息,但它们似乎都不对。去这里最好的方法是什么?

1 答案


0

看来我需要org.apache.flink网站.api.java.typeutils.RowTypeInfo。它有方法getFieldIndex(String fieldName)


我来回答

写文章

提问题

面试题