腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何
根据
流
中
的
元素
动态
划分
连续
的
RXJava
流
?
、
、
最简单
的
示例是如下所示
的
字符串流: ["3", "a", "b", "c", "1", "a", "2", "a", "b"] 是数字
的
数字描述了它
的
组应该包含多少
元素
。非常重要
的
是,
流
是
连续
的
,所以我们不能只等待下一个数字来拆分流。据我所知,
RXJ
浏览 21
提问于2019-04-06
得票数 2
回答已采纳
2
回答
如何
用
RxJava
以特定
的
方式合并两个观察值?
、
我是
RxJava
的
新手,遇到了下一个问题:我有两个
流
:Stream 2: -▲-▲-▲-▲-▲-▲-▲-▲-▲-▲-▲->Stream 3: -●-●-▲-●-●-▲-●-●-▲-●-●-▲-> 这意味着我们有来自S1
的
两个
元素
和来自S2
的
元素
,来自S1
的
两个
浏览 0
提问于2015-10-21
得票数 1
1
回答
火花
流
DStream
元素
与RDD
、
、
、
我正在使用Spark
的
流
API,我只是想更好地了解
如何
最好地设计代码。我目前正在使用pyspark.streaming.kafka.createDirectStream的卡夫卡消费者(用火药厂) 火花
流
提供了一种称为离散
流
或DStream
的
高级抽象,它表示
连续
的
数据
流
DStreams可以从卡夫卡、弗卢姆和
动态
等源
的
输入数据
流
中
创建,也可以
浏览 4
提问于2016-02-29
得票数 0
1
回答
如何
使用
RxJava
将另一个
流
的
元素
属性作为标准来筛选一个可观察
的
流
?
、
、
我正在使用两个数据结构平坦
的
存储库,例如。"MenuItemRepo“和"IngredientRepo”它们之间
的
关系结构是:一个MenuItem可以包含多个成分,而一个单独
的
成分(例如。我可以使用
RxJava
只从MenuItem
流
中选择MenuItem
元素
,其中它们
的
MenuItem id与MenuItem-配料引用
流
中
的
特定成分id相匹配。我使用.filter()运算符在一个可流动
的<
浏览 3
提问于2018-01-19
得票数 1
回答已采纳
2
回答
在Corda流程测试
中
,
如何
获得只分配给相关方
的
模块化cordapp?
、
、
、
、
根据
Corda编码指南,我已经将模块
划分
为契约和工作
流
--这是常见
的
。有一些工作
流
模块,比如工作
流
-Pary1,工作
流
-第2部分,等等。现在,我只想将这些工作
流
提供给
流
测试
中
的
特定节点。
如何
做到这一点?
浏览 0
提问于2019-10-04
得票数 0
回答已采纳
1
回答
球拍方案-从
流
中
删除重复
的
连续
字符
、
、
我正在尝试实现一个函数,该函数递归地从给定
流
中
删除所有额外
的
空间。任何
连续
的
空格都应该被删除,允许在单词之间有一个最大
的
空格。我想不出
如何
正确地实现这一点。我尝试过将流转换为列表并以这种方式操作它,但我根本不知道
如何
构造一个新
的
流
并
根据
我对每个
元素
提供
的
测试来返回它。我试图使用
流
映射,但在这种情况下,它似乎不适合我(移除
元素
,构
浏览 0
提问于2016-12-04
得票数 2
回答已采纳
1
回答
有Flow版本
的
flatMapIterable吗?
、
、
现在,我正在努力逐个映射api返回
的
列表
中
的
元素
。有没有像
RxJava
的
flatMapIterable这样
的
运算符?例如,当
流
有一个ArrayList<T>时,我希望对该列表
中
的
每个
元素
进行操作,并将其作为新
的
流
获取。
浏览 16
提问于2020-03-22
得票数 3
回答已采纳
1
回答
任意位置
的
串接
流
、
还有一个关于
RxJava
的
问题。我这周着火了。我有一个Model对象
流
,我将其转换为ViewModel对象
流
。一切都很直接--我只是使用map操作符,它工作得很好。然而,我有一个要求--有时我需要在满足给定标准
的
元素
之后添加假ViewModel。:我看了concatMap操作符--它允许我用更多
的
<em
浏览 1
提问于2015-09-16
得票数 0
1
回答
Python
中
的
SICP“
流
作为信号”
、
、
我已经找到了一些在Python
中
实现类似于SICP
的
流
的
好例子(,)。但是,我仍然不知道
如何
处理像SICP3.5.3“integral”
中
的
一个例子。(add-streams (scale-stream integrand dt) int) 这个问题
的
棘手之处在于返回
的
流
int是
根据
自身定义
的
(也就是说,
浏览 2
提问于2015-10-02
得票数 3
回答已采纳
2
回答
为什么<hr>、<br>和<em>
元素
属于html
中
的
流
内容?
、
在一节
中
,他们说: 另外,我也很困惑到底什么是
流
内容?我一直在阅读这方面的内容,例如,短语和
流
内容之间
浏览 10
提问于2016-10-25
得票数 5
回答已采纳
1
回答
为两个输入流分配时间戳和水印,稍后连接为使用“EventTime”进行
动态
警报
、
、
我有一个Flink程序,它接受两个
流
,即数据/传感器读数
流
和警报规则
流
。我正在广播规则
流
,并将其连接到数据
流
以生成
动态
警报。在ProcessingTime
中
,一切都很好,但是没有任何东西可以使用EventTime。我已将时间戳&水印分配给数据
流
,并按原样传递规则
流
(因为只有在看到新
的
附加规则/更新时,规则
流
才会有记录)。当两个
流
,即一个具有时间戳和水印<
浏览 0
提问于2019-08-21
得票数 2
回答已采纳
3
回答
基于oracle表
中
状态列
的
触发Informatica工作
流
我想在不使用pl/sql过程或触发器
的
情况下实现以下场景 <
浏览 4
提问于2014-11-07
得票数 0
0
回答
Spark结构化流媒体
、
、
如何
在Kafka stream上实现从单个作业执行多个
流
SQL查询。结构化流媒体是一种可靠
的
前进方式。例如,我在一个作业
中
对一个
流
运行10个查询。假设我只想运行9个查询,是否有一种方法可以
动态
地更改要在每次运行时从存储运行
的
查询。我希望每次执行
流
查询时,都从存储
中
动态
挑选查询,即
连续
查询。
浏览 10
提问于2016-12-20
得票数 1
3
回答
RxJava
vs Java8并行
流
、
、
、
它们之间有什么相似之处和不同之处,看起来Java并行
流
有一些
RXJava
中
可用
的
元素
,对吗?
浏览 0
提问于2014-04-24
得票数 26
2
回答
基于光
流
的
分割
、
、
、
您好,我想分割基于光
流
()
的
视频序列
中
的
对象,我正在使用opencv,并且已经能够使用函数生成两个
连续
帧
的
流
场。有人能解释一下我
如何
根据
这个
流
场来分割图像吗?
浏览 3
提问于2013-03-14
得票数 3
1
回答
aws绿草流管理器可以从服务器触发吗?
、
、
、
、
我试图找出一个解决方案,当用户触发时,没有静态ip
的
边缘设备(raspberry pi)应该将视频流流到
动态
流
。我
的
方法是主机(可以从边缘设备访问)--一个接受用户输入并存储状态
的
快捷键,边缘设备不断检查是否有用户输入,并将按照快速as存储
的
阶段发送视频
流
。AWS已经有了一个IoT流管理器,它可以将数据发送到
动态
流
,我需要知道
的
是,是否可以
根据
用户请求打开/关闭这个流管理器,用户将通过发送
浏览 15
提问于2022-09-27
得票数 0
1
回答
Java8StreamScreen不起作用
、
、
这就是我要做
的
: .sorteddistinct() .collect(Collectors.toList()); 我期待一个排序
的
列表没有任何重复我重写了hashCode和equals方法,我还注意到这些方法每次都返回正确
的
值。有人能看到我
的<
浏览 3
提问于2017-09-12
得票数 9
回答已采纳
1
回答
将不确定
流
的
长度传递给WCF服务
、
、
有没有办法将不确定
流
的
长度传递给WCF服务? 背景由于WCF
流
只允许消息
中
的
一个
流
,所以我决定将所有流连接到一个
流
中
,并将其
划分
为服务器代码。
流
客户端提供
的
流
将包含各种类型
的
浏览 7
提问于2016-05-16
得票数 0
回答已采纳
1
回答
如何
处理-dynamic- videostream并在该videostream中找到“匹配”
的
(相对)位置?
、
、
正如问题所述:
如何
处理一些
动态
的
视频
流
?我说
的
动态
,实际上是指我只想处理我屏幕上
的
东西。因此,imagearray应该是某种“
连续
截图”。 我想
根据
特定
的
模式处理视频/图像。我该怎么做呢?我需要能够使用匹配(或部分匹配)
的
位置。我想,针对不同需求
的
.NET组件也可能很有用……
浏览 3
提问于2009-12-19
得票数 0
回答已采纳
3
回答
如何
在安卓体系结构组件中使用
RxJava
而不是LiveData?
、
、
注意:如果您已经在使用像
RxJava
或Agera这样
的
库,您可以继续使用它们而不是LiveData。但是,当您使用它们或其他方法时,请确保正确地处理生命周期,以便当相关
的
LifecycleOwner停止时,数据
流
暂停,而当LifecycleOwner被销毁时,数据
流
被销毁。您还可以添加android.arch.lifecycle:reactivestreams工件,以便将LiveData与另一个反应性
流
库(例如,
RxJava
2)一起使用。上面的声明是从android p
浏览 0
提问于2018-05-11
得票数 2
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
在8102年的今天,你清楚Spring 5.0的WebFlux吗?
学习笔记1:数据库—流数据分析与处理
Java8流的简单梳理
Flink实现高效实时处理百万级数据:实践与优化
Flink:动态表上的连续查询
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券