一个相关的旧邮件列表：link Flink Table接口条件函数文档：link 示例： table.select($("apple").isNotNull() : $("pear").as("fruit")); $("apple").isNotNull()返
浏览 4提问于2020-09-14得票数 0
回答已采纳
1回答
我正在尝试使用flink scala表api连接两个表。我有一个表有两个(a，b)列，另一个表有一个( c)列，我想把这两个表连接到一个更大的表，这个表有三个(a，b，c)列。我只是想加入他们，我不想使用任何条件(Where子句)来加入他们。但是Flink抛给我一个使用Where子句的错误，这是一种在where子句中不带任何条件地连接表的方法吗？如果我想使用where子句，我应该给出什么条件？下面是我连接两个表<em
浏览 2提问于2015-07-10得票数 2
1回答
我正在使用Flink的表API。我想在Table查询中使用CASE WHEN。我的查询使用三个字段：routeid, startlocation, distance和CASE WHEN子句，以便根据distance值识别基于routeid满足的条件。示例： routeid, CASE WHEN (routeid=1) AND (distance > 0 AND distance <
浏览 0提问于2016-05-16得票数 0
我试图在scala中使用Flink表API。编译时间没有错误，但是我正在flink集群中运行作业：flink.api.table.TableException: Type is not supported:<GenericType<java.lang.Object</artifactId></dependency>
我
浏览 4提问于2016-06-23得票数 1
回答已采纳
我使用的是Flink v1.7.1。当我使用tableSource、SQL和tableSink完成Flink流作业时，我不知道如何为它添加单元测试。
浏览 21提问于2019-02-27得票数 2
回答已采纳
这是我的Flink SQL at org.apache.flink.table.api.BatchTableEnvironment.translate(BatchTableEnvironment.scala:498)
at org.apache.flink</em
浏览 8提问于2020-08-11得票数 0
回答已采纳
我有一个简单的测试用例来学习如何使用表API和case /，如下所示：import org.apache.flink.table.api.TableEnvironment).print()
"""
sel
浏览 2提问于2019-01-24得票数 1
回答已采纳
DataStream<String> sourceStream = streamEnv.fromElements("key_a", "key_b", "key_c", "key_d");
Table这显然是一个简化的演示场景。在使用更大的生产数据集之前，我想了解如何使用Flink API在玩具数据集上实现这一点。有关表连接的文档显示了如何连接两个表并取回另一个表，这不是我想要<e
浏览 66提问于2021-04-25得票数 0
回答已采纳
1回答
因此，我认为按以下方式修改代码是可行的： "Id1, " +at org.apache.flink.table.api.TableEnvironment.runVolcanoPlanner(TableEnvironment.scala:387)
at org.apache.flink.ta
浏览 0提问于2019-08-26得票数 0
回答已采纳
1回答
Flink创建视图或表作为选择
、、、、
我正在阅读文档，在Create一节中，我找不到任何类似于CREATE VIEW AS SELECT或CTAS的东西。Select的功能，但不需要自动抓取源表的模式。此外，我发现：
Table result = tableEnv.sqlQuery("SELECTproduct, amount FRO
浏览 2提问于2020-08-30得票数 0
回答已采纳
1回答
我试图在本地运行flink，为一个具有并行性的作业设置8个任务槽。我使用FlinkKafkaProducer011作为接收器。作业可以运行约20分钟，检查点在这段时间内会成功。但是，作业在此之后失败，我得到以下错误：
org.apache.flink.streaming.connectors.kafka.FlinkKafka011Exception:未能向Kafka发送数据
浏览 1提问于2019-07-12得票数 1
我已经编写了一个简单的示例来接收表，但是即使在实现了AppendTableSink接口之后，也可以在Apache中获得这个异常。; import org.apache.flink.table.api.Table;
import org.apache.flink.table.ap
浏览 1提问于2017-08-24得票数 0
我尝试使用flink的表和sql作为一个简单的示例，在这个示例中，我从文件中读取字符串，将其转换为Tuple2，并尝试将其插入表中。这是我的密码。import org.apache.flink.api.common.functions.FlatMapFunction;import org.apache.<em
浏览 1提问于2016-12-21得票数 2
2回答
SQL条件选择子查询值
、、、、
我想对我的select子查询应用条件检查。我怎样才能做得最好呢？以下是初始查询： SELECT (SELECT min(table2.column1) FROM table2 WHERE table2.table1Id =WHERE table1.column2 = "something" AND (:paramete
浏览 22提问于2020-10-24得票数 0
回答已采纳
UDF的整个scala项目都在这里： Flink_SQL_Client_UDF/Scala_fixed/ 我注册udf的操作如下所示： ①mvn scala:compile package③add the following sentence into $FLINK_HOME/conf/flink-conf.
浏览 137提问于2021-01-30得票数 0
回答已采纳
2回答
我正试图在PyFlink中的一个窗口上进行一些聚合。/table.py", line 1290, in selectpy4j.protocol.Py4JJavaError: An error occurred while calling o46.select.
浏览 15提问于2021-06-17得票数 1
当我使用filter filter而不是select时，它工作得很好，但当我添加group_by和order_by时，它会给我一个错误。")\: org.apache.flink.table.api.ValidationException: A limit
浏览 102提问于2020-07-16得票数 0
回答已采纳
1回答
除了这个question之外，我还创建了这个示例来集成DataStreamAPI和TableAPI，这一次我没有出错，而且我有两个作业而不是一个，一个作业是为运行正常的DataStreamAPI创建的，另一个作业是为运行正常的TableAPI创建的，但唯一的问题是永远不会从DataStreamAPI收到任何值，示例： /*FILTERING NULL IDs*/ env.e
浏览 39提问于2020-09-08得票数 0
回答已采纳
它只使用应与结果所需完全匹配的类型信息。但是它不工作，有什么帮助吗？;import org.apache.flink.table.api.BatchTableEnvironment;import org.apache.<em
浏览 0提问于2017-10-29得票数 0
我试图通过将flink env对象传递给flatMap对象来在flatMap中使用table api。但是我得到了序列化异常，它告诉我已经添加了一些不能序列化的字段。
你能帮我照亮一下这个吗？
浏览 4提问于2016-08-15得票数 1
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号