Tengo la siguiente situación Map<Key, ListContainer> map; public class ListContainer{ List<AClass> lst; } Tengo que fusionar todas las listas lstde los ListContainerobjetos de un Mapmapa. public static void main(String args[]){ List<AClass> alltheObjectsAClass =...
Tengo la siguiente expresión: scheduleIntervalContainers.stream() .filter(sic -> ((ScheduleIntervalContainer) sic).getStartTime() != ((ScheduleIntervalContainer)sic).getEndTime()) .collect(Collectors.toList()); ... donde scheduleIntervalContainerstiene el tipo de elemento...
Parece que tengo problemas para entender cómo Java compone las operaciones de transmisión en una tubería de transmisión. Al ejecutar el siguiente código public static void main(String[] args) { StringBuilder sb = new StringBuilder(); var count = Stream.of(new String[]{"1", "2", "3", "4"})...
Parece que IntStream.iteratees solo una versión ordenada ligera para IntStream.generate. ¿Es verdad? Si no, ¿cuál es la diferencia
Tengo un código Java que proporciona objetos de items. Los limita en función de maxNumber: items.stream() .map(this::myMapper) .filter(item -> item != null) .limit(maxNumber) .collect(Collectors.toList()); Funciona correctamente, pero la pregunta es la siguiente: ¿hay alguna forma de...
Estoy tratando de entender por qué el siguiente programa Java da un OutOfMemoryError, mientras que el programa correspondiente sin .parallel()no. System.out.println(Stream .iterate(1, i -> i+1) .parallel() .flatMap(n -> Stream.iterate(n, i -> i+n)) .mapToInt(Integer::intValue)...
Tengo un mapa Map<K, V>y mi objetivo es eliminar los valores duplicados y generar la misma estructura Map<K, V>nuevamente. En caso de que se encuentre el valor duplicado, debe seleccionarse una clave ( k) de las dos claves ( k1y k1) que contienen estos valores, por esta razón, asumir la...
Quiero usar a Streampara paralelizar el procesamiento de un conjunto heterogéneo de archivos JSON almacenados de forma remota de un número desconocido (el número de archivos no se conoce por adelantado). Los archivos pueden variar ampliamente en tamaño, desde 1 registro JSON por archivo hasta...
Estaba tratando de convertir una matriz int a List y tomé la ruta desconocida de usar Java 8 Stream y se me ocurrió esto Arrays.stream(arr).boxed().collect(Collectors.toList()); Todavía tengo dificultades para entender completamente esta línea, principalmente, ¿Por qué Collectors.toList()en...
Cerrada . Esta pregunta necesita estar más centrada . Actualmente no está aceptando respuestas. ¿Quieres mejorar esta pregunta? Actualice la pregunta para que se centre en un problema solo editando esta publicación . Cerrado hace 4 días .
Para limpiar una lista de datos, he creado un método que acepta la lista de datos y la lista de operaciones de limpieza a realizar. public <T> List<T> cleanData(List<T> data, List<Function<T, T>> cleanOps) { List<T>dataNew=data.stream().map((str) -> { T...
Tengo una lista de colores como esta: Rosa, azul, rojo, azul, gris, verde, morado, negro ... etc. List<String> listOfColors = Arrays.asList("Pink", "Blue", "Red", "blue", "Grey", "green", "purple", "black"); Hay algunas operaciones intermedias como filtrar algunos colores de frutas,...
Tengo un Map<String,List<String>>y quiero que se convierta Map<String,List<Long>>porque cada uno Stringen la lista representa un Long: Map<String,List<String>> input = ...; Map<String,List<Long>> output= input.entrySet() .stream()...
Tengo un mapa hash con los valores a continuación, en valores que he fechado como tipo de datos de cadena. Me gustaría comparar todas las fechas disponibles en el mapa y extraer solo un valor-clave que tenga una fecha muy reciente. Me gustaría comparar con valores, no con claves. He incluido el...
Tengo el siguiente código: Stream<String> lines = reader.lines(); Si la cadena del primer puño es igual "email", quiero eliminar la primera cadena del flujo. Para otras cadenas de la secuencia, no necesito esta verificación. ¿Cómo podría lograrlo? PD Claro que puedo transformarlo en la...
Encontré un cuestionario sobre Java 8 Stream API del método peek como se muestra a continuación Arrays.asList("Fred", "Jim", "Sheila") .stream() .peek(System.out::println) .allMatch(s -> s.startsWith("F")); La salida es Fred Jim ¿Estoy confundido sobre cómo funciona esta transmisión? Mi...
¿Hay alguna manera de que lo siguiente se pueda realizar como un conjunto de operaciones de flujo, en lugar de verificar explícitamente si los productos recomendados están vacíos y luego devolver la lista predeterminada o devolver la lista filtrada ? public List<Product>...
Tengo un CSVarchivo de 35 GB . Quiero leer cada línea y escribir la línea en un nuevo CSV si coincide con una condición. try (BufferedWriter writer = Files.newBufferedWriter(Paths.get("source.csv"))) { try (BufferedReader br = Files.newBufferedReader(Paths.get("target.csv"))) {...
Estoy tratando de procesar el siguiente código usando subprocesos múltiples en el nivel de pedido. List<String> orders = Arrays.asList("order1", "order2", "order3", "order4", "order1"); Ejecución secuencial actual: orders.stream().forEach(order -> { rules.forEach(rule -> {...
Estoy tratando de filtrar un recurso y excluir algunos elementos basados en un campo. Para excluir, tengo un conjunto (que contiene una identificación que debe excluirse) y una lista (contiene múltiples rangos de identificadores que deben excluirse). Escribí la lógica a continuación y no estoy...