腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
使用
异步
I
/
O
从
Flink
调用
http
REST
api
apache-flink
、
flink-streaming
在每次
从
流中获取数据时,我都必须
从
flink
流程元素中获取
Rest
API
中的数据,我如何才能做到这一点,我找不到足够的材料来
异步
调用
Rest
服务。请帮我写一些样本文章。
浏览 85
提问于2020-04-28
得票数 0
1
回答
Apache外部
api
调用
apache-flink
、
stream-processing
是否可以在apache代码中
调用
外部
api
(RESTful)。如果有可能的话,那我们该怎么做呢?我从简单的java代码
调用
一个
api
,它运行良好,但是当我在apache中
使用
相同的代码时,它会抛出一个异常: java.io.IOException: Server returned
HTTP
responsecode: 500 for URL:
http
://example.com/someapi
浏览 1
提问于2018-04-27
得票数 2
1
回答
在
Flink
中
使用
异步
I
/
O
调用
分页
HTTP
apache-flink
、
flink-sql
、
flink-batch
我的用例是,我有一个像那样的分页
api
,下面是一个指向下一组记录的指针。
api
将返回一个指向响应中下一组记录的指针,然后我需要
使用
该指针并传入url的下一个参数。我的问题是: ,因为
Flink
中的
异步
I
/
O
提供了一种
使用
HTTP
调用
外部
API
的机制。如何
调用
分页
api
?
使用
批处理/流模式。也需要将下一个指针放在数据库中,以便对
浏览 14
提问于2022-08-31
得票数 0
1
回答
执行
REST
调用
的
Flink
转换(async,Future,Netty)
asynchronous
、
netty
、
apache-flink
我有一个由20台机器组成的集群,它们通过
REST
API
提供“分类”微服务,它们可以提供每秒10k tweet的最大吞吐量,并且它们的延迟是3秒。我猜要从
Flink
使用
这个服务,实现应该是这样的: @map(Tweet tweet) { twc.class
浏览 16
提问于2016-08-07
得票数 2
回答已采纳
1
回答
如何在Apache程序中
调用
rest
rest
、
http
、
apache-flink
我想知道是否有一个解决方案可以
调用
或者我也可以直接
从
我的
flink
程序
调用
REST
?
浏览 3
提问于2020-02-03
得票数 2
1
回答
用于外部数据访问的
异步
I
/
O
BEAM
API
apache-beam
我很想知道用于外部数据访问的Asynchronous
I
/
O
Flink
API
是否也适用于Beam。我找不到任何具体的东西。我知道横梁
使用
Flink
作为执行框架,所以
异步
I
/
O
对横梁也是可能的,但我不确定
API
是否已经定义。
浏览 18
提问于2021-10-06
得票数 0
1
回答
如何
使用
AWS EMR上的Apache
Flink
安全地更新正在运行的作业?
apache-flink
、
amazon-emr
、
flink-streaming
我看到了有关如何
使用
保存点的
Flink
文档。我希望有一个简单的解决方案来更新AWS EMR中的
Flink
作业。https://ci.apache.org/projects/
flink
/
flink
-docs-release-1.9/ops/deployment/aws.html https://ci.apache.org/projects/
flink
/
f
浏览 28
提问于2020-06-11
得票数 1
1
回答
使用
大量内存管理状态-
从
存储中查询
apache-flink
、
flink-streaming
我们正在与
flink
一起进行
异步
IO
调用
。很多时候,IO
调用
是重复的(相同的参数集),我们
调用
的大约80%的
API
对相同的参数返回相同的响应。所以,我们不想再打电话了。我们认为我们可以
使用
状态来存储先前的响应并再次
使用
它们。问题是,尽管我们的响应可以再次
使用
,但此类响应的数量很大,因此需要大量的内存。是否有一种方法可以在需要时将其持久化以驱动和查询?
浏览 7
提问于2020-02-03
得票数 2
回答已采纳
1
回答
HttpWebRequest.BeginGetResponse是否在WP7或SilverLight线程池中
使用
阻塞GetResponse?
silverlight
、
windows-phone-7
、
http
、
rest
、
networking
我正在将
使用
REST
API
的安卓应用程序移植到WP7平台。1)
使用
像
I
/
O
浏览 2
提问于2012-07-29
得票数 0
回答已采纳
1
回答
使用
rest
api
的django应用程序-将代码放在何处
django
、
boto
在查看/保存模型实例时,我需要
使用
第三方
REST
api
。我知道如何做到这一点,但是,我不确定的是,这段代码应该与django应用程序放在哪里。我的直觉是将这段代码放在model类中,但您也可以
使用
视图...我就是不确定。我们将非常感谢您的指导。 干杯
浏览 0
提问于2013-03-20
得票数 2
回答已采纳
1
回答
在
异步
i
/
o
操作符等待响应时,
flink
检查点停止。
asynchronous
、
async-await
、
apache-flink
、
flink-streaming
异步
i
/
o
操作符(1.15.2)正在等待未来的返回(基本上让嵌入式函数完成其处理),直到检查点在这个操作符处停止。只有当它完成后才能继续。附上截图。基本上,我想测试
异步
io正在等待响应的场景&作业被重新启动。因此,理想情况下,最后一个检查点将被恢复&从技术上讲,
异步
i
/
o
处理应该
使用
相同的数据集重新启动。
浏览 18
提问于2022-11-18
得票数 1
1
回答
如何提供Apache
Flink
DataStream
apache-flink
、
flink-streaming
我是Apache
Flink
的新手。我想创建一个DataStream,并将来自另一个系统的值提供给它。我找到了如何添加"SourceFunctions“的例子,在这个函数中,我必须等待来自源的值,并通过
调用
ctx.collect将这些值发布到
Flink
,然后再次等待,这就是轮询。但是我有一个数据源,它在值到达时
调用
函数(
异步
)。所以,我想要做的是:当这个
异步
调用
发生时,我想把值放到一个闪烁DataStream,伪代码: mysystem.connect_to_
浏览 2
提问于2017-11-28
得票数 1
1
回答
如何在基于
REST
的web服务中一次处理数千个请求?
java
、
web-services
、
rest
、
asynchronous
使基于
REST
的web服务(POST)
异步
是一次处理数千个请求的最佳方式吗(请记住,我只有一个服务器实例为请求提供服务)? 编辑: Jersey被错误标记。例如:我有一个基于
rest
的web服务,它应该在很短的时间内(~60秒)被10万个客户端
使用
。我知道,如果允许我部署服务器的多个实例,那么我就可以
使用
负载均衡器来处理所有传入的请求,并相应地委托它们。但我被限制只能
使用
单个实例。在这种限制下,我可以选择什么设计?我可以考虑使请求
异步
(不会立即响应客户端),以便能够让服
浏览 10
提问于2017-01-08
得票数 2
1
回答
什么是非阻塞
Rest
客户端?
rest
、
asynchronous
、
nonblocking
、
jersey-2.0
我已经经历了很多东西来解释非阻塞和
异步
I
/
O
之间的细微差别,但大多数似乎都与服务器端编程有关。这似乎也是有道理的。但是,就
Rest
客户端而言,非阻塞和
异步
I
/
O
之间是否存在相关性?我已经在网上花了很多时间,但恐怕我仍然无法掌握其中的区别,或者更确切地说,无法理解拥有一个非阻塞
Rest
客户端的意义。我更关心泽西的客户。是的,
API
说它支持
异步
客户端,并且可以
使用
Future.isD
浏览 2
提问于2014-09-03
得票数 4
2
回答
如何
使用
从
on_read处理程序发出的最后回调将响应
异步
返回给
调用
方?
c++
、
boost
、
boost-asio
、
boost-beast
我需要为c++客户端公开一个
异步
REST
,在内部
使用
boost::beast来发送
REST
请求/接收响应。 起点是
http
_client_async.cpp示例。现在,客户机将
使用
这个
异步
api
传递一个回调函数,这个函数需要在
REST
操作结束时
从
on_read() handlerhttp_client_async.cpp
调用
,将完整的响应传递给
调用
方。
浏览 5
提问于2020-06-03
得票数 1
回答已采纳
2
回答
无法
使用
java
rest
客户端上传
Flink
1.5中的jar
apache-flink
、
flink-streaming
在
使用
java
REST
客户端将jar上传到
Flink
1.5.0服务器时,我们得到了错误响应{“error”:“Internal server error: null"}。同样的代码在
Flink
1.4.2中也能正常工作。事实上,我们可以看到jar是
从
Flink
GUI上传的。但是错误的状态中断逻辑。有什么建议吗?- Unhandled exception org.apache.
flink
.shaded.netty4.io.netty.handler.cod
浏览 172
提问于2018-06-01
得票数 1
回答已采纳
1
回答
在Java中播放框架
异步
处理和阻塞
I
/
O
java
、
multithreading
、
asynchronous
、
playframework-2.0
我的应用程序
使用
Play框架来处理
REST
请求。我需要在
http
请求处理程序中执行一些可能持久的阻塞
I
/
O
操作。同时,我想有效地处理一些短期持久的请求。 Play框架
使用
相同的默认线程池,其中执行所有应用程序代码。至少在Java中,不可能在不同线程池上运行
异步
工作。因此,我的问题是,考虑到这样的操作
使用
相同的线程池,
异步
运行潜在的阻塞
I
浏览 3
提问于2014-03-20
得票数 14
回答已采纳
1
回答
当谈到
Flink
异步
IO时,什么是“容量”参数?
apache-flink
在
使用
Flink
AsyncDataStream#unorderedWait时,有一个名为“容量”的参数,引用
flink
官方文档的话说, 容量:这个参数定义了同时进行的
异步
请求的数量。尽管
异步
I
/
O
方法通常会带来更好的吞吐量,但操作员仍然是流应用程序的瓶颈。限制并发请求的数量可以确保操作员不会积累越来越多的待定请求,但是一旦容量耗尽,它将触发反向压力。假设我的玩具
flink
应用程序消耗了一个kafka,对于每一个kafka消息,它都会发出一个
浏览 3
提问于2020-12-21
得票数 5
回答已采纳
1
回答
如何在提交作业前获取
Flink
任务管理器编号?
apache-flink
、
flink-streaming
我通过以下方式启动了
Flink
数据流作业 val env = StreamExecutionEnvironment.getExecutionEnvironment env.setParallelism
浏览 32
提问于2021-06-17
得票数 0
回答已采纳
1
回答
带
Flink
和Scala的neo4j
scala
、
neo4j
、
apache-flink
我正在
使用
Scala2.11.7和
Flink
1.3.2处理数据。现在,我想将生成的org.apache.
flink
.
api
.scala.DataSet存储在neo4j图形数据库中。有一些Github项目是为了兼容性: (顺便说一句:为什么
浏览 1
提问于2017-08-31
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
聊聊非阻塞I/O编程
目前最受欢迎的12个Python开源框架,你用过几个?
java 中的 BIO/NIO/AIO 详解
一文详解:企业数字化的未来基石——微服务
Redis常用连接池
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券