Java 8 Stream API explained with code samples

Java 8 introduced the Stream API. The Stream API along with lambda expressions can be used to perform bulk operations on the elements in a Collection. Not only that, you can pipeline the Stream operations to perform a number of sequential operations.

Edit

How do Streams work?

A new method called stream has been added to all the Collection interfaces, this returns a java.util.Stream interface. There are various methods on this stream interface that perform the corresponding operation on the Stream instance.

Suppose you have an integer array. Suppose you want to find all the elements that are greater than the value 9. Before Streams and Java 8, you would need to write code like the following:

public class FilterStreamDemo {public static void main(String[] args) {List<Integer> input = Arrays.asList(5, 3, 11, 15, 9, 2, 5, 11);List<Integer> output = new ArrayList<Integer>();for(int num:input){if(num >= 9)output.add(num);}}}

So this code iterates through the input list. It checks if each number is greater than 9 and if so adds it to the output list.

Using Streams, we can re-write the above code as follows:

public class FilterStreamDemo {public static void main(String[] args) {List<Integer> input = Arrays.asList(5, 3, 11, 15, 9, 2, 5, 11);Stream<Integer> stream = input.stream().filter(num -> num >= 9);}}

The code first invokes the input.stream method which returns a Stream instance. There is a filter method present on the Stream interface. This accepts a Predicate instance. Here, we are passing a lambda expression for the Predicate. So the lambda expression matches any element which is greater than 9. Thus the filter method runs this Predidate on every element in the input Stream and creates a new Stream with the output. So the result is a Stream that only has elements greater than 9. Compared to the earlier code, this code is much cleaner and easy to read.

Iterating Through a Stream

Just like Java 8 provides the forEach method for iterating through a Collection, it also provides this method on the Stream interface. So using this forEach, you can iterate through a Stream. Consider the following code snippet:

public class FilterStreamDemo {public static void main(String[] args) {List<Integer> input = Arrays.asList(5, 3, 11, 15, 9, 2, 5, 11);Stream<Integer> stream = input.stream().filter(num -> num >= 9);stream.forEach(num -> System.out.println(num));}}

Here, the Stream.filter is used to filter the Stream and create a new Stream with numbers greater than 9. Then the code invokes the forEach method on the Stream. Just like the forEach method on the Collection interfaces, this forEach method accepts a Consumer object. Here, the code is passing a lambda expression for the Consumer instance. This lambda expression simply prints the corresponding element.

So when you execute this code, it will print the following output:

11
15
9
11

Chaining Operations

The real power of Streams is that it allows you to chain a number of operations. For example, consider the following code:

public class StreamChainingOperationsDemo {public static void main(String[] args) {List<Integer> input = Arrays.asList(5, 3, 11, 15, 9, 2, 5, 11);long count = input.stream().filter(num -> num >= 9).distinct().count();System.out.println("count ="+count);}}

Here, the code first invokes the filter method. This is followed by the distinct method which returns a Stream with unique elements. So basically, the distinct method eliminates duplicates in the input Stream. Finally, the code invokes the count method. This returns the number of elements in the input Stream. So when you execute this code, it will print the following output:

count =3

Converting Stream to a Collection

You can convert the results of chaining several Streams back to a Collection. There is a method called collect on the Stream interface for this. So consider the following code snippet:

public class CollectStreamDemo {public static void main(String[] args) {List<Integer> list = Arrays.asList(5, 3, 11, 15, 9, 2, 5, 11);List<Integer> distinctList = list.stream().distinct().collect(Collectors.toList());distinctList.forEach(num -> System.out.println(num));}}

Here, the code invokes the distinct method to obtain the unique elements in the input. Then the code invokes the collect method.This accepts a Collector instance. There is a Collectors class. It has a method called toList which returns a Collector that converts the Stream to a List. So when you execute this code, it prints the following output:

5
3
11
15
9
2

 

Comments

Post a Comment

Popular posts from this blog

How to use logging in SpringBoot with code samples

Image
In this article, we will learn how to use logging in SpringBoot. Introduction There are several Java logging frameworks like logback, log4j, and so on. Spring Boot supports out-of-the-box support for logback. Let us learn how to use logging in SpringBoot with logback. Step 1 – Create a New Maven Project Create a new Maven project. (Refer to  this  blog post). This will create a project in Eclipse as follows:   Step 2 – Add the Spring Boot Dependencies Add the spring-boot-starter-web dependency to the pom.xml . So, the pom.xml should look as follows: <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.learnjava</groupId> <artifactId>learnjava-springboot-logging-example</artifactId> <version>0.0.1-SNAPSHOT&
Read more

Python While Loop with code samples

Much like a Java while loop, you can use a Python while loop to repeatedly execute a block of code as long as a condition is true. In this article, we will learn more about the Python while loop. Python While loop Syntax A while loop in Python has the following syntax: while <condition>: loop body The while keyword is followed by a condition. If the condition evaluates to true, the body of the loop is executed. Once the body of the loop is completed, the condition is checked again and this is repeated until the condition evaluates to false at which point the loop is exited. While loop Sample Code The following code demonstrates how you can use the while loop: num=10counter=1total=0while counter<=num: total += counter counter+=1print("sum of first 10 numbers is",total) This code adds the numbers from 1 to 10 and prints the sum. It uses a while loop to iterate from 1 to 10. The while loop checks the condition counter <= num and if so adds the current value of count
Read more

How to convert a List to a Set

In this blog post ,I will be showing you how you can convert a List to a Set. Consider the following code snippet: public class ListToSetDemo {public static void main(String[] args) {List<Integer> list = Arrays.asList(5,3,11,15,9);//Method 1Set<Integer> set = new HashSet<Integer>(list);System.out.println("Set is "+set);//method 2Set<Integer> set2 = new HashSet<Integer>();set2.addAll(list);System.out.println("Set is "+set2);}} This code demonstrates two ways to convert a List to a Set. Method 1 Here, we are creating a new HashSet . We are invoking the constructor that accepts a Collection object. Here, we are passing in the input list to this constructor.   Method 2 Here again, we are creating a new HashSet . However, we are using the default constructor. We are then invoking the addAll method and passing in the input list.   When you run this code, it will print the following output: Set is [3, 5, 9, 11, 15]Set is [3, 5, 9, 11, 15] No
Read more