首页 > Windows开发 > 详细

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

时间:2021-06-02 15:31:17      阅读:11      评论:0      收藏:0      [点我收藏+]
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"))

 

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

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

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!