Java 8 Stream API Terminal İşlemler

By Volkan Özdemir Last updated Jul 28, 2018

Terminal işlemler, stream pipeline’ın sonunda kullanılan ve zincir halindeki işlemleri sonlandıran işlemlerdir. Terminal işlemler, eager’dir. Yani terminal işlem çağrıldığı anda, stream üzerindeki tüm işlemler yapılır. Terminal işlemler, bir primitive type ve ya bir koleksiyon döndürebilir ve ya hiç bir şey döndürmez.

Matching:

3 farklı match işlemi vardır. Match işlemleri Predicate tipindeki bir Functional Interface’i parametre olarak alır. Şimdi işlemleri ayrı ayrı görelim.

AllMatch: Belirtilen koşulun stream deki tüm elemanlar tarafından sağlanması halinde true döner. Bu işlemler short-circuit işlemler’de denir. Sql deki AND gibidir. False olan bir eleman bulduğunda stream sonlandırılır.



boolean isAllMatch = personels.stream().allMatch(personel -> personel.getAge() > 20);
System.out.println("Personel yaşı 20 den büyük mü: "+isAllMatch);

boolean isAllMatch = personels.stream().allMatch(personel -> personel.getAge() > 20);

System.out.println("Personel yaşı 20 den büyük mü: "+isAllMatch);

NoneMatch: allmatch’in karşıtıdır. Stream içindeki elemanlardan ilgili koşulu hiç biri sağlamaz ise true aksi durumda false döner.



boolean isNoneMatch = personels.stream().noneMatch(personel -> personel.getAge() > 40);
System.out.println("Tüm Personel 40 dan küçük mü: "+isNoneMatch);

boolean isNoneMatch = personels.stream().noneMatch(personel -> personel.getAge() > 40);

System.out.println("Tüm Personel 40 dan küçük mü: "+isNoneMatch);

AnyMatch: Stream içindeki elemanlardan herhangi birinin ilgili koşulu sağlaması durumunda true hiç biri sağlamaz ise false döner.



boolean isAnyMatch = personels.stream().anyMatch(personel -> personel.getAge() > 30);
System.out.println("30 dan büyük personel var mı: "+isAnyMatch);

boolean isAnyMatch = personels.stream().anyMatch(personel -> personel.getAge() > 30);

System.out.println("30 dan büyük personel var mı: "+isAnyMatch);

Finding:
Stream içerisinde ilgili koşulu sağlayan elemanı bulur. İki metot vardır. FindAny ve findFirst. Bu metotlar geriye Optional değer dönerler. Optional<T> sınıfı, bazı metotların geri dönüş tipidir. Bunun sebebi, zincir halindeki işlemler de match veya finding işlemleri herhangi bir değer bulamaz ise geriye null döner ve bu durum zincirin devamında hataya sebebiyet verir. Bunun önüne geçebilmek için, bu metotlar Optional dönüş tipini kullanır.

FindAny: Koşulu sağlayan herhangi bir eleman var ise döner.



Optional<Personel> personel = personels.stream()
				.filter(p -> p.getAge() < 30)
				.findAny();

if(personel.isPresent()) {
	System.out.println(personel.get().getName());
} else {
	System.out.println("NOT FOUND");
}

Optional<Personel> personel = personels.stream()

.filter(p -> p.getAge() < 30)

.findAny();

if(personel.isPresent()) {

System.out.println(personel.get().getName());

} else {

System.out.println("NOT FOUND");

}

FindFirst: Koşulu sağlayan ilk elemanı döner. Stream sıralamayı sağlamak durumunda değilse, findAny’den bir farkı yoktur. Sıralı ise, ilk elemanı döner.



Optional<Personel> personel2 = personels.stream()
				.filter(p -> p.getAge() < 30)
				.findFirst();

if(personel2.isPresent()) {
	System.out.println(personel2.get().getName());
} else {
	System.out.println("NOT FOUND");
}

Optional<Personel> personel2 = personels.stream()

.filter(p -> p.getAge() < 30)

.findFirst();

if(personel2.isPresent()) {

System.out.println(personel2.get().getName());

} else {

System.out.println("NOT FOUND");

}

Collect: collect metotu ile stream elemanlarını başka bir koleksiyon içerisine doldurabilir, gruplama yapabilir veya toplama işlemleri yapabiliriz. collect metodu iki farklı parametre seti alarak çalışır. İlki collector tipinde bir interfacedir. Bu interface’in metotlarına Collectors sınıfının static metotları ile erişebiliriz. İkincisi ise, sırası ile Supplier, BiConsumer ve BiConsumer tipinde üç parametre bekler.

collect(Collector) Kullanımı

toList:

Personel stream içerisinden sadece MALE olanları filtreleyip, yeni bir liste olarak döndürdük.



List<Personel> malePersonels = personels.stream()
	.filter(personel -> personel.getGender().equals(Gender.MALE))
	.collect(Collectors.toList());
		
System.out.println(malePersonels);

List<Personel> malePersonels = personels.stream()

.filter(personel -> personel.getGender().equals(Gender.MALE))

.collect(Collectors.toList());

System.out.println(malePersonels);



[Personel [name=Tuna, gender=MALE, age=34, team=PM], 
Personel [name=Tolga, gender=MALE, age=30, team=DEVELOPMENT], 
Personel [name=Erdem, gender=MALE, age=30, team=DEVELOPMENT]]

[Personel [name=Tuna, gender=MALE, age=34, team=PM],

Personel [name=Tolga, gender=MALE, age=30, team=DEVELOPMENT],

Personel [name=Erdem, gender=MALE, age=30, team=DEVELOPMENT]]

toMap:

Personel stream içerisinden sadece MALE olanları filtreleyip, <Name,Team> çifti şeklinde bir map döndürdük.



Map<String,Team> mapPersonels = personels.stream()
	.filter(personel -> personel.getGender().equals(Gender.MALE))
	.collect(Collectors.toMap(Personel::getName, Personel::getTeam));

System.out.println(mapPersonels);

Map<String,Team> mapPersonels = personels.stream()

.filter(personel -> personel.getGender().equals(Gender.MALE))

.collect(Collectors.toMap(Personel::getName, Personel::getTeam));

System.out.println(mapPersonels);



{Tuna=PM, Tolga=DEVELOPMENT, Erdem=DEVELOPMENT}

{Tuna=PM, Tolga=DEVELOPMENT, Erdem=DEVELOPMENT}

grouping:

Personel stream içerisindeki elemanları, <Gender,List<Personel>> çifti şeklinde bir map döndürdük.



Map<Gender, List<Personel>> genderMap = personels.stream()
	.collect(Collectors.groupingBy(personel -> personel.getGender()));
System.out.println(genderMap);

Map<Gender, List<Personel>> genderMap = personels.stream()

.collect(Collectors.groupingBy(personel -> personel.getGender()));

System.out.println(genderMap);



{FEMALE=[Personel [name=Ayşe, gender=FEMALE, age=25, team=TEST], Personel [name=Zeynep, gender=FEMALE, age=28, team=ANALYIST]], 
MALE=[Personel [name=Tuna, gender=MALE, age=34, team=PM], Personel [name=Tolga, gender=MALE, age=30, team=DEVELOPMENT], Personel [name=Erdem, gender=MALE, age=30, team=DEVELOPMENT]]}

{FEMALE=[Personel [name=Ayşe, gender=FEMALE, age=25, team=TEST], Personel [name=Zeynep, gender=FEMALE, age=28, team=ANALYIST]],

MALE=[Personel [name=Tuna, gender=MALE, age=34, team=PM], Personel [name=Tolga, gender=MALE, age=30, team=DEVELOPMENT], Personel [name=Erdem, gender=MALE, age=30, team=DEVELOPMENT]]}

summarizingInt:

Bu metot ile int bir stream içindeki elemanların nümerik özeti yaparız. Örneğimiz de Personelin yaşlarını alarak yeni bir stream oluşturduk ve summarizingInt ile yaş bilgisine dair özet bilgiler oluşturduk.



IntSummaryStatistics statics = personels.stream()
		.map(personel -> personel.getAge())
		.collect(Collectors.summarizingInt(age -> age));
		
System.out.println(MessageFormat.format(" Sum: {0},n Avg: {1},n Max: {2},n Min: {3},n Count: {4}", statics.getSum(), statics.getAverage(),statics.getMax()
,statics.getMin(),statics.getCount()));

IntSummaryStatistics statics = personels.stream()

.map(personel -> personel.getAge())

.collect(Collectors.summarizingInt(age -> age));

System.out.println(MessageFormat.format(" Sum: {0},n Avg: {1},n Max: {2},n Min: {3},n Count: {4}", statics.getSum(), statics.getAverage(),statics.getMax()

,statics.getMin(),statics.getCount()));



 Sum: 147,
 Avg: 29.4,
 Max: 34,
 Min: 25,
 Count: 5

Sum: 147,

Avg: 29.4,

Max: 34,

Min: 25,

Count: 5

joining:

CharSequence alıp geriye String dönen metottur. Dönen String ifade modifiye edilmiş bir değer olabilir. Örneğimizde, önce isimlerden oluşan bir stream oluşturup sonra bu isimleri “,” ile birbirine bağlayıp geriye String bir ifade döneceğiz.



String nameJoining = personels.stream()
		.map(personel -> personel.getName())
		.collect(Collectors.joining(", "));
System.out.println(nameJoining);

String nameJoining = personels.stream()

.map(personel -> personel.getName())

.collect(Collectors.joining(", "));

System.out.println(nameJoining);



Tuna, Tolga, Erdem, Ayşe, Zeynep

Tuna, Tolga, Erdem, Ayşe, Zeynep

reducing:
Stream içerisindeki elemanları teker teker işleyerek geriye toplam, min, max vb tek değerlerin dönmesini sağlayan metottur.

Reduce metotu sıradaki eleman ile bir önceki elemanı beraber işler. Identity başlangıç değerini verir. Identity olmayan reduce metotları geriye Optional objesi döner.

reduce(T identity, BinaryOperator accumulator)



int min = personels.stream()
		.map(personel -> personel.getAge())
		.reduce(0, Integer::min);
System.out.println(min);

int min = personels.stream()

.map(personel -> personel.getAge())

.reduce(0, Integer::min);

System.out.println(min);

reduce(BinaryOperator accumulator)

Örneğimizde dönüş tipi Optional<Integer> olduğunda, ifPresent ile var olup olmadığına baktık ve sonra yazdırdık.



personels.stream()
	.map(personel -> personel.getAge())
	.reduce(Integer::max).ifPresent(i -> System.out.println(i));

personels.stream()

.map(personel -> personel.getAge())

.reduce(Integer::max).ifPresent(i -> System.out.println(i));

reduce(U identity,BiFunction<U, ? super T, U> accumulator, BinaryOperator combiner)



int total = personels.stream()
		.map(personel -> personel.getAge())
		.reduce(0, (before,after) -> (before + after));
System.out.println(total);

int total = personels.stream()

.map(personel -> personel.getAge())

.reduce(0, (before,after) -> (before + after));

System.out.println(total);

Personellerimiz arasındaki en genç personeli bulalım.



personels.stream()
	.reduce((p1,p2) -> p1.getAge() < p2.getAge() ? p1 : p2)
	.ifPresent(System.out::println);

personels.stream()

.reduce((p1,p2) -> p1.getAge() < p2.getAge() ? p1 : p2)

.ifPresent(System.out::println);

Örnek Kodlar: Java8StreamAPI

İnşallah faydalı bir yazı olmuştur.

İyi Çalışmalar