腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
为什么
使用
Java
流
API
收集器
的
管道
分组
需要
更多
时间
?
java
、
performance
、
java-8
、
java-stream
我正在
使用
Stream
API
从列表创建Map of Map。列表包含1000万条记录。我已经用两个'groupingBy‘操作用一条语句做到了这一点,如下所示。问题是,这一行语句几乎
需要
1.5分钟才能执行,这成为了我
的
性能关键型应用程序
的
执行瓶颈。我已经给出了我在下面
使用
并行
流
API
尝试
的
代码 Map<MyKey, Map<String, List<Person>>> personMap
浏览 18
提问于2019-06-13
得票数 2
2
回答
Java
8 GroupingBy进入Peek
java
、
java-8
、
java-stream
最近,我了解了
Java
8中
的
流
,并开始
使用
它们。现在我有一个关于groupingBy
收集器
方法
的
问题:这个查询
的
结果是一个Map<String, Long>
浏览 3
提问于2017-01-09
得票数 9
回答已采纳
3
回答
OutOfMemoryException :从服务器加载大量图像
android
、
out-of-memory
我正在开发一个从Server下载映像
的
应用程序.我创建了用于显示图像
的
GridView,它正在成功地工作.但问题是,当图像数量增加时,由于堆内存
的
增加,它抛出一个OutOfMemoryException .这是我
的
JSO
浏览 3
提问于2014-08-01
得票数 1
回答已采纳
1
回答
用嵌套列表进行
分组
和和
java
、
java-8
、
java-stream
、
grouping
我有嵌套列表,我正在尝试
使用
java
流
和
收集器
来
分组
和求和以获得所需
的
结果。有了这个,我无法在多个SubAccounts上循环。要么我必须
使用
for循环,要么
使用
其他逻辑。我想要实现
使用
streams
api
。有可能吗?List<Assets> list; Long assetId;} 我正试图在
浏览 0
提问于2019-03-25
得票数 6
回答已采纳
1
回答
TPL数据
流
数据回收
c#
、
task-parallel-library
、
tpl-dataflow
、
recycle
我正在开发一个音频处理工具,我想
使用
TPL数据
流
构建它。数据
流
本身将由声音处理块之间传递
的
音频样本组成。这些样本通常只有几Kb大小(float[]/byte[]具有1k到4k元素)。因此,数据
流
是一个简单
的
管道
,如下所示: -> TransformBlock<byte[], float[]> -> TransformBlock有些块可以完全“就位”,即通过修
浏览 2
提问于2014-12-08
得票数 1
回答已采纳
1
回答
Java
收集器
:将对象列表
分组
为具有计算值
的
其他对象列表
java
、
java-8
、
java-stream
、
collectors
我最近接触到了
Java
8和它
的
stream,以及最近它
的
收集器
API
,我看到它有可能完成许多要
流
的
转换,但是我有一种情况,我不确定
java
8是否可能,甚至可能。{ public String joinedDescriptions我想知道是否可以从ClassA对象列表中生成一个ClassB对象
的
分组
列表最后,joinedDescriptions是来
浏览 0
提问于2018-12-09
得票数 1
回答已采纳
2
回答
是否可以在不关闭
流
的
情况下对元素进行
分组
?
java
、
java-8
、
java-stream
有没有可能对Stream中
的
元素进行
分组
,然后继续流式传输,而不必从返回
的
映射
的
EntrySet创建新
的
流
?with date, lastName, avgAge, numPersons });它工作得很好,但是看起来有点笨拙,特别是流到一个map中,然后立即流到该map
的
条目集上有没有一种方法可以在
流
中对对象进行
分组
,而不是继续流式传输?
浏览 1
提问于2017-06-23
得票数 1
1
回答
如何
使用
BigQuery存储读取
API
定义Apache Beam中
的
最大流数
google-cloud-platform
、
google-bigquery
、
google-cloud-dataflow
、
apache-beam
为此,我想
使用
Apache光束,并在数据
流
中运行此
管道
。而且我
的
BQ查询
需要
很长
时间
才能执行。因此,希望
使用
BigQuery
的
Storage Read
API
来减少这一
时间
,该
API
支持
使用
流
读取数据。尽管Beam支持
使用
存储
API
,但我找不到设置最大流数
的
文档。谁能帮助我如何设置从BigQuery读取数据<e
浏览 25
提问于2021-05-02
得票数 0
3
回答
Java
8StreamsAPI在GroupingBy中具有等价
的
子句?
java
、
java-8
、
stream
我在Streams
API
中遇到了一个很难解决
的
问题。嗯,据我所知,这个问题是可以解决
的
,但在一个电话里就不能很好地解决。下面,以FeatureContentWeight对象
流
为例,我希望按 Feature 和 Content 进行
分组
,并获得每个特性和内容
的
最大权重。由于我不
需要
维护一个Map,所以我在最后从Map中得到了值。问题是,我只希望中有超过3项
的
组。因此,我想要功能
的
每个特性和内容
的
最大权重,超过给定计数
浏览 3
提问于2014-11-05
得票数 7
回答已采纳
1
回答
Azure Data Factory -手动触发器执行
时间
debugging
、
triggers
、
azure-data-factory
、
execution-time
我一直在检查ADF提供
的
一些结果。我是这个工具
的
新手,我想
更多
地了解在
使用
触发器或调试选项运行ETL后看到
的
执行
时间
。 ? 我
的
问题是,
为什么
在过程结束时会有差异?Debug几乎是另一个
的
25%。当我执行一个带有触发器选项
的
ETL时,与调试相比,这会增加处理
时间
。
浏览 21
提问于2020-06-18
得票数 1
回答已采纳
2
回答
Collectors.toConcurrentMap和通过ConcurrentHashMap供应商选项将地图转换为ConcurrentHashMap之间有什么区别?
java
、
java-8
、
java-stream
、
concurrenthashmap
、
collectors
我想通过
Java
8 Map和Collector接口将一个Stream转换为ConcurrentHashMap,我可以
使用
两个选项。p -> p.age, 哪个是更好
的
选择我应该什么时候
使用
每一种选择?
浏览 2
提问于2016-11-30
得票数 9
回答已采纳
1
回答
以结构化方式组合多个
java
流
java
、
java-stream
、
collectors
我想
使用
Java
的
流
API
对一个对象列表进行一些计算:Item类包含许多属性。对于其中
的
一些,我
需要
取集合中所有项
的
平均值,对于其他属性,我
需要
进行其他形式
的
计算。为了实现这一点,我一直在执行单独
的
流
/
收集器
调用,尽管我没有遇到任何性能问题(因为列表大小通常大约为100),但我想学习如何变得更简
浏览 0
提问于2018-04-24
得票数 7
回答已采纳
1
回答
如何改进数据流流水线中
的
低吞吐量群密钥
group-by
、
google-cloud-dataflow
、
apache-beam
、
key-value
我有一个apache批处理
管道
(用
java
编写),用于将bigquery中
的
原始分析数据转换为聚合形式。会话记录(现在可能在接下来
的
几天内扩展到页面事件)和一组新
的
页面事件从bigquery中读取。然后,
管道
执行一个groupByKey操作,在聚合操作之前按用户id (跨两个数据集)
分组
以创建会话记录。从在线研究中,我知道有时
使用
Combine操作比
使用
groupByKey操作更有效(除其他外,这个),但我认为这不适合我
分组<
浏览 6
提问于2020-08-18
得票数 1
2
回答
如何
使用
Java
8流在一次迭代中flatMap 2不同
的
字段?
java
、
functional-programming
、
java-8
、
java-stream
如果我有一个List,其中每个元素包含2个List字段,那么如何通过主列表在一次迭代中合并所有包含
的
列表。 换句话说,
使用
流
以函数形式表示以下命令式代码
的
最佳方法是什么?
浏览 1
提问于2015-12-28
得票数 3
回答已采纳
2
回答
为什么
流
操作与
收集器
重复?
java
、
java-8
、
java-stream
请允许我提出一些抱怨,也许这是令人厌烦
的
,但我想描述一下:“
为什么
会提出这个问题?”。我回答
的
问题与昨晚
的
其他问题不同-- ,和。我只能想到
为什么
操作与
的
操作重复
的
几个原因如下: 消费(stream.map(.)>
流
){.} 更强大,可以将组合在一起收集流中
的
元素,然而,只提供一些有用/
浏览 1
提问于2017-05-30
得票数 3
回答已采纳
1
回答
Kafka
流
-
使用
地址聚合和连接用户
apache-kafka
、
apache-kafka-streams
我
的
原型正在工作,它正在为每个用户保存一个地址列表,但我在问自己,KGroupedStream是否会在一段
时间
后删除一些
流
。 (user, address, queue) -> {..
浏览 0
提问于2018-12-03
得票数 2
回答已采纳
1
回答
Apache Flink中DataStream与Table
API
的
区别
apache-flink
、
flink-streaming
、
flink-sql
我是Apache Flink
的
新手,我想了解DataStream和Table
API
之间
的
用例。请您帮我了解一下,什么时候选择Table接口而不是DataStream接口。据我所知,用Table
API
可以做
的
事情,也可以用DataStream
API
来做。这两个
API
有什么不同?
浏览 14
提问于2018-08-01
得票数 2
回答已采纳
2
回答
使用
java
服务真的比
使用
flow服务快吗?
java
、
webmethods
我听说
java
服务比
使用
flow服务运行得更快。但是,当我尝试将
流
服务更改为
java
服务时,我只得到了相同
的
处理
时间
。下面是截图: 下面是我
的
java
服务代码String SCDataFound = "";pipelineCursor_1.destroy();
浏览 8
提问于2015-03-11
得票数 2
2
回答
Java
/ SQL -How每隔30分钟或1小时将
时间
分组
java
、
datetime
、
sqldatetime
我
需要
一个解决方案来
分组
输入
时间
,并显示相应
的
时间
间隔和用户/记录在该
时间
间隔内
的
计数。
时间
间隔计数下午12:30 -下午1:00 26我尝试在sql和LocalTime中
使用
流
分组
,但我无法根据
时间
间隔进行<
浏览 10
提问于2022-10-25
得票数 0
回答已采纳
2
回答
Google Cloud Dataflow -
Java
SDK与Python
java
、
python
、
google-cloud-platform
、
google-cloud-dataflow
、
apache-beam
我开始
使用
进行批处理和
流
处理。正在开发
的
工作主要用于摄取来自不同来源(MySQL、Kafka和文件系统)
的
数据,清理它们,进行
流
和沐浴聚合,并将其写回。考虑到这些任务,是否有
使用
Java
或Python 编写作业
的
建议?他们之间在性能和功能方面有什么明显
的
差异吗? 例如,我注意到对于
Java
,内置
的
I/O PTransform JdbcIO是可用
的
。这个PTransfor
浏览 3
提问于2020-07-07
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
不吹不黑JAVA Stream的collect用法与原理,远比你想象的更强大
Java Stream函数式编程?用过都说好,案例图文详解送给你
Java:Java中内存泄漏的原因以及如何避免它们
如何在NativeScript中嵌入V8?
十分钟学会Java io
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券