腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(6607)
视频
沙龙
2
回答
如何获取Apache中筛选函数中不匹配的值的输出
、
、
Apache的新手,我尝试过滤以字母"N“开头的单词,并得到输出,但是我如何获得不以单词"N”开头的单词,这是我正在使用的代码import org.apache.
flink
.api.common.functions.FlatMapFunction; import org.apache.
flink
.api.java.tuple.Tuple2;
浏览 1
提问于2020-05-12
得票数 0
回答已采纳
1
回答
与python连接,作业执行失败
、
、
见守则:from org.apache.
flink
.api.common.functionsimport
FilterFunction
import sys def readjason(self'r')
浏览 0
提问于2019-03-06
得票数 1
1
回答
Spark Streaming是否支持迭代为
Flink
?
、
例如,下面是
Flink
的程序,它从一系列整数中连续减去1,直到它们达到零: return value - 1 ;}); Data
浏览 0
提问于2015-11-23
得票数 0
1
回答
如何过滤大于
flink
中某一点的值?
import com.sun.org.apache.xpath.internal.operations.Bool;import org.apache.
flink
.api.java.tuple.Tuple2;import org.apache.
flink
.streami
浏览 10
提问于2019-02-12
得票数 0
回答已采纳
1
回答
当
flink
运行超过12小时时,机器上CPU负载增加的原因
、
、
、
我有一个
flink
作业,并行度设置为6,很少有简单的转换,问题是当
Flink
运行超过12小时时,例如机器上的负载开始增加,然后我认为这是因为在一天中的某些小时内进入
flink
的流量,但问题是当流量下降时MyProcessWindowFunction())keyed_stream.filter(new
FilterFunction
addSink(new SinkFuncion()); /*
浏览 84
提问于2020-08-01
得票数 0
2
回答
如何在
Flink
应用程序中更新/刷新参数
、
、
我有一个
Flink
应用程序的AWS动态分析服务。我需要根据阈值过滤数据流上的一些值。另外,我使用AWS系统管理器参数存储服务传递阈值参数。.name("FilterData")过滤器类:import org.apache.
flink
.api.common.functions.
FilterFunction
InputData](
浏览 7
提问于2022-01-27
得票数 0
回答已采纳
1
回答
如何在
flink
中读取前N条kafka消息?
、
、
我正在使用
flink
构建一个管道,它的来源是kafka。为了测试,我只想读取来自kafka的前N条消息,然后需要停止流。 我该怎么做呢?我使用的是FlinkKafkaConsumer08。
浏览 15
提问于2019-02-15
得票数 0
回答已采纳
2
回答
Flink
从GenericRecord流生成动态流
、
、
、
、
;import org.apache.
flink
.api.common.serialization.SimpleStringEncoder;import org.apache.
flink
.api.java.utils.ParameterTool;
浏览 69
提问于2020-02-21
得票数 1
回答已采纳
1
回答
如果我没有为
flink
流设置窗口,会发生什么?
、
、
如果我像下面这样写代码,并且没有为
flink
kafka流设置时间窗口,会发生什么?打印间隔是多少? @Override public boolean filter(SuperLog superLog
浏览 0
提问于2018-12-24
得票数 0
1
回答
闪烁keyedStream计数状态
、
、
我已经将
flink
配置为从主题中读取。这些是来自设备的一些警报。private static
FilterFunction
<DeviceState> nodeDownFilter = new
FilterFunction
<DeviceState>() {
浏览 0
提问于2021-10-04
得票数 0
2
回答
在另一个数据流中创建新数据流
、
、
我有两种数据类型。我有一个type1数据流。在stream1内部,我希望创建type2对象,并同时收集type1和type2的对象。或者是否有其他方法从一种类型中收集两种不同类型的数据?
浏览 2
提问于2016-11-29
得票数 0
回答已采纳
1
回答
如何以编程方式将文本写入
Flink
套接字?
、
、
、
请参考下面的代码,了解工作中的消费者DataStream代码:import org.apache.
flink
.streaming.api.datastream.DataStream;import org.apache.<e
浏览 4
提问于2020-05-03
得票数 0
回答已采纳
1
回答
Flink
-如何将JVM选项传递给CLI
、
、
- -Dlog.file=/sicdbgagrv2/
flink
-1.4.0/log/
flink
-root-jobmanager-1-sic-dbg-agrv2.log/
flink
-1.4.0/conf/log4j.properties org.apache.
flink
.runtime.jobmanager.JobManager -- -Dlog.file=/sicdbgagrv2/
浏览 0
提问于2018-03-01
得票数 0
回答已采纳
1
回答
一个对象闪动运算符(例如筛选器)或Apache
Flink
作业中的两个对象
、
、
我有来自不同Apache Kafka主题的4个输入DataStreams (JSON消息)的Apache
Flink
Job,而我只有一个对象XFilterFunction -它做一些过滤。我写了一些数据管道逻辑(用于原始示例): inputDataStream1.filter
浏览 0
提问于2020-09-25
得票数 0
2
回答
如何在
flink
cep中进行子类型()到元组的操作?
、
Tuple3< String, String, String > > begin( "start" ) } ) .next( "4" ).subtype(Tuple.getTupleClass( 2 )).where( new
FilterFunction
extends org.apapche.
fli
浏览 9
提问于2017-01-10
得票数 0
1
回答
在窗口上执行DataStream查询,执行orderBy
、
因此,我正在使用
Flink
SQL模拟一个流任务,并希望在每个窗口上执行一个DataStream查询。sum(days), avg(salary)WHERE age > 25ORDER BY name, age.filter(new
FilterFunction
() ....) \\ where clause .keyby(nameIndex, ageIndex)
浏览 3
提问于2017-06-29
得票数 0
1
回答
如何解决
flink
服务器中的“行时间戳为空”错误
我试图在
flink
服务器上运行一些代码,但无法 DataStream<UserInfo> keyedStream = executionEnvironmentDataStream<Row> userInfoDataStream = tableEnv.toRetractStream(table, Row.class) at org.apache.
浏览 0
提问于2020-12-30
得票数 0
回答已采纳
2
回答
如何在Scala中的Apache中强制转换字符串?
、
、
我目前的代码是:import org.apache.
flink
.api.common.functions{
FilterFunction
, FlatMapFunction, MapFunction} val
浏览 2
提问于2021-02-22
得票数 1
回答已采纳
2
回答
Flink
SQL是否支持Java Map类型?
、
、
我正在尝试使用
Flink
的SQL API从映射中访问键。它失败与错误异常在线程“主”org.apache.
flink
.table.api.TableException:类型是不支持的:任何请告诉我如何可以修复它。String> alertStream = tableEnv.toAppendStream(alerts, String.class); alertStream.filter(new
FilterFunction
at org.apache.
flink
.table.calcite.FlinkT
浏览 34
提问于2017-08-11
得票数 1
1
回答
集成- Apache + Spring
、
e.getMessage()); }RemoveNumber3Filter } 异常: Caused by: org.apache.
flink
.runtime.client.JobExecutionException: Job execution failedat org.apache.
flink
.runtime.jobmanager.JobManager$$anonf
浏览 2
提问于2018-01-04
得票数 8
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Flink基础教程(二):初探Flink
Flink CDC 如何与其他 Flink 特性集成?
Apache Flink 进阶(六):Flink 作业执行深度解析
《从0到1学习Flink》——Apache Flink 介绍
flink handbook-flink数据流编程模型
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
云直播
活动推荐
运营活动
广告
关闭
领券