DataStream<String> sourceStream = streamEnv.fromElements("key_a", "key_b", "key_c", "key_d");
DataTypes.ROW(这显然是一个简化的演示场景。在使用更大的生产数据集之前，我想了解如何使用Flin
浏览 66提问于2021-04-25得票数 0
回答已采纳
我是Apache Flink的新手，我想了解DataStream和Table API之间的用例。请您帮我了解一下，什么时候选择Table接口而不是DataStream接口。据我所知，用Table API可以做的事情，也可以用DataStream API来做。这两个API有什么不同？
浏览 14提问于2018-08-01得票数 2
回答已采纳
我尝试使用flink的表和sql作为一个简单的示例，在这个示例中，我从文件中读取字符串，将其转换为Tuple2，并尝试将其插入表中。这是我的密码。import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.java.table.
浏览 1提问于2016-12-21得票数 2
我使用的是Flink v1.7.1。当我使用tableSource、SQL和tableSink完成Flink流作业时，我不知道如何为它添加单元测试。
浏览 21提问于2019-02-27得票数 2
回答已采纳
我已经编写了一个简单的示例来接收表，但是即使在实现了AppendTableSink接口之后，也可以在Apache中获得这个异常。; import org.apache.flink.streaming.api.datastream.DataStream;
import org.<
浏览 1提问于2017-08-24得票数 0
1回答
，另一个作业是为运行正常的TableAPI创建的，但唯一的问题是永远不会从DataStreamAPI收到任何值，示例： /*FILTERING NULL IDs*/ DataStreamInit.init(stream_filtered);
env.exec
浏览 39提问于2020-09-08得票数 0
回答已采纳
我的代码就像：tableEnv.createTemporaryView("input_tableRow> rows = src.map(val -> Row.of(val.f0, val.f1)).returns(rti);新代码工作正常，但在我看来有点扭
浏览 3提问于2021-08-02得票数 0
回答已采纳
CommonCalc.scala:44) at org.apache.flink.table.plan.nodes.datastream.DataStreamCalc.translateToPlan:837)
at org
浏览 1提问于2018-03-02得票数 1
1回答
不会触发Flink版本1.12.2的任何错误。(BlinkPlannerFactory.java:48) at org.apache.flink.table.<e
浏览 8提问于2021-04-29得票数 0
回答已采纳
我想创建一个用scala编写的flink项目。当我导入时'flink-streaming-scala_2.11'我可以运行如下代码：但我看到每一个都是这样：
flink-
浏览 6提问于2017-07-23得票数 0
回答已采纳
问题
org.apache.flink.streaming.api.scala.function.ProcessWindowFunction对于窗口操作，就像在o
浏览 1提问于2019-07-07得票数 0
在eclipse中尝试执行基本的Flink程序时，由于.print()被datastream_name.print()调用来打印我的数据，我得到了错误。(StreamExecutionEnvironment.java:2139)
at org.apache.flink.streaming.api.datastream.DataStream.clean(DataStream.java:203)
浏览 15提问于2022-06-26得票数 0
我跟随使用mysql数据库作为Flink的接收器。org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:151) org.apache.flink.streaming.api.
浏览 2提问于2020-09-23得票数 2
因为它们是DataSet和DataStream API的一部分，所以可以在一个工作中完成我想要做的事情吗？
浏览 34提问于2020-04-29得票数 0
回答已采纳
1回答
我有一个Flink应用程序，它保持与这个错误的错误。 com.org.ads.audience.traffic.MyClass@6eaa21d8 is not serializable.org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:140)
org.apache.flink.api.java.ClosureCleaner.clean
浏览 448提问于2019-09-25得票数 1
我试图从本地加载一个复杂的JSON文件(多个不同的数据类型、嵌套的对象/数组等)，使用将它们作为源代码读取，然后将它们放到DataStream中，然后执行一些操作(为了简洁起见，此处不显示)。转换给我一个DataStream[Row]类型的DataStream[Row]，我需要将它转换为DataStream[RowData] (为了接收器的目的，这里不详细介绍)。import org.apache<
浏览 27提问于2022-03-04得票数 1
1回答
我想要做的是，如果数据存储等于从hbase中读取的特定字符串，则忽略它。下面是我得到的示例程序和错误。import org.apache.flink.api.java.tuple.Tuple2 table.close();}
错
浏览 4提问于2016-11-06得票数 0
回答已采纳
1回答
我正在尝试读取一个包含34个字段的文件，以便使用Netbeans在控制台上打印。但是，我所能输出的只是模式。因为与csvreader一起使用的Flink的这个特定版本中缺少打印选项。;import org.apache.flink.streaming.api.datastream.Da
浏览 0提问于2018-07-30得票数 2
回答已采纳
1.4.2 (1.4.x)运行相同的代码，我得到了以下错误：import org.apache.flink.api.common.functions.MapFunction;
import org.apache.f
浏览 2提问于2018-03-24得票数 4
回答已采纳
我是Apache的新手，我尝试过滤以字母"N“开头的单词，并得到输出，但是我如何获得不以单词"N”开头的单词，这是我正在使用的代码import org.apache.flink.api.common
浏览 1提问于2020-05-12得票数 0
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号