腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9071)
视频
沙龙
1
回答
rxJava
排序
(
按键
)
任务
执行
java
、
concurrency
、
rx-java
比方说,我对文件A、文件B和文件C进行了更改,并将它们提交以供
执行
。然后,在编写它们的过程中,我对文件A进行了更改并将其发布。例如,有3个线程在运行。一旦
执行
了对A、B和C的第一次更改(写入文件),对A的第一次和第二次更改将几乎同时
执行
。但是,我希望在第一个更改完成后应用第二个更改。 我如何在
rxJava
中做到这一点? 另一点。一种选择是等待所有
任务
完成。 是否有合适的
RxJava
原语/方法有望涵盖这两个用例? 我是
RxJava
的新手,但我希望这是有意义的。在
浏览 22
提问于2019-02-04
得票数 0
1
回答
MapReduce程序中的洗牌步骤是否与映射并行运行?
java
、
scala
、
hadoop
、
apache-spark
、
mapreduce
在
执行
此操作时,我注意到在完成所有映射
任务
之后,减少
任务
几乎立即开始
执行
。现在,这是令人惊讶的,因为那里的减少
任务
与
按键
分组的数据一起工作,这意味着在两者之间有洗牌/
排序
步骤。
按键
和/或
排序
进行映射和分组也能并行进行吗?
浏览 2
提问于2017-04-04
得票数 5
回答已采纳
2
回答
使用Hadoop MapRed进行
排序
sorting
、
hadoop
、
mapreduce
井, 我想知道在
执行
reduce
任务
后如何更改简单WordCount程序的
排序
顺序?我已经制作了另一个按值
排序
而不是
按键
排序
的映射,但它仍然是按升序
排序
的。有没有简单易用的方法(改变
排序
顺序)?!
浏览 1
提问于2012-02-29
得票数 3
回答已采纳
1
回答
Flink streaming:事件是否根据它们的键分别分发到每个
任务
槽?
parallel-processing
、
streaming
、
apache-flink
、
data-stream
例如,如果我有
按键
A
排序
的事件和
按键
B
排序
的事件,并行度为2。是不是所有
按键
A的事件都去一个
任务
槽,而键B的事件都去另一个
任务
槽? 如果我只
按键
A的顺序获取事件,会发生什么情况?它们是否也会分布到两个
任务
槽中。这是否意味着我失去了它们出现的顺序?
浏览 20
提问于2021-11-01
得票数 0
回答已采纳
1
回答
hadoop流是否在map和reduce阶段之间使用稳定的
排序
?
sorting
、
hadoop
、
mergesort
、
stable-sort
例如,如果我们在作业的阶段1中
按键
"a“
排序
,在作业的阶段2中
按键
"b”
排序
(它将阶段1的输出作为stdin),那么当这两个阶段完成时,我们是否可以假设记录是
按键
"b“
排序
的,其次是
按键
"a”
排序
的?还假设reduce
任务
的数量为1或更多。 请记住,答案可能会根据第一阶段的reduce
任务
的数量而有所不同。例如,如果第一阶段的reduce
任务
的数量大于1,则键
浏览 3
提问于2011-12-21
得票数 0
回答已采纳
1
回答
减速器数量和输出顺序
hadoop
、
mapreduce
当我使用函数job.setNumReduceTasks(1);时,我得到
按键
排序
的输出。但是,当我删除此函数时,输出不会
按键
排序
。那么,当我们有多个减速机
任务
时,我们应该期望从减速器得到
排序
输出吗? 谢谢。
浏览 3
提问于2015-12-07
得票数 0
回答已采纳
2
回答
RxJava
:如何仅在最后一个
任务
完成时每5秒
执行
一次
任务
rx-java
、
reactive-programming
、
rx-android
、
reactivex
我在用
RxJava
。我必须每5秒
执行
一次特定的
任务
。通过使用"Observable.Interval“方法,这是非常有效的。但是,我也有以下约束:如果最后一个
任务
没有完成,就不能
执行
新
任务
。在这种情况下,只有在最后一个
任务
完成时才需要
执行
新
任务
。所有的想法都会很感激^^ 感谢您的阅读。
浏览 1
提问于2016-12-10
得票数 11
回答已采纳
1
回答
rxjava
中的后台
任务
队列。
java
、
android
、
rx-java
是否可以使用
rxjava
实现一个后台
任务
队列?我需要在任何时候添加
任务
的可能性,并且只需要同时
执行
一个
任务
。我尝试过PublishSubject,但是当我将
执行
推到新线程observeOn(Schedulers.newThread())时,它会同时启动多个
任务
。更新:可以使用
rxjava
实现类似生产者-消费者模式的东西吗?
浏览 8
提问于2015-07-16
得票数 8
1
回答
用
RxJava
替换Handler.post
android
、
rx-java
、
rx-java2
、
android-handler
这可能是一个简单的答案,但由于我是
RxJava
的新手,所以不太确定。 我有一个对Runnable进行排队的Handler。我想在main/UI线程上
执行
某些
任务
,目前我有以下代码: private val handler = Handler(Looper.getMainLooper())} handler.removeCallbacksAndMessages(null) 我想使用
R
浏览 34
提问于2021-06-17
得票数 0
回答已采纳
1
回答
RxJava
2- Observable.flatMapSingle澄清
rx-java
、
rx-java2
我做了一个
RxJava
2实验,包括以下步骤: 结果:由于异步操作,ListB的项目顺序与ListA不同。
浏览 3
提问于2017-11-08
得票数 10
回答已采纳
2
回答
如何将AsyncTask和AsyncTaskLoader替换为它们的Rx等价物?
android
、
android-asynctask
、
rx-android
、
asynctaskloader
问题所在 --需要取消订阅,尽管它并没有说它需要它。
浏览 2
提问于2017-10-23
得票数 1
3
回答
如何使用
RxJava
执行
具有多个依赖项的异步
任务
java
、
rx-java2
我正在学习
rxjava
,并转换我的一些代码库来了解它是如何工作的。目前,我正试图使用可观察或可完成的方法来完成
执行
任务
(
任务
执行
没有相关的返回值),其依赖关系如下:
任务
: A、B、C、D、E A completes -> execute B B completes ->
浏览 2
提问于2017-06-30
得票数 2
1
回答
改进调用队列方法或
Rxjava
android
、
retrofit
、
rx-java
、
rx-android
而
Rxjava
是: 看来这两个人的方法是一样的。每种方法的优点和缺点是什么?哪一种更适合使用?
浏览 1
提问于2017-09-07
得票数 13
回答已采纳
1
回答
是否可以调用一个Firebase函数获取秘密,
执行
一些代码,然后使用加密数据调用另一个函数?
android
、
security
、
google-cloud-functions
在这种情况下,我需要
执行
一个函数,将数据返回给应用程序,然后
执行
另一个函数,知道之前创建的秘密。 有人能给我指出正确的方向吗?
浏览 3
提问于2021-08-09
得票数 0
1
回答
RxJava
:从订阅()
执行
AsyncTask失败
android
、
android-asynctask
、
reactive-programming
、
rx-java
是因为计时器在异步
任务
运行之前就结束了吗?即OnNext在
任务
之前结束,结束OnComplete上的计时器线程。
浏览 2
提问于2014-04-23
得票数 2
1
回答
RxJava
2-并行化事件以
执行
有副作用的事件
java
、
rx-java2
、
reactive-streams
我希望并行
执行
,而不是在最后聚合事件。我是
RxJava
的新手,正在尝试评估它是否符合我的需求。 我知道如何进行正常的非并行
执行
。但是,我希望将其并行化,并同时
执行
所有
任务
。文档基本上告诉您使用flatMap,这是有意义的,但我无法理解如何运行整个过程。Schedulers.computation()) ) 这就是我需要的,但这当然不会启动Flowable,因为没有订阅它1.我所有的
任务
都是无关的.runOn(
浏览 18
提问于2019-01-06
得票数 0
1
回答
Hadoop洗牌/合并时间:平均和总计
hadoop
、
mapreduce
Hadoop输出以下统计数据:
浏览 4
提问于2015-01-23
得票数 1
1
回答
哪个更快?使用自定义比较器类或lambda函数
lambda
、
java-8
、
comparator
、
treemap
我正在尝试用java创建一个
排序
映射(
按键
的递减顺序
排序
)。我试过了如果我为同一
任务
编写比较器类,会产生任何性能影响吗?
浏览 0
提问于2018-10-16
得票数 3
回答已采纳
1
回答
AsyncTask回调
android
、
unit-testing
、
android-asynctask
、
robolectric
、
powermockito
我想测试在AsyncTask中
执行
的方法。我已经在里面模仿了所有的方法。我拥有的- Robolectric.flushBackgroundThreadScheduler(); 因此,使用“静态”方法创建
任务
时存在问题
浏览 2
提问于2017-02-16
得票数 2
回答已采纳
3
回答
RxJava
和螺栓有什么区别?
android
、
rx-java
、
bolts-framework
我已经对此进行了研究,我知道
RXJava
正在使用可观察的模式,而Bolts则依赖于
执行
器。什么样的框架才能更好地处理需要在序列中完成的
任务
?我听说过使用singleExecutors、队列、链接异步
任务
以及这两个框架。我见过更多的人使用螺栓和
rxjava
,但我很想知道人们在这两者之间的经历。 谢谢!
浏览 3
提问于2016-07-18
得票数 7
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
MapReduce 如何处理数据排序?
使用 Kotlin+Spring Boot 进行后端开发
GitHub 上最受欢迎的 5 大 Java 项目
corda ledger系列教5 观察者模式、订阅-发布模式和响应式编程
MapReduce 五个阶段说明
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券