阅读 52

Flink Table Api $"" $("") '

case class Person(var id: Int, var name:String, var age: Int);
val tPerson: Table = tableEnv.from("person")

如上:如果我们要选择 id 字段,方法如下

$"id": 定义该隐式转换的类如下

  implicit class FieldExpression(val sc : scala.StringContext) extends scala.AnyRef {
    def $(args : scala.Any*) : org.apache.flink.table.expressions.Expression = { /* compiled code */ }}

$("id"): 定义该隐式转换的类如下

public final class Expressions {    
public static ApiExpression $(String name) {
        return new ApiExpression(unresolvedRef(name));
    }
...
}

‘id:这个符号定义位置没找到,但是需要以入

import org.apache.flink.table.api._

 

这三个符号,都是对字段的引用,就如 where name = "张飞", .where(‘name.isEqual("zhangfei"))

 

原文:https://www.cnblogs.com/wudeyun/p/14841082.html

文章分类
代码人生
版权声明:本站是系统测试站点,无实际运营。本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 XXXXXXo@163.com 举报,一经查实,本站将立刻删除。
相关推荐