wczytywanie strumieniowe prosto z pliku

src/emps/v3_funkcyjnie/Grupowanie99.java

+package emps.v3_funkcyjnie;
+
+import java.util.IntSummaryStatistics;
+import java.util.Map;
+import java.util.TreeMap;
+import java.util.stream.Collectors;
+
+public class Grupowanie99 {
+
+	public static void main(String[] args) {
+		Map<String, IntSummaryStatistics> grupy = ObslugaCSV.wczytajStrumieniowo("emps.csv")
+				.collect(Collectors.groupingBy(
+						Employee::getJobTitle,
+						TreeMap::new,
+						Collectors.summarizingInt(Employee::getSalary)));
+		
+		grupy.forEach((job, stats) -> {
+			System.out.printf("| %-32s | %2d | %5d | %8.2f | %5d |%n",
+	                job, stats.getCount(), stats.getMin(), stats.getAverage(), stats.getMax());
+		});
+	}
+
+}

src/emps/v3_funkcyjnie/ObslugaCSV.java

@@ -2,11 +2,15 @@ package emps.v3_funkcyjnie;
 
 import java.io.File;
 import java.io.FileNotFoundException;
+import java.io.IOException;
 import java.io.PrintWriter;
+import java.nio.file.Files;
+import java.nio.file.Path;
 import java.time.LocalDate;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Scanner;
+import java.util.stream.Stream;
 
 public class ObslugaCSV {
 	public static List<Employee> wczytaj() {
@@ -24,10 +28,7 @@ public class ObslugaCSV {
 			scanner.nextLine(); // pomijamy pierwszą linię
 			while(scanner.hasNextLine()) {
 				String linia = scanner.nextLine();
-				String[] t = linia.split(";", -1);
-				Employee emp = new Employee(Integer.parseInt(t[0]), t[1], t[2], t[3],
-						Integer.parseInt(t[4]), LocalDate.parse(t[5]),
-						t[6], t[7], t[8], t[9], t[10]);
+				Employee emp = parsujLinie(linia);
 				emps.add(emp);
 			}
 		} catch (FileNotFoundException e) {
@@ -37,6 +38,29 @@ public class ObslugaCSV {
 		return emps;
 	}
 
+	public static Stream<Employee> wczytajStrumieniowo(Path plik) {
+		try {
+			return Files.lines(plik)
+					.skip(1)
+					.map(ObslugaCSV::parsujLinie);
+		} catch (IOException e) {
+			e.printStackTrace();
+			return Stream.empty();
+		}
+	}
+	
+	public static Stream<Employee> wczytajStrumieniowo(File plik) {
+		return wczytajStrumieniowo(plik.toPath());
+	}
+
+	public static Stream<Employee> wczytajStrumieniowo(String sciezka) {
+		return wczytajStrumieniowo(Path.of(sciezka));
+	}
+
+	public static Stream<Employee> wczytajStrumieniowo() {
+		return wczytajStrumieniowo("emps.csv");
+	}
+
 	public static void zapisz(List<Employee> lista, File plik) {
 		try(PrintWriter out = new PrintWriter(plik)) {
 			out.println(
@@ -60,4 +84,12 @@ public class ObslugaCSV {
 		zapisz(lista, "emps.csv");
 	}
 	
+	private static Employee parsujLinie(String linia) {
+		String[] t = linia.split(";", -1);
+		Employee emp = new Employee(Integer.parseInt(t[0]), t[1], t[2], t[3],
+				Integer.parseInt(t[4]), LocalDate.parse(t[5]),
+				t[6], t[7], t[8], t[9], t[10]);
+		return emp;
+	}
+
 }

src/emps/v3_funkcyjnie/S2_Filtrowanie.java

+package emps.v3_funkcyjnie;
+
+public class S2_Filtrowanie {
+
+	// Program wypisuje tylko zarabiających >= 10 tys,
+	// realizujemy to filtrowaniem, ale przy okazji pokazuję Wam schemat "filter / map" - podstawowe operacje na strumieniach.
+	// W tej wersji wczytujemy dane strumieniowo prosto z pliku, bez tworzenia listy.
+	public static void main(String[] args) {
+		ObslugaCSV.wczytajStrumieniowo("emps.csv")
+			.filter(emp -> emp.getSalary() >= 10_000)
+			.map(emp -> emp.getFirstName() + " " + emp.getLastName() + " " + emp.getSalary())
+			.map(String::toUpperCase) // ew.  .map(s -> s.toUpperCase())
+			.forEach(System.out::println);
+	}
+
+}