flink流具有多个数据流，然后使用org.apache.flink.streaming.api.datastream.DataStream#union方法对这些数据流进行合并。Sorting union of streams to identify user sessions in Apache Flink 我得到了答案，但com.liam.learn.flink.example.union.UnionStreamDemo.SortFunction环境信息:
浏览 30提问于2019-01-12得票数 2
我们有两种信息要发送到Flink
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;import org.apache.flink.streaming.connectors.fs.RollingSin
浏览 3提问于2016-05-06得票数 5
我试图将一个Seq[DataSet(Long,Long,Double)]与Flink中的单个DataSet[(Long,Long,Double)]结合起来： el.vector, 150, metric)).reduce(
(a, b) => a.union(b)org.apache.flink.optimizer.CompilerException:目前无法处理超过64个输出的节点。在o
浏览 1提问于2015-07-24得票数 4
回答已采纳
卡夫卡，Flink和Tidb的新版本。假设我有三个源MySql表-- s_a、s_b和s_c，并希望实时收集记录以针对TiDb表t_a和t_b。映射规则是`s_b` union `s_c` ---> `t_b` with some transformation (e.g我采用的解决方案是kafka +带有Tidb接收器的Flink，其中binlog更改被订阅到Kafka主题；Flink使用该主题并将转换结果写入Tidb。对我来说，<
浏览 3提问于2020-11-20得票数 0
假设我有两种不同类型的数据流，一种提供天气数据，另一种提供车辆数据，我想使用Flink对数据进行复杂的事件处理。
Flink 1.3.x中的哪种方法是正确的方法？我看到了不同的方法，如Union、Connect、Window Join。
浏览 3提问于2017-07-12得票数 3
回答已采纳
1回答
我正在研究Flink中的数据倾斜处理，以及如何改变低，以便对元组进行均匀处理。我创建了合成的、倾斜的数据源，我的目标是通过窗口处理(聚合)它们。这是。streamTrainsStation01.union(streamTrainsStation02)
.union(streamTicketsStation01).union(streamTicketsStation02addSink(new MqttStationPlatformPublisher(ipAddressSink, topic)).name(me
浏览 0提问于2019-04-10得票数 0
回答已采纳
/bin/flink run examples/explore-flink.jar -c启动我的应用程序import org.apache.flink.api.java.tuple.Tuple2;import org.sense.flink.mqtt.MqttTemperature;
import org.sense
浏览 0提问于2019-02-01得票数 0
回答已采纳
org.apache.avro.generic.GenericData.Record;import org.apache.flink.api.common.functions.MapFunction;import org.apache.flink.streaming.api.environment.StreamExecutio
浏览 1提问于2016-05-09得票数 2
我以为所有的Java依赖都是和pip install apache-flink一起安装的 以上错误发生在该行上： kafka_consumer = FlinkKafkaConsumer(
topics
浏览 252提问于2021-09-26得票数 0
1回答
= delayqueue.map(prepareData2()) // these messages comes from delay
val taggedStream = enrichedResults.process(tagStreamAsRetryOrNot延迟流的另一端： delayQueue(written by flink) => co
浏览 35提问于2021-04-24得票数 1
我使用Flink 1.3.2与来自flink连接器的hbase (flink-hbase_2.11)，使用DataSet API。TableInputFormat("table", 1);tableInputFormat9 = new TableInputFormat("table", 9);
浏览 2提问于2017-12-07得票数 0
基本上，我使用CoFlatMapFunction (<code>C0</code>)来过滤一个流，并在运行时更改过滤参数，为此我使用了Flink。如果我使用union，它将不起作用，因为流是不同的，并且我不被允许执行Union。如果我使用过滤器，我将不会有我想要的动态行为。有什么建议吗？
谢谢
浏览 19提问于2018-12-21得票数 0
回答已采纳
1回答
我试着联合一些flink DataSets。它们都包含在一个赛格里。maxBeforezTCZ(it,at plusMinutes(i))))val ma_all = ma_range.head union(ma_range.tail.head)
线程“主”org.apache.flink.api.common.InvalidProgram
浏览 3提问于2015-09-04得票数 2
回答已采纳
;import org.apache.flink.api.java.functions.KeySelector;import org.apache.flink.configuration.Configuration;import org.apache.flink.streaming.api
浏览 0提问于2019-02-01得票数 0
回答已采纳
com.hulu.hiveIngestion.HiveAddPartitionThread.run(HiveAddPartitionThread.java:48) at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:63)
at org.apache.fli
浏览 66提问于2020-07-29得票数 0
1回答
我在下面的一个片段中概述了我正在尝试工作的内容(作为概念的证明)，但是当我试图上传它时，我得到了一个org.apache.flink.client.program.ProgramInvocationExceptionStreams, one for each "rule" that is being executed
// For now, I have a simple custom wrapper on flink'sMyClass.filter(logs, "response"
浏览 3提问于2019-03-04得票数 0
回答已采纳
1回答
我有一个使用python表api的Flink作业。现在，我的应用程序将使用一个额外的源流。我很好奇用表API消费多个源流的推荐方式是什么。 其他信息： 这两个输入流只是两个事件源。它就像DataStream中的union operation 谢谢!
浏览 14提问于2021-11-05得票数 0
我想让flink使用者流中的每条消息产生多条消息，每条消息通过一个单独的线程生成到kafka中的某些主题，使用flink kafka producer.Im用Scala编写程序，但是使用Java的答案就可以了new Thread { flink_producer(str)
} }
val stream
浏览 0提问于2018-01-30得票数 0
回答已采纳
;import org.apache.flink.api.common.functions.RichMapFunction;import org.apache.flink.streaming.api.TimeCharacteristic;
import org.apache.flink.stre
浏览 10提问于2019-02-12得票数 0
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号