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)：

• 测试数据

（编辑：青岛站长网）

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