streampipeline

Author: Juan Sáez García

streamspipeline/.gitignore

@@ -0,0 +1 @@
+target

streamspipeline/pom.xml

@@ -0,0 +1,75 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+ <modelVersion>4.0.0</modelVersion>
+
+ <groupId>com.streamspipeline</groupId>
+ <artifactId>streamspipeline</artifactId>
+ <version>1.0-SNAPSHOT</version>
+
+ <name>streamspipeline</name>
+ <!-- FIXME change it to the project's website -->
+ <url>http://www.example.com</url>
+
+ <properties>
+ <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+ <maven.compiler.source>1.8</maven.compiler.source>
+ <maven.compiler.target>1.8</maven.compiler.target>
+ </properties>
+
+ <dependencies>
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ <version>4.11</version>
+ <scope>test</scope>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <pluginManagement><!-- lock down plugins versions to avoid using Maven defaults (may be moved to parent pom) -->
+ <plugins>
+ <!-- clean lifecycle, see https://maven.apache.org/ref/current/maven-core/lifecycles.html#clean_Lifecycle -->
+ <plugin>
+ <artifactId>maven-clean-plugin</artifactId>
+ <version>3.1.0</version>
+ </plugin>
+ <!-- default lifecycle, jar packaging: see https://maven.apache.org/ref/current/maven-core/default-bindings.html#Plugin_bindings_for_jar_packaging -->
+ <plugin>
+ <artifactId>maven-resources-plugin</artifactId>
+ <version>3.0.2</version>
+ </plugin>
+ <plugin>
+ <artifactId>maven-compiler-plugin</artifactId>
+ <version>3.8.0</version>
+ </plugin>
+ <plugin>
+ <artifactId>maven-surefire-plugin</artifactId>
+ <version>2.22.1</version>
+ </plugin>
+ <plugin>
+ <artifactId>maven-jar-plugin</artifactId>
+ <version>3.0.2</version>
+ </plugin>
+ <plugin>
+ <artifactId>maven-install-plugin</artifactId>
+ <version>2.5.2</version>
+ </plugin>
+ <plugin>
+ <artifactId>maven-deploy-plugin</artifactId>
+ <version>2.8.2</version>
+ </plugin>
+ <!-- site lifecycle, see https://maven.apache.org/ref/current/maven-core/lifecycles.html#site_Lifecycle -->
+ <plugin>
+ <artifactId>maven-site-plugin</artifactId>
+ <version>3.7.1</version>
+ </plugin>
+ <plugin>
+ <artifactId>maven-project-info-reports-plugin</artifactId>
+ <version>3.0.0</version>
+ </plugin>
+ </plugins>
+ </pluginManagement>
+ </build>
+</project>

streamspipeline/src/main/java/com/streamspipeline/Persona.java

@@ -0,0 +1,33 @@
+package com.streamspipeline;
+
+import java.util.Optional;
+
+public class Persona {
+
+ private String nombre;
+ private String apellido1;
+ private Optional<String> apellido2;
+
+ public Persona(String nombre, String apellido1, Optional<String> apellido2) {
+ this.nombre = nombre;
+ this.apellido1 = apellido1;
+ this.apellido2 = apellido2;
+ }
+
+ public String getNombre() {
+ return nombre;
+ }
+
+ public String getApellido1() {
+ return apellido1;
+ }
+
+ public Optional<String> getApellido2() {
+ return apellido2;
+ }
+
+ @Override
+ public String toString() {
+ return nombre + "," + apellido1 + " " + apellido2.orElse("");
+ }
+}

streamspipeline/src/main/java/com/streamspipeline/PersonaUtil.java

@@ -0,0 +1,44 @@
+package com.streamspipeline;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Optional;
+import java.util.stream.Stream;
+
+public class PersonaUtil {
+
+ /** todos los metodos deben construir streams a partir de esta lista */
+ private List<Persona> bbdd = new ArrayList<>();
+
+ public PersonaUtil() {
+ bbdd.add(new Persona("Antonia", "Garcia", Optional.of("Sastre")));
+ bbdd.add(new Persona("John", "smith", Optional.empty()));
+ bbdd.add(new Persona("Pedro", "Llull", Optional.of("Mir")));
+ }
+
+ /**
+ * Devuelve stream con las personas que no tiene segundo apellido
+ */
+ public Stream<Persona> listaSinApellido2() {
+ return this.bbdd.stream().filter(persona -> !persona.getApellido2().isPresent());
+ }
+
+ /**
+ * Devuelve stream con los nombres de todas las personas
+ */
+ public Stream<String> listaNombres() {
+ return this.bbdd.stream().map(persona -> persona.getNombre());
+ }
+
+ /**
+ * Devuelve stream con primer apellido ordenado sin tener en cuenta mayusculas /
+ * minusculas
+ * pista: metodo de String compareToIgnoreCase
+ */
+ public Stream<String> listaApellido1Ordenada() {
+ return bbdd.stream()
+ .map(p -> p.getApellido1())
+ .sorted((p1, p2) -> p1.compareToIgnoreCase(p2));
+ }
+
+}

streamspipeline/src/test/java/com/streamspipeline/TestUtil.java

@@ -0,0 +1,48 @@
+package com.streamspipeline;
+
+import static org.junit.Assert.*;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+import org.junit.Before;
+import org.junit.Test;
+
+public class TestUtil {
+
+ private PersonaUtil util;
+
+ @Before
+ public void init() {
+ util = new PersonaUtil();
+ }
+
+ @Test
+ public void test_apellido2_null() {
+ List<Persona> resultado = util.listaSinApellido2().collect(Collectors.toList());
+ assertEquals(1, resultado.size());
+ assertEquals("John", resultado.get(0).getNombre());
+ }
+
+ @Test
+ public void test_obtener_nombres() {
+ List<String> resultado = util.listaNombres().collect(Collectors.toList());
+
+ assertEquals(3, resultado.size());
+ assertEquals("Antonia", resultado.get(0));
+ assertEquals("John", resultado.get(1));
+ assertEquals("Pedro", resultado.get(2));
+
+ }
+
+ @Test
+ public void test_obtener_apellido1() {
+ List<String> resultado = util.listaApellido1Ordenada().collect(Collectors.toList());
+
+ assertEquals(3, resultado.size());
+ assertEquals("Garcia", resultado.get(0));
+ assertEquals("Llull", resultado.get(1));
+ assertEquals("smith", resultado.get(2));
+
+ }
+}