1. Introduction
In this quick tutorial, weβll demonstrate how to merge two maps using the Java 8 capabilities.
To be more specific, weβll examine different merging scenarios, including maps that have duplicate entries.
2. Initialization
To start, weβll define two Map instances:
private static Map<String, Employee> map1 = new HashMap<>();
private static Map<String, Employee> map2 = new HashMap<>();
The Employee class looks like this:
public class Employee {
private Long id;
private String name;
// constructor, getters, setters
}
Then we can push some data into the Map instances:
Employee employee1 = new Employee(1L, "Henry");
map1.put(employee1.getName(), employee1);
Employee employee2 = new Employee(22L, "Annie");
map1.put(employee2.getName(), employee2);
Employee employee3 = new Employee(8L, "John");
map1.put(employee3.getName(), employee3);
Employee employee4 = new Employee(2L, "George");
map2.put(employee4.getName(), employee4);
Employee employee5 = new Employee(3L, "Henry");
map2.put(employee5.getName(), employee5);
Note that we have identical keys for the employee1 and employee5 entries in our maps, which weβll use later.
3. Map.merge()
Java 8 adds a new merge() function into the java.util.Map interface.
The merge() function works as follows; if the specified key isnβt already associated with a value, or the value is null, it associates the key with the given value.
Otherwise, it replaces the value with the results of the given remapping function. If the result of the remapping function is null, it removes the result.
First, weβll construct a new HashMap by copying all the entries from the map1:
Map<String, Employee> map3 = new HashMap<>(map1);
Next, weβll introduce the merge() function, along with a merging rule:
map3.merge(key, value, (v1, v2) -> new Employee(v1.getId(),v2.getName())
Finally, weβll iterate over the map2 and merge the entries into map3:
map2.forEach(
(key, value) -> map3.merge(key, value, (v1, v2) -> new Employee(v1.getId(),v2.getName())));
Letβs run the program and print the content of map3:
John=Employee{id=8, name='John'}
Annie=Employee{id=22, name='Annie'}
George=Employee{id=2, name='George'}
Henry=Employee{id=1, name='Henry'}
As a result, our combined Map has all the elements of the previous HashMap entries. Entries with duplicate keys have been merged into one entry.
Also, we can see that the Employee object of the last entry has the id from map1, and the value is picked from map2.
This is because of the rule we defined in our merger function:
(v1, v2) -> new Employee(v1.getId(), v2.getName())
4. Stream.concat()
The Stream API in Java 8 can also provide an easy solution to our problem. First, we need to combine our Map instances into one Stream. This is exactly what the Stream.concat() operation does:
Stream combined = Stream.concat(map1.entrySet().stream(), map2.entrySet().stream());
Here we passed the map entry sets as parameters.
Next, we need to collect our result into a new Map. For that, we can use Collectors.toMap():
Map<String, Employee> result = combined.collect(
Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
As a result, the collector will use the existing keys and values of our maps. But this solution is far from being perfect. As soon as our collector meets entries with duplicate keys, itβll throw an IllegalStateException.
To handle this issue, we can simply add a third βmergerβ lambda parameter into our collector:
(value1, value2) -> new Employee(value2.getId(), value1.getName())
Itβll use the lambda expression every time a duplicate key is detected.
Finally, weβll put it all together:
Map<String, Employee> result = Stream.concat(map1.entrySet().stream(), map2.entrySet().stream())
.collect(Collectors.toMap(
Map.Entry::getKey,
Map.Entry::getValue,
(value1, value2) -> new Employee(value2.getId(), value1.getName())));
Now letβs run the code and see the results:
George=Employee{id=2, name='George'}
John=Employee{id=8, name='John'}
Annie=Employee{id=22, name='Annie'}
Henry=Employee{id=3, name='Henry'}
As we can see, the duplicate entries with the key βHenryβ were merged into a new key-value pair, where the id of the new Employee was picked from map2 and the value from map1.
5. Stream.of()
To continue to use the Stream API, we can turn our Map instances into a unified stream with the help of Stream.of().
Here we donβt have to create an additional collection to work with the streams:
Map<String, Employee> map3 = Stream.of(map1, map2)
.flatMap(map -> map.entrySet().stream())
.collect(Collectors.toMap(
Map.Entry::getKey,
Map.Entry::getValue,
(v1, v2) -> new Employee(v1.getId(), v2.getName())));
First, we transform map1 and map2 into a single stream. Next, we convert the stream into the map. As we can see, the last argument of toMap() is a merging function. It solves the duplicate keys problem by picking the id field from v1 entry, and the name from v2.
Hereβs the printed map3 instance after running the program:
George=Employee{id=2, name='George'}
John=Employee{id=8, name='John'}
Annie=Employee{id=22, name='Annie'}
Henry=Employee{id=1, name='Henry'}
6. Simple Streaming
Additionally, we can use a stream() pipeline to assemble our map entries. The code snippet below demonstrates how to add the entries from map2 and map1 by ignoring the duplicate entries:
Map<String, Employee> map3 = map2.entrySet()
.stream()
.collect(Collectors.toMap(
Map.Entry::getKey,
Map.Entry::getValue,
(v1, v2) -> new Employee(v1.getId(), v2.getName()),
() -> new HashMap<>(map1)));
As we expect, the results after the merge are:
{John=Employee{id=8, name='John'},
Annie=Employee{id=22, name='Annie'},
George=Employee{id=2, name='George'},
Henry=Employee{id=1, name='Henry'}}
7. StreamEx
In addition to solutions provided by the JDK, we can also use the popular StreamEx library.
Simply put, StreamEx is an enhancement for the Stream API, and provides many additional useful methods. Weβll use an EntryStream instance to operate on key-value pairs:
Map<String, Employee> map3 = EntryStream.of(map1)
.append(EntryStream.of(map2))
.toMap((e1, e2) -> e1);
The idea is to merge the streams of our maps into one. Then weβll collect the entries into the new map3 instance. Itβs also important to mention the (e1, e2) -> e1 expression, as it helps to define the rule for dealing with the duplicate keys. Without it, our code will throw an IllegalStateException.
And now, the results:
{George=Employee{id=2, name='George'},
John=Employee{id=8, name='John'},
Annie=Employee{id=22, name='Annie'},
Henry=Employee{id=1, name='Henry'}}
8. Summary
In this brief article, we learned different ways of merging maps in Java 8. More specifically, we used Map.merge(), Stream API, and the StreamEx library.
