在这里，DataStream将键值对作为对象返回，我需要直接使用键值，而不是对象，因为我需要根据键对值进行分组。(false), properties));
// stream.keyBy("record1").print(); 当我给stream.keyby(“record1”).print()时，它显示Exception in thread "main" org.apache.flink.api.common.InvalidProgramE
浏览 7提问于2020-01-24得票数 0
此代码运行良好：但这是抛出异常： at org.apache.flink.api.java.typeutils.TypeExtractor.getKeySelectorTypes(TypeExtractor.java:253)
at org.apache.flink.<
浏览 3提问于2016-03-25得票数 1
回答已采纳
在Apache Flink中获取Exception in thread "main" java.lang.IndexOutOfBoundsException。我试着在效仿，但我得到了免责的提法。our warning pattern PatternStream<CSBEvent> alertPatternStrea
浏览 1提问于2017-11-24得票数 0
我是Flink的新手，以下是流式模式字数： //x is the stream of (word, 1) .flatMap(_.toLowerCase.split("\\W+")) val y: KeyedStream[(String, I
浏览 18提问于2019-01-13得票数 1
回答已采纳
我正在使用Flink的Scala。我在reports = DataStream[Tuple15]上进行了一些转换( Tuple15是Scala，所有字段都是Int)。Type: GenericType<scala.Tuple5> at org.apache.flink.api.comm
浏览 7提问于2016-07-06得票数 4
回答已采纳
我正在遵循Flink官方文档中的示例，试图了解connectedStreams是如何工作的。下面是示例：https://ci.apache.org/projects/flink/flink-docs-master/learn-flink/etl.html#connected-streams publicException {
StreamExecutionEnvironment env = StreamExecutionEnvironment.g
浏览 45提问于2020-07-24得票数 0
回答已采纳
Flink中也有相同的功能吗？
实际上，我想知道我的代码是否如下所示，Flink会评估dataStream一两次吗？val dataStream = env.addSource(...).filter(...).flatMap(...)val s1 = dataStream.keyBy(key1).timeWindow(...).aggregate(..)val s2 = dataStream.keyBy(key2).timeWindow(...).r
浏览 1提问于2020-11-18得票数 0
回答已采纳
1回答
我正在尝试从将Apache教程中的维基百科编辑流分析重写到Scalaimport org.apache.flink.api.common.functions.FoldFunction;import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streami
浏览 1提问于2016-12-29得票数 0
回答已采纳
2回答
[((String, Response), Int)] = parsedStream .keyBy(_._1._1)// ((us, GA, Atlanta,Response()), 14) .keyByevidence$28: org.apache.flink.ap
浏览 18提问于2019-05-02得票数 1
我正在使用Flink来处理来自某些数据源(如Kafka、Pravega等)的数据。dataStream.map(new MapFunction然后，我尝试将JSON数据转换为一个字符串，然后对其进行KeyBy并计数。org.apache.flink</
浏览 0提问于2020-06-03得票数 0
回答已采纳
2回答
话虽如此，如果我使用以下代码DataStream<Element> res = data.filter(...).keyBy(...).timeWindow(...).apply(...);
.keyBy()将DataStream转换为KeyedStream，并在Flink工作节点之间分发。我的问题是，flink在这里将如何处理filter？在对流进行分区/分发之前，过滤
浏览 7提问于2020-05-08得票数 0
回答已采纳
1回答
import org.apache.flink.api.java.functions.KeySelector(firstField: String,otherFields:
String*)org.apa
浏览 0提问于2018-12-29得票数 0
回答已采纳
我是Apache的新手，我尝试过滤以字母"N“开头的单词，并得到输出，但是我如何获得不以单词"N”开头的单词，这是我正在使用的代码import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.<e
浏览 1提问于2020-05-12得票数 0
回答已采纳
来自Flink的官方文档：
import org.apache.flink.streaming.api.functions.co.ProcessJoinFunction;val greenStream: DataStream[Integer]
浏览 11提问于2020-02-17得票数 0
回答已采纳
下面是运行我的小flink程序的异常。该应用程序有来自同一个模拟源的两个数据流。它有一个广播状态。我写这篇文章是为了做一些性能测试，但是给了我一些例外。at org.apache.flink.streaming.api.datastream.KeyedStream.setConnectionType(KeyedStream.java:251)at org.apache.flink.streaming.api.datastream.DataStream.
浏览 15提问于2019-10-01得票数 1
回答已采纳
org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java:151) org.apache.flink.api.java.ClosureCleaner.clean(ClosureCleaner.java::1899)
org.
浏览 2提问于2020-09-23得票数 2
我有两个流，一个是Int流，另一个是json .In，json，有一个键，就是一些int .So，我需要通过键比较来过滤json流和其他整数流，所以在Flink中可以吗？
浏览 1提问于2017-04-20得票数 2
回答已采纳
我想分析一下Flink对RocksDB进行的每个应用程序接口调用所用的时间。但是，我找不到这些函数。示例如下： package org.apache.flink.streaming.examples.spendreport;
import org.apache.flink.streaming.api.environment.Str
浏览 21提问于2020-07-27得票数 0
回答已采纳
我是Flink的新手。有时，我想在不需要先做keyBy的情况下在DataStream上进行聚合。为什么Flink不支持聚合(sum、min、max等)在DataStream上？
谢谢你艾哈迈德
浏览 1提问于2021-03-16得票数 1
2回答
下面是Flink的快速启动示例：。env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
val result = edits.keyBy( _.getUserenv: StreamExecutionEnvironment = StreamEx
浏览 3提问于2017-11-05得票数 7
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号