zoukankan      html  css  js  c++  java
  • 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"))

  • 相关阅读:
    第二阶段团队冲刺第五天
    第二阶段冲刺七
    第二阶段冲刺六
    第二阶段冲刺五
    第二阶段冲刺四
    冲刺第二阶段三
    冲刺第二阶段二
    冲刺第二阶段 一
    项目总结
    第二阶段SCRUM
  • 原文地址:https://www.cnblogs.com/wudeyun/p/14841082.html
Copyright © 2011-2022 走看看