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

 

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

上一篇:细思极恐!最安全的Telegram账户信息也免不了被破解


下一篇:Surface RT在Win10中安装UWP软件,证书签名【已解决】