Apache Flink 漫谈系列(10) - JOIN LATERAL

上面界说的焦点是要求用户实现eval要领，我们写一个详细示例。

• 示例

// 界说一个简朴的UDTF返回范例，对应接口上的 T 
case class SimpleUser(name: String, age: Int) 
// 担任TableFunction，并实现evale要领 
// 焦点成果是理会以#支解的字符串 
class SplitTVF extends TableFunction[SimpleUser] { 
// make sure input element's format is "<string>#<int>" 
def eval(user: String): Unit = { 
if (user.contains("#")) { 
val splits = user.split("#") 
collect(SimpleUser(splits(0), splits(1).toInt)) 
} 
}} 

(2) 示例(完备的ITCase)：

• 测试数据

（编辑：湖南网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!