flink equalTo 的 scala 语法不太理解，麻烦老师解答

请问老师，图中标注的语法是怎么理解的？

我的理解是，equalTo 返回的是一个 function，如果这个 function 没有返回值的话我还能理解，但是这个匿名 function 的返回值（first._1, first._2, second._2）是一个 Tuple 了，后续怎么能又调用 print 呢？所以我可能理解错了，麻烦老师指教一下~

ischand 2022-03-14

源自：Flink快速上手篇 5-3 DataSet API之Transformation-outerJoin

收起

2回答

徐老师回答被采纳获得+3积分 2022-03-14 19:25:13

代码拆开，完整一点的写法是这样的，这样应该好理解了

equalsTo返回的是JoinDataSet类型的数据结构。

后面是调用的JoinDataSet中的apply方法，apply可以省略不写。

val joinDataSet = text1.join(text2)
  .where(0)
  .equalTo(0)

val resDataSet = joinDataSet.apply{ (first, second) => {
  (first._1, first._2, second._2)
  }
}

resDataSet.print()

收起回答

提问者 ischand 2022-03-14 19:26:11

老师，又有不理解的了，为什么 scala 中函数可以用花括号来调用？

收起回答

徐老师 #1

这是scala的语法特性

2022-03-14 19:28:31
提问者 ischand #2

如果调用方式是 sum(1) 的话，我能充分理解，但是 scala 允许 sum { 1 } ，这是什么意思呢，老师

2022-03-14 19:28:36
徐老师 #3

scala中会有很多平时工作中没用过的语法特性

2022-03-14 19:29:12