腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(22)
视频
沙龙
1
回答
RichAsyncFunction
中的Apache flink超时处理
、
、
2- AsyncFunction接口中没有方法超时:)我使用的是AsyncDataStream.unorderedWait,它使用kafka并用
RichAsyncFunction
事实上,所有消息都已读取(正确的偏移量已提交给zookeeper),但并非所有消息都到达
RichAsyncFunction
.asyncInvoke。
浏览 0
提问于2018-07-05
得票数 0
1
回答
使用Flink向Cassandra写入记录的不同方法的差异
、
我正在寻找RichSinkFunction、
RichAsyncFunction
、AsyncIO和CassandraSink在使用Flink在Cassandra DB中编写记录faster/multithreaded因为它打开和关闭连接,所以once.
RichAsyncFunction
-实现与RichSinkFunction一样。它最初在Sync模式下工作。我可以将executorService用于多线程目的。此外,根据其中一个这样的答案,我们可以使用executorService和
RichAsyncFunction
一样创建单独的线
浏览 5
提问于2022-01-12
得票数 0
回答已采纳
1
回答
我可以用
RichAsyncFunction
编写同步代码吗
、
,我可以使用
RichAsyncFunction
。我写了下面的代码片段: public class SendGGSheetFunction extends
RichAsyncFunction
<Obj, String> { @Override
浏览 38
提问于2020-10-06
得票数 1
回答已采纳
1
回答
flink接收器只支持生物吗?
、
、
、
接收器的invoke方法似乎没有办法做异步?例如返回Future我知道flink有异步api,但它似乎不适用于接收器impl?
浏览 6
提问于2017-12-08
得票数 2
回答已采纳
1
回答
AsyncFunction在KeyedStream上工作吗?
我没找到,所以我在问!是否有在AsyncFunction s上应用KeyedStream?如果是的话,它会保留每把钥匙的订单吗?
浏览 2
提问于2017-12-09
得票数 2
回答已采纳
1
回答
Apache :使用外部/阻塞调用的数据丰富流
、
在我的应用程序中,我想丰富无限的事件流。流本身是通过散列Id来并行化的。对于每个事件,可能都会调用外部源(例如REST、DB)。这一呼吁由于自然而受阻。必须维护一个流分区内事件的顺序。理论上,这是可行的,但我觉得这样做不好,因为我不知道如果流中有一些阻塞操作,Flink是如何反应的。如果有很多并行流阻塞,即我是否用完线程,会发生什么情况?或者,在流被并行化的地方,行为流是如何向上的? 有没有其他人可能有类似的问题,回答我的问题或一些想法,如何
浏览 1
提问于2016-06-16
得票数 5
回答已采纳
1
回答
用Postgres实现Spring + Apache项目
、
、
、
、
我有一个使用apache处理数据传输信号的SpringBoot gradle项目。当一个新信号通过datastream传入时,我想查询查找(即findById() )--它使用已经创建的postgres数据库表中的ID来查询详细信息,以便获取有关信号的其他信息并丰富数据。我希望避免使用spring依赖项来执行查找(即自动存储库),并希望继续使用flink实现进行查找。 我可以在哪里指定如何添加postgres连接配置信息,如端口、数据库、url、用户名、密码等。(为了简单起见,可以假定postgres db在我的计算机中是本地的)。是否就像将配置添加到application.propertie
浏览 4
提问于2020-05-26
得票数 0
回答已采纳
1
回答
是否有一种方法只将过滤过的事件从Apache流传递到AsyncDataStream/AsyncIO流?
AsyncDataStream.orderedWait(stringInputStream, lookupCodesInDB(), 3000, TimeUnit.MILLISECONDS, 100); return new
RichAsyncFunction
<String, JsonObject>() {
浏览 1
提问于2019-04-29
得票数 0
回答已采纳
1
回答
集成测试flink作业
、
它是一个
RichAsyncFunction
,在open方法中,我构造了一个用于丰富的http客户端。 现在我想为我的工作写一个集成测试。
浏览 28
提问于2020-06-01
得票数 2
1
回答
使用异步I/O从Flink调用http REST api
、
在每次从流中获取数据时,我都必须从flink流程元素中获取Rest API中的数据,我如何才能做到这一点,我找不到足够的材料来异步调用Rest服务。请帮我写一些样本文章。
浏览 85
提问于2020-04-28
得票数 0
1
回答
如何在Apache Flink ui中显示指标?
、
我也在我的
RichAsyncFunction
里做了 UI的文档中并不清楚,我们是否需要在Flink服务器上启用某些功能?
浏览 32
提问于2019-05-04
得票数 1
1
回答
Apache :检查点--在延迟后分派元素的操作符
、
class MessageDelayFunction[T](schedulingDelay: Int, timeUnit: TimeUnit) extends
RichAsyncFunction
[T
浏览 5
提问于2021-12-22
得票数 0
回答已采纳
1
回答
显示Apache计数器值,但未显示仪表值
、
public class AsyncClass extends
RichAsyncFunction
<String, String> { private transient Counter counter
浏览 3
提问于2020-01-16
得票数 1
回答已采纳
1
回答
DataSet --从Cassandra获取数据作为通用ResultSet,并将其转换为Flink
、
我尝试使用以下代码异步处理此查询:private static final Logger logger
浏览 8
提问于2017-12-21
得票数 0
1
回答
在Flink中使用异步I/O调用分页HTTP
、
、
我的用例是,我有一个像那样的分页api,下面是一个指向下一组记录的指针。api将返回一个指向响应中下一组记录的指针,然后我需要使用该指针并传入url的下一个参数。,因为Flink中的异步I/O提供了一种使用HTTP调用外部API的机制。如何调用分页api?使用批处理/流模式。也需要将下一个指针放在数据库中,以便对我处理的内容进行审计跟踪。。有人知道怎么做吗?问候
浏览 14
提问于2022-08-31
得票数 0
1
回答
链接AsyncDataStream如何传递和使用配置参数
、
CustomAsyncConnector中的代码就像您在其核心发现的每个示例一样: public class CustomAsyncConnector extends
RichAsyncFunction
浏览 1
提问于2017-05-02
得票数 1
回答已采纳
3
回答
Apache Flink -异步刷新Hashmap
、
我正在使用Scala API开发一个Apache Flink应用程序(我是一个使用这项技术的新手)。 我正在使用hashmap来存储来自数据库的一些值,并且我需要每隔一小时刷新这些值。有没有办法异步刷新这个hashmap? 谢谢!
浏览 25
提问于2019-03-01
得票数 0
1
回答
Apache Flink
RichAsyncFunction
open()是在初始化调用时调用一次,还是在每个函数调用时调用一次?
open()函数是在初始化时执行一次,还是在每次执行丰富函数时执行? 所以,如果我们想要执行一个繁重的操作,比如创建一个数据库DataSource,我们可以在那里执行,而且不会在每次调用时都被初始化?
浏览 164
提问于2019-04-30
得票数 1
回答已采纳
1
回答
从Cassandra读取数据,以便在Flink中进行处理
、
、
我必须使用Flink作为流引擎来处理Kafka的数据流。为了对数据进行分析,我需要查询Cassandra中的一些表。做这件事最好的方法是什么?我一直在Scala中寻找此类案例的示例。但是我找不到any.How,可以使用Scala作为编程语言在Flink中读取来自Cassandra的数据吗?还有另一个问题。答案中提到了多种方法。我想知道在我的情况下,什么是最好的方法。而且,大多数可用的示例都是用Java编写的。我正在寻找Scala示例。
浏览 2
提问于2017-03-28
得票数 4
2
回答
如何使用bazel使用/导入Flink的TestHarness类?
、
、
、
、
/external/maven/BUILD file我想使用Bazel构建工具测试我自己的异步flink流操作符
RichAsyncFunction
。
浏览 0
提问于2020-05-09
得票数 1
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Streaming SQL在贝壳的演进之路
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
云直播
活动推荐
运营活动
广告
关闭
领券