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