为什么在.distinct()之后总是有一个.collect()？
在.distinct()之后总是有一个.collect()的原因是，.distinct()操作返回一个包含不重复元素的流，而.collect()操作将流的结果收集到一个集合中。
.distinct()是流操作中的一个中间操作，用于去除流中的重复元素，保留不同的元素。它使用元素的equals()方法来判断元素是否相同。例如，对于一个整数流[1, 2, 2, 3, 3, 4, 5]，使用.distinct()操作后，结果为[1, 2, 3, 4, 5]。
但是.distinct()只是返回一个去重后的流，并没有实际执行去重操作。为了获取最终的结果，需要使用.collect()操作将流的结果收集到一个集合中。.collect()是终端操作，触发流的遍历和处理，并将结果保存到指定的集合中。常见的集合类型有List、Set和Map。
例如，对于上述的整数流，可以使用.collect(Collectors.toList())将结果收集到一个List集合中，结果为[1, 2, 3, 4, 5]。
腾讯云提供了丰富的云计算相关产品，包括云服务器、云数据库、云存储等。具体推荐的腾讯云产品和介绍链接地址如下：
- 云服务器（CVM）：提供稳定可靠的虚拟机服务，支持多种规格和操作系统，适用于各类应用场景。详细信息请参考：https://cloud.tencent.com/product/cvm
- 云数据库 MySQL 版（CDB）：提供高性能、高可用的数据库服务，支持自动备份、容灾等特性，适用于各种规模的应用。详细信息请参考：https://cloud.tencent.com/product/cdb_mysql
- 云存储（COS）：提供安全可靠、高扩展性的对象存储服务，适用于图片、音视频、日志等数据的存储和管理。详细信息请参考：https://cloud.tencent.com/product/cos
通过使用腾讯云的产品，可以有效地支持和扩展云计算领域的各类应用。
相关·内容
经常看到.distinct().collect()结构。将collect()函数紧跟在distinct()函数之后的内在原因是什么？
浏览 70提问于2019-09-29得票数 1
我有以下情况，但它两次调用stream()似乎是一种难闻的气味： .map(entityKey -> entityKey.getObjectRef())
.collectstream() // having to call stream() a
浏览 0提问于2018-10-26得票数 1
回答已采纳
1回答
当我在一个长时间运行的Task中创建一个文件( Sqlite数据库)时，我遇到了一个问题，如果任务被取消，我无法正确地删除它。它抛出一个关于在另一个进程中使用的IOException，我假设另一个进程就是Task。 }, cancellationToken).ContinueWith((result) =>
浏览 1提问于2014-09-06得票数 2
我有一个有效的cypher查询来获得可选的结果，然后在后续查询中使用结果节点并组合结果。(DISTINCT n) + collect(DISTINCT parent) + collect(DISTINCT descendant)) as nodes, parentRelation, childRelation(DISTINCT node) + collect(DISTINCT contextualNode) as knowledge
浏览 14提问于2021-04-13得票数 1
回答已采纳
我在互联网上发现了一个使用包装类的建议，到目前为止，我的代码如下所示： .map(Wrapper::unwrap)在文档中，据说distinct()
返回由该流的不同元素Wrapper) other).person.getName().equals(per
浏览 0提问于2018-06-26得票数 0
回答已采纳
1回答
我有以下标签：
MATCH (m:Movie)<-[:LIKE]-(p:Person {personId : 1})WITHcollect(distinct t.tagName) a
浏览 4提问于2016-09-30得票数 0
我有一个pySpark数据，我想按一个列分组，然后在另一个列中为每个组找到唯一的项。在熊猫身上我可以做，我也想对我的火花数据做同样的。我可以在组中找到项目的distictCount并计数，如下所示 .agg(
fn.countDistinct(col('B'))为了
浏览 0提问于2019-06-19得票数 5
回答已采纳
1回答
(p1) AS person, count(r_pfq) AS friend_score, collect(fq.name) AS friendsORDER BY friend_score DESC现在，当我尝试使用(p1) AS person, count(r_pfq) AS friend_score, collect(fq.name) AS frie
浏览 1提问于2014-04-22得票数 0
1回答
我有一个相当长的涉及Cypher查询的查询，需要在一个大约有100万个节点的Neo4j数据库上运行。实际的查询非常简单，但是我添加了一些逻辑来格式化数据，一旦我们将数据返回到API，就可以快速使用它。--我注意到，仅仅返回节点而不执行任何数据格式化，就会使查询速度提高到大约一秒钟，所以我非常确信在格式化数据和确保唯一性时会出现这个问题。认为使用DISTINCT可能真的会减慢速度，但在删除它之后，我没有看到任何明显的速度加快。我在这里犯了什么明显的错误，真的会影响性能吗？(
DISTINCT
浏览 0提问于2018-04-23得票数 1
回答已采纳
我不确定这是不是一个bug，所以如果你这样做d.distinct().map(x => d.filter(_.equals(x)))我使用的是 0.6.1。
浏览 1提问于2012-12-08得票数 7
回答已采纳
我有以下代码，它试图读取一些json，区分它们，并将输出写到一个json文件中。我的问题是，我是否应该在.distinct()之后使用.collect()，否则它将在幕后发生？val manyJsons = sqlContext.read.json(someJsonDirectory)distinctJsons.coalesce
浏览 0提问于2017-06-12得票数 1
回答已采纳
2回答
例如，在附加的查询中，有时集合(项)是空的(第三个块)，但其他集合的结果仍然相关。 OPTIONAL MATCH(u) --(i: Item)WITH groups, collect(distinctu) as users, collect(distinct i) as items, <
浏览 3提问于2015-04-24得票数 12
1回答
我试图在用户模型上实现，但是我的帮助器方法上的sql查询有问题。用户模型以国家为领域之一。users.jsgoogle.setOnLoadCallback(drawRegionsMap);
// var data = google.visualization.arrayToDataTable([
//
浏览 6提问于2013-03-31得票数 1
回答已采纳
2回答
让我们假设我有一个Stream<T>，并且只想得到不同的元素并排序。天真的做法是只做以下几点： .sorted()或者，也许是相反的： .distinct()
浏览 2提问于2017-05-05得票数 34
回答已采纳
<String>> keysQuery = listExtractQglobal.parallelStream()谢谢
浏览 2提问于2021-03-25得票数 0
MATCH (m:computer)
CALL apoc.export.csv.data( M, [], null, {stream:true有没有一个参数来控制这个？新增功能： MATCH (m:SportsTeam)-[r:hasMember]-(n)
WITH collect(DISTINCT m) AS M, collect(DISTINCT n) AS N,collect(r) a
浏览 17提问于2020-10-29得票数 0
回答已采纳
用于将两组数据组合在一个流中。Stream.concat(stream1, stream2).collect(Collectors.toSet());stream1.collect(Collectors.toSet()).addAll(stream2.collect(Collectors.toSet()));
哪个更有效率，为什么？
浏览 18提问于2017-01-12得票数 14
回答已采纳
为了制作另一个d3查看器，我想从一个rest查询中得到一个图。CREATE (b)-[:KNOWS]->(c)但是使用下面的查询调用POST查询将返回2个图形，每个图形都有一个</em
浏览 1提问于2014-09-11得票数 1
我的代码部分是： System.out.println(c); }).distinct.length()) .collect
浏览 1提问于2018-04-13得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
云直播活动推荐
腾讯云开发者
