- Java 双重比较
- java - 比较器与 Apache BeanComparator
- Objective-C 完成 block 导致额外的方法调用?
- database - RESTful URI 是否应该公开数据库主键?
我有以下两个类:
人物
:
public class Person {
private final Long id;
private final String address;
private final String phone;
public Person(Long id, String address, String phone) {
this.id = id;
this.address = address;
this.phone = phone;
}
public Long getId() {
return id;
}
public String getAddress() {
return address;
}
public String getPhone() {
return phone;
}
@Override
public String toString() {
return "Person [id=" + id + ", address=" + address + ", phone=" + phone + "]";
}
}
CollectivePerson
:
import java.util.HashSet;
import java.util.Set;
public class CollectivePerson {
private final Long id;
private final Set<String> addresses;
private final Set<String> phones;
public CollectivePerson(Long id) {
this.id = id;
this.addresses = new HashSet<>();
this.phones = new HashSet<>();
}
public Long getId() {
return id;
}
public Set<String> getAddresses() {
return addresses;
}
public Set<String> getPhones() {
return phones;
}
@Override
public String toString() {
return "CollectivePerson [id=" + id + ", addresses=" + addresses + ", phones=" + phones + "]";
}
}
我想进行流式操作,以便:
Person
映射到 CollectivePerson
Person
的address
和phone
分别合并为addresses
和phone
在 CollectivePerson
中为所有具有相同 id
Person
我为此编写了以下代码:
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.stream.Collectors;
public class Main {
public static void main(String[] args) {
Person person1 = new Person(1L, "Address 1", "Phone 1");
Person person2 = new Person(2L, "Address 2", "Phone 2");
Person person3 = new Person(3L, "Address 3", "Phone 3");
Person person11 = new Person(1L, "Address 4", "Phone 4");
Person person21 = new Person(2L, "Address 5", "Phone 5");
Person person22 = new Person(2L, "Address 6", "Phone 6");
List<Person> persons = new ArrayList<>();
persons.add(person1);
persons.add(person11);
persons.add(person2);
persons.add(person21);
persons.add(person22);
persons.add(person3);
Map<Long, CollectivePerson> map = new HashMap<>();
List<CollectivePerson> collectivePersons = persons.stream()
.map((Person person) -> {
CollectivePerson collectivePerson = map.get(person.getId());
if (Objects.isNull(collectivePerson)) {
collectivePerson = new CollectivePerson(person.getId());
map.put(person.getId(), collectivePerson);
collectivePerson.getAddresses().add(person.getAddress());
collectivePerson.getPhones().add(person.getPhone());
return collectivePerson;
} else {
collectivePerson.getAddresses().add(person.getAddress());
collectivePerson.getPhones().add(person.getPhone());
return null;
}
})
.filter(Objects::nonNull)
.collect(Collectors.<CollectivePerson>toList());
collectivePersons.forEach(System.out::println);
}
}
它的工作和输出为:
CollectivePerson [id=1, addresses=[Address 1, Address 4], phones=[Phone 1, Phone 4]]
CollectivePerson [id=2, addresses=[Address 2, Address 6, Address 5], phones=[Phone 5, Phone 2, Phone 6]]
CollectivePerson [id=3, addresses=[Address 3], phones=[Phone 3]]
但我相信可能有更好的方法,流式分组来实现相同的目的。任何指针都会很棒。
最佳答案
您可以使用 Collectors.toMap
具有合并功能:
public static <T, K, U, M extends Map<K, U>>
Collector<T, ?, M> toMap(Function<? super T, ? extends K> keyMapper,
Function<? super T, ? extends U> valueMapper,
BinaryOperator<U> mergeFunction,
Supplier<M> mapSupplier)
映射看起来像这样:
Map<Long,CollectivePerson> collectivePersons =
persons.stream()
.collect(Collectors.toMap (Person::getId,
p -> {
CollectivePerson cp = new CollectivePerson (p.getId());
cp.getAddresses().add (p.getAddress());
cp.getPhones().add(p.getPhone());
return cp;
},
(cp1,cp2) -> {
cp1.getAddresses().addAll(cp2.getAddresses());
cp1.getPhones().addAll(cp2.getPhones());
return cp1;
},
HashMap::new));
您可以轻松提取 List<CollectivePerson>
来自那个Map
使用:
new ArrayList<>(collectivePersons.values())
这是输出 Map
对于您的示例输入:
{1=CollectivePerson [id=1, addresses=[Address 1, Address 4], phones=[Phone 1, Phone 4]],
2=CollectivePerson [id=2, addresses=[Address 2, Address 6, Address 5], phones=[Phone 5, Phone 2, Phone 6]],
3=CollectivePerson [id=3, addresses=[Address 3], phones=[Phone 3]]}
关于Java 8 Stream Mapping 分组操作,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/46806917/
我正在努力做到这一点 在我的操作中从数据库获取对象列表(确定) 在 JSP 上打印(确定) 此列表作为 JSP 中的可编辑表出现。我想修改然后将其提交回同一操作以将其保存在我的数据库中(失败。当我使用
我有以下形式的 Linq to Entities 查询: var x = from a in SomeData where ... some conditions ... select
我有以下查询。 var query = Repository.Query() .Where(p => !p.IsDeleted && p.Article.ArticleSections.Cou
我正在编写一个应用程序包,其中包含一个主类,其中主方法与GUI类分开,GUI类包含一个带有jtabbedpane的jframe,它有两个选项卡,第一个选项卡包含一个jtable,称为jtable1,第
以下代码产生错误 The nested query is not supported. Operation1='Case' Operation2='Collect' 问题是我做错了什么?我该如何解决?
我已经为 HA redis 集群(2 个副本、1 个主节点、3 个哨兵)设置了本地 docker 环境。只有哨兵暴露端口(10021、10022、10023)。 我使用的是 stackexchange
我正在 Desk.com 中构建一个“集成 URL”,它使用 Shopify Liquid 模板过滤器语法。对于开始日期为 7 天前而结束日期为现在的查询,此 URL 需要包含“开始日期”和“结束日期
你一定想过。然而情况却不理想,python中只能使用类似于 i++/i--等操作。 python中的自增操作 下面代码几乎是所有程序员在python中进行自增(减)操作的常用
我需要在每个使用 github 操作的手动构建中显示分支。例如:https://gyazo.com/2131bf83b0df1e2157480e5be842d4fb 我应该显示分支而不是一个。 最佳答
我有一个关于 Perl qr 运算符的问题: #!/usr/bin/perl -w &mysplit("a:b:c", /:/); sub mysplit { my($str, $patt
我已经使用 ArgoUML 创建了一个 ERD(实体关系图),我希望在一个类中创建两个操作,它们都具有 void 返回类型。但是,我只能创建一个返回 void 类型的操作。 例如: 我能够将 book
Github 操作仍处于测试阶段并且很新,但我希望有人可以提供帮助。我认为可以在主分支和拉取请求上运行 github 操作,如下所示: on: pull_request push: b
我正在尝试创建一个 Twilio 工作流来调用电话并记录用户所说的内容。为此,我正在使用 Record,但我不确定要在 action 参数中放置什么。 尽管我知道 Twilio 会发送有关调用该 UR
我不确定这是否可行,但值得一试。我正在使用模板缓冲区来减少使用此算法的延迟渲染器中光体积的过度绘制(当相机位于体积之外时): 使用廉价的着色器,将深度测试设置为 LEQUAL 绘制背面,将它们标记在模
有没有聪明的方法来复制 和 重命名 文件通过 GitHub 操作? 我想将一些自述文件复制到 /docs文件夹(:= 同一个 repo,不是远程的!),它们将根据它们的 frontmatter 重命名
我有一个 .csv 文件,其中第一列包含用户名。它们采用 FirstName LastName 的形式。我想获取 FirstName 并将 LastName 的第一个字符添加到它上面,然后删除空格。然
Sitecore 根据 Sitecore 树中定义的项目名称生成 URL, http://samplewebsite/Pages/Sample Page 但我们的客户有兴趣降低所有 URL(页面/示例
我正在尝试进行一些计算,但是一旦我输入金额,它就会完成。我只是希望通过单击按钮而不是自动发生这种情况。 到目前为止我做了什么: Angular JS - programming-fr
我的公司创建了一种在环境之间移动文件的复杂方法,现在我们希望将某些构建的 JS 文件(已转换和缩小)从一个 github 存储库移动到另一个。使用 github 操作可以实现这一点吗? 最佳答案 最简
在我的代码中,我创建了一个 JSONArray 对象。并向 JSONArray 对象添加了两个 JSONObject。我使用的是 json-simple-1.1.jar。我的代码是 package j
我是一名优秀的程序员,十分优秀!