RxJava -在groupBy之后映射不同的函数

文章/答案/技术大牛

发布

0回答

java、functional-programming、rx-java、reactive-programming、rx-java2

假设我有一个发出整数的可观察对象。我想对所有的奇数加1，对所有的偶数减1。使用RxJava实现这一点的一种干净的方法是什么？我正在努力理解如何使用groupBy来实现这一点，因为我看不到一种干净的方法来在groupBy之后重新获得odd和even可观察性，然后将不同的函数映射到它们中的每一个(也许在之后将它们

浏览 3提问于2018-07-16得票数 0

回答已采纳

1回答

将groupBy和toList rxjava函数与sqlbrite一起使用

android、android-sqlite、rx-java、sqlbrite

当我使用sqlbrite时，在使用groupBy()之后不能使用rxjava函数toList()。下面是我的代码：query.flatMap(q -> {}). groupBy(item ->

浏览 0提问于2015-10-20得票数 3

2回答

如何加速groupby.filter()操作？

python、pandas、pandas-groupby

我有以下带有groupby函数的代码 lambda x: x["BOX_ID"].nunique()> 1但是滤波器的功能非常慢。我想使用转换或映射函数。但是，变换函数和映射函数的结果都不同于滤波函数。我对为什么

浏览 4提问于2020-12-08得票数 3

回答已采纳

4回答

Scala GroupBy保持插入顺序？

scala、collections、map、hashmap

列表、地图等中的groupBy方法在函数之后生成一个地图。提前谢谢。

浏览 0提问于2012-03-07得票数 31

回答已采纳

2回答

RxJava和在集合中保存数据

multithreading、asynchronous、rx-java、reactive-programming

在使用rxjava进行了一些编码之后，我仍然不能理解当我想要一些操作来保存集合中的一些数据(假设是键值的映射)时，我应该做什么，这会让你以一种完全不同的方式思考。例如，假设我想发出一些对某个api的put调用，并将所有失败的调用响应保存在一个映射中，以便以后进行一些“错误纠正”。到现在为止，看起来我需要从上到下编写整个流程来完成这个请求，->错误和纠正，这是一个操作管道，我想将发生在不

浏览 0提问于2017-12-18得票数 0

2回答

在groupBy之后使用映射的Scala

scala、map、group-by

，而值是居住在那个城市的人的平均年龄。我使用了groupBy方法：这给了我这个我如何重新映射它来过滤我所需要的信息，即按城市划分的</

浏览 5提问于2014-12-11得票数 0

回答已采纳

2回答

春季引导rest应用程序中的RxJava自定义异常处理/传播

java、spring、rest、rx-java

我想知道RxJava和spring最好的地方是什么？private Single<Customer> findCustomerById(long customerId) { return Single.fromCallableCust

浏览 2提问于2017-07-31得票数 0

3回答

我是熊猫的新手，因此请耐心地对待这个问题。我有一个Df，它包含了多年和许多州收集的年份、州和种群数据。我想要找出任何年份的最大pop和相应的状态1995 Alabama xx; 1196 New York yy; 1997 Utah zz 我做了一个groupby，得到了一年内所有州的人口；我如何迭代所有年份的人口state_yearwise = df.groupby(["Year", "State"])["Pop"]

浏览 0提问于2017-09-16得票数 1

1回答

如何将RX.Observable转换为IO.reactivex.Observable

rx-java、rx-java2

我使用rxjava jdbc库查询数据库，但使用rx1支持的库。io.reactivex.Observable.fromIterable(BlockingObservable.from(rx1).toIterable()); 但是它不工作，我能得到RX Java2的等效代码吗我的意思是我想返回io.reactivex.Observable<T>而不是rx.Observable<T>。谢谢你的帮助。

浏览 70提问于2020-06-27得票数 0

回答已采纳

2回答

在groupby之后在多列中应用不同的函数

r、dataframe、dplyr、aggregate

我很难将head(1)应用于一列，将聚合应用到另一列，逻辑表达式应用到另一列，在groupby之后。我有一个这样的dataframe df：在每个组中返回dista

浏览 0提问于2018-08-01得票数 4

回答已采纳

2回答

如何在Java中避免回调地狱？

java

比如javascript中的TwoStep或q。

浏览 1提问于2015-03-30得票数 11

1回答

分组观测值的flatMap和flatMap single

rx-java、rx-java3

我是RxJava的新手，正在尝试理解它。Observable.just( new Employee(123, "Bill", 194_000, 6.7)); obs.groupBy(e -> e.getRating()) .subscribe(

浏览 7提问于2021-07-01得票数 1

1回答

在groupby函数之后合并两个大小不同的数据

python、pandas、dataframe

我试图通过过滤数据将这个组和原始的dataframe联系起来。在做了groupby之后，我丢失了原始dataframe中的一些列。其想法是将其与各自的州和城市价值观联系起来。我只想要原始dataframe与包含9行的最终dataframe的接口。15 |CEMBC_0003 |CE |FOR |170 |2 |4 |在小组讨论

浏览 1提问于2021-06-03得票数 2

回答已采纳

2回答

项目反应器(或RxJava2)的执行器序列调用

java、functional-programming、rx-java2、project-reactor

我有以下任务，我想通过使用Project Reactor (或RxJava)来解决它。这是事件的来源。每个事件都由serviceId和一些有效负载组成。收到事件后，我们需要使用有效负载对指定的serviceId执行操作。但我们应该确保到同一serviceId的两个请求之间的时间间隔必须大于或等于一秒。但是对不同服务的请求可以并行执行。另外，我们应该注意到服务的数量是动态的。

浏览 3提问于2018-11-28得票数 1

4回答

Underscore.js在对象数组中查找唯一值；返回唯一项及其计数

javascript、underscore.js、unique

我使用_underscore.js来查找数组中的所有唯一项，但我不知道如何获得返回的唯一项的数量。map(function(person) { return person.age }).uniq().value();[7,9,2] 我真正需要的是如果是愚蠢的，慢慢来，告诉我，因为我愿意接受其他的解决方案。

浏览 5提问于2013-10-09得票数 28

回答已采纳

1回答

groupby后用于聚合的列组合

python、pandas、aggregate、pandas-groupby

).aggregate(combination(columnA, columnB))df['combination'] = combination(columnA, columnB)唯一的要求是列的组合是在groupby之后计算的。描述我看起来很自然，从逻辑上讲，在某些情况下，我会先进行分组

浏览 5提问于2020-02-02得票数 1

回答已采纳

1回答

RxJava从Observable<JsonArray>返回JsonArray

java、rx-java、observable、vert.x、reactivex

我是函数式编程和反应式RxJava的新手。我想从数据库中获取设备的id和名称，并将其存储在地图中，我在RxJava样式中做到了这一点。我正在调用一个不需要返回任何内容的函数然后这个函数看起来像； private void updateDeviceNameMap我可以通过Observable.from(ObjectName)将任何

浏览 17提问于2018-02-01得票数 0

2回答

使用Rxjava和Retrofit

android、retrofit、rx-java

我用的是Rxjava和Retrofit。我知道如何使用它，但我仍然不清楚“Rxjava对Retrofit到底做了什么”。我们对REST调用使用任何转换器(如Gson)和Okhttp库进行改造，一旦得到响应，它就具有可观察的类型(如果使用Rxjava，否则它将是调用类型)。现在的问题是，如果我们已经得到响应，那么Rxjava究竟是如何处理这个响应的呢？首先，如果我对Rxjava的理解是错误的，请告诉我

浏览 0提问于2017-09-11得票数 0

回答已采纳

1回答

rxkotlin和LiveData有什么区别？

android、kotlin、android-livedata、rx-kotlin

我正在学习Rx，我不明白两者之间的区别。你能简单解释一下吗？

浏览 7提问于2022-05-08得票数 1

1回答

如何使用Retrofit2、RxJava2、Gson TypeAdapterFActory正确映射Gson？

android、android-studio、gson

我目前使用的是Retrofit2、RxJava2、Retrofit2 RxJava2适配器、RxAndroid。首先，我是否应该使用TypeAdapterFactory而不是JsonSerializer来反序列化和序列化我的Gson (我听说前者比后者快)？我的Gson有一个非常复杂的结构：首先，正如我所提到的，我计划使用TypeAdapterFactory。这是映射我的Gson的所有不同情况<

浏览 14提问于2017-12-31得票数 0

点击加载更多