Intermediate işlemler geriye yeni bir stream dönen işlemlerdir. Intermediate operasyonlar ile stream üzerinde zincir işlemler yapabiliriz. Buna stream pipeline denilir. Pipeline içindeki her bir intermediate işlem, bir initial stream ile başlar ve kendinden sonrakine yeni bir stream döner. Bu işlemler, lazy’dir. Terminal işlemi çağrılana kadar, herhangi bir intermediate işlem çalışmaz.
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 |
public class LazyLogic { public static void main(String[] args) { List<String> list = Arrays.asList("1","2"); Stream<Integer> stream = list.stream() .map(n-> Integer.parseInt(n)) .filter(value -> {System.out.println("Filter "+value); return value % 2 == 0;}); System.out.println("Lazy Oldugundan Metotlar Calismadi"); stream.forEach(value -> System.out.println(value)); } } |
|
1 2 3 4 5 6 7 8 |
Lazy Oldugundan Metotlar Calismadi Filter 1 Filter 2 2 |
Kodun çıktısını inceleyelim. 1 ve 2 elemanlarından oluşan bir listemiz var. Bu listeden bir stream olusturuyoruz ve stream üzerinde map ve filter intermediate işlemleri yapıyoruz. Ama stream.forEach çağrılana kadar stream üzerinde herhangi bir işlem yapılmadı.
Intermediate işlemler stateless ve stateful olarak ikiye ayrılırlar. Filter stateless bir işlemdir. Her bir eleman bir öncekinden ve sonrakinden ayrı değerlendirilir. Stateful metotlarda ise, ilgili işlem başlamadan önce, önceki işlemin tamamlanması gerekmektedir. Sorted, distinct bu tarz işlemlerdendir. Bir önceki işlem sonucu oluşacak tüm sonuçlar bilinmeli ki stateful işlemler yapılabilsin. Bu gereksinim, stateful işlemlerin buffer’lı çalışmasına sebep olur. Buffer büyük verilerde memory problemine sebebiyet verebilir. Dikkatli kullanılması gereken işlemlerdir.
Şimdi Java Stream API içeresindeki intermediate operasyonlar ve kullanım amaçlarını inceleyelim.
Map: Stream içerisindeki elemanların formunu değiştiren operasyondur. Elemanın bir özelliğini ve stream içindeki elemanın tipini değiştirebiliriz. Bir örnek üzerinden bakalım.
Personel listesinin içerisinden, her bir personelin cinsiyetini almak istediğimiz de;
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 |
public class MapOperation { public static void main(String[] args) { List<Personel> personels = PersonelGenerator.personelGenerator(); //Ornek-1 List<Gender> genders = personels.stream() .map(personel -> personel.getGender()) .collect(Collectors.toList()); for(Gender cursor : genders) { System.out.println(MessageFormat.format("Gender: {0}", cursor.toString()) ); } //Ornek-2 personels.stream() .map(personel -> personel.getName().toUpperCase()) .forEach(name -> System.out.println(name)); } } |
Çıktı:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 |
Gender: MALE Gender: MALE Gender: MALE Gender: FEMALE Gender: FEMALE TUNA TOLGA ERDEM AYŞE ZEYNEP |
Map metodu ile stream içerisindeki Personel örneklerinin içerisinden gender bilgilerini aldık ve oluşan yeni stream’i collect metodu ile başka bir listeye çevirdik. Personel listesinden Stream<Personel> oluşturduk, map işlemi sonrası oluşan stream ise Stream<Gender> oldu. İkinci örneğimizde ise, personel isimlerini büyük harf ile güncelledik ve oluşan stream, Stream<String> oldu.
map metotu Function<R,V> tipinde bir functional interface alır. R input tipi, V output tipidir.
map(personel -> personel.getAddress()) personel input, address ise outputtur.
Not: Terminal işlemi ile sonlandırılan bir stream, tekrardan kullanılamaz. Eğer kullanmaya çalışır isek aşağıdaki hatayı alırız.
|
1 2 3 4 5 |
Exception in thread "main" java.lang.IllegalStateException: stream has already been operated upon or closed |
MapToInt, MapToLong, MapToDouble:
Nümerik terminal işlemlerinin bazıları belli bir stream tipi ister. Örneğin min, max gibi metotlar, Object tipinde bir stream değil Integer veya Double tipinde stream isterler. Bu metotları kullanacağımız zaman, MapToInt ve diğer metotları kullanırız.
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 |
public class MapToIntOperation { public static void main(String[] args) { List<String> stringList = Arrays.asList("1","2","3","4","5"); double avg = stringList.stream() .mapToInt(n-> Integer.parseInt(n)) .average().getAsDouble(); System.out.println(avg); } } |
Çıktı:
|
1 2 3 4 5 |
3.0 |
FlatMap: Map bir tip donerken, flatMap stream döner. Eğer elimizde işleyecek olduğumuz liste içerisinde integer listesi var ise, iç listelerin önce stream olarak alınması ve sonrasında işlenmesi gerekir. Bu işlemi map ile yapamayız.
Aşağıdaki örnekte çift sayıları bulucağız.
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 |
public class FlatMapOperation { public static void main(String[] args) { List<List<Integer>> listOfIntegerList = new ArrayList<List<Integer>>(); listOfIntegerList.add(Arrays.asList(1,2)); listOfIntegerList.add(Arrays.asList(3,4)); listOfIntegerList.add(Arrays.asList(5,6)); listOfIntegerList.stream().flatMap(i -> i.stream()) .filter(value -> value % 2 == 0) .forEach(i -> System.out.println(i)); } } |
Çıktı:
|
1 2 3 4 5 6 7 |
2 4 6 |
Örneğimizde, flatMap içerisine parametre olarak liste gönderildi ve bunu stream’e çevirdik. Filtre ile de oluşan stream içerisindeki çift sayıyı bulmaya çalıştık.
Filter: Boolean bir değer dönen Predicate interface’ini parametre olarak alır, ilgili koşulu true olan elemanlardan oluşan bir stream döner.
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 |
public class FilterOperation { public static void main(String[] args) { List<String> stringList = Arrays.asList("1","2","3","4","5","6","7","8"); stringList.stream() .map(n-> Integer.parseInt(n)) .filter(value -> value % 2 == 0) .forEach(value -> System.out.println(value)); } } |
Çıktı:
|
1 2 3 4 5 6 7 8 |
2 4 6 8 |
Distinct: Stream’in içindeki elemanları tekil hale çevirir. Tekrar eden elemanlar elenir. Tekrar eden elemanlar, nesnenin equals metotu kullanılarak bulunur.
|
1 2 3 4 5 6 7 8 9 10 11 12 13 |
public class DistinctOperation { public static void main(String[] args) { List<String> list = Arrays.asList("1","2","2","8","8","5","6","7","8"); list.stream() .map(n-> Integer.parseInt(n)) .distinct() .forEach(value -> System.out.println(value)); } } |
Çıktı:
|
1 2 3 4 5 6 7 8 9 10 |
1 2 8 5 6 7 |
Skip: long tipinde parametre alarak, verilen parametre kadar elemanı atlar. Verilen değer stream’in eleman sayısından büyük veya eşit ise, geriye dönen stream boş bir streamdir. Atılan elemanlar baştaki elemanlardır. Bu durumda stream’in ordered ve unordered olma durumu önem kazanır. Stream ordered ve paralel işleniyorsa, bu metot kötü performans gösterir. Memory problemine yol açabilir. Eğer metot kullanılacak ve ordered olması önemli değilse, stream unordered yapılmalıdır.
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 |
public class SkipOperation { public static void main(String[] args) { List<String> list = Arrays.asList("1","2","3","4","5","6","7","8"); list.stream() .map(n-> Integer.parseInt(n)) .skip(3) .forEach(value -> System.out.println(value)); } } |
Çıktı:
|
1 2 3 4 5 6 7 8 9 |
4 5 6 7 8 |
Limit: long tipinde parametre alarak, sadece verilen parametre kadar elemanı alır.
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 |
public class LimitOperation { public static void main(String[] args) { List<Integer> list = Arrays.asList(1,8,3,4,5,6,7,2); list.stream() .map(n-> n*n) .limit(3) .forEach(value -> System.out.println(value)); } } |
Çıktı:
|
1 2 3 4 5 6 7 |
1 64 9 |
Sort: sorted() metotu varsayılan sıralamaya göre sıralama yapar. Integerler 0 dan itibaren veya string ifadeler alfabetik olarak. sorted(Comparator<? super Personel> comparator) bir instance’in herhangi bir özelliğini verebilir ve ona göre sıralama yapabiliriz.
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 |
public class SortedOperation { public static void main(String[] args) { List<Integer> list = Arrays.asList(1,8,3,4,5,6,7,2); list.stream() .map(n-> n*n) .sorted() .forEach(value -> System.out.println(value)); List<Personel> personels = PersonelGenerator.personelGenerator(); personels.stream() .sorted(Comparator.comparing(Personel::getName)) .forEach(value -> System.out.println(value.getName())); /*Tersten Sıralama*/ personels.stream() .sorted(Comparator.comparing(Personel::getName).reversed()) .forEach(value -> System.out.println(value.getName())); } } |
Çıktı:
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 |
1 4 9 16 25 36 49 64 Ayşe Erdem Tolga Tuna Zeynep Zeynep Tuna Tolga Erdem Ayşe |
Örnek Kodlar: Java8StreamAPI
İnşallah faydalı bir yazı olmuştur.
İyi Çalışmalar
