flink-sql

2热度

1回答

表API斯卡拉

我想连接两个表使用flink scala table api。我有一个包含两个（a，b）列的表格，另一个表格包含一个（c）列，我想将这两个表格连接到一个有三个（a，b，c）列的更大的表格。我只是想加入他们，我不想用任何条件（Where子句）加入他们。但Flink抛出一个错误，以使用Where子句，是否在where子句中没有任何条件的情况下加入表的方式？如果我想使用where子句，我应该给予什么条件

apache-flink flink-sql 2015-07-10

---

1热度

1回答

Flink Table API＆SQL和地图类型（Scala）

我在使用Flink的Table API和/或Flink的SQL支持（Flink 1.3.1，Scala 2.11）在streaming环境中。我开始用DataStream[Person]和Person是一个案例类，看起来像： Person(name: String, age: Int, attributes: Map[String, String]) 所有工作正常，直到我开始把attribut

scala apache-flink flink-streaming flink-sql 2017-08-02

---

0热度

1回答

阿帕奇弗林克：留下一个TableFunction JOIN不会返回预期的结果

弗林克版本：1.3.1 我创建了两个表，一个是从内存，另一个是从UDTF。当我测试join和left join时，他们返回了相同的结果。我期望的是左连接有更多的行而不是连接。 我的测试代码是这样的： public class ExerciseUDF { public static void main(String[] args) throws Exception { te

left-join apache-flink flink-sql 2017-09-27

---