Estou tentando entender por que o seguinte programa Java fornece um OutOfMemoryError, enquanto o programa correspondente sem .parallel(). System.out.println(Stream .iterate(1, i -> i+1) .parallel() .flatMap(n -> Stream.iterate(n, i -> i+n)) .mapToInt(Integer::intValue)...
Eu tenho um mapa Map<K, V>e meu objetivo é remover os valores duplicados e gerar a mesma estrutura Map<K, V>novamente. Caso o valor duplicado for encontrado, deve ser selecionada uma chave ( k) das duas teclas ( k1e k1) que detêm esses valores, por isso, assumir a
Desejo usar um Streampara paralelizar o processamento de um conjunto heterogêneo de arquivos JSON armazenados remotamente, de número desconhecido (o número de arquivos não é conhecido antecipadamente). Os arquivos podem variar amplamente em tamanho, de 1 registro JSON por arquivo até 100.000...
Eu estava tentando converter uma matriz int em List e segui a rota desconhecida de usar o Java 8 Stream e criei essa Arrays.stream(arr).boxed().collect(Collectors.toList()); Eu ainda tenho dificuldade para entender completamente essa linha, principalmente, Por que Collectors.toList(), neste...
Para limpar uma lista de dados, criei um método que aceita a lista de dados e a lista de operações de limpeza a serem executadas. public <T> List<T> cleanData(List<T> data, List<Function<T, T>> cleanOps) { List<T>dataNew=data.stream().map((str) -> { T...
Eu tenho uma lista de cores como esta: Rosa, azul, vermelho, azul, cinza, verde, roxo, preto ... etc List<String> listOfColors = Arrays.asList("Pink", "Blue", "Red", "blue", "Grey", "green", "purple", "black"); Existem algumas operações intermediárias, como filtrar algumas cores de...
Fechado . Esta questão precisa ser mais focada . No momento, não está aceitando respostas. Deseja melhorar esta pergunta? Atualize a pergunta para que ela se concentre apenas em um problema editando esta postagem . Fechado há 4 dias . AtomicInteger...
Eu tenho um Map<String,List<String>>e quero que ele se transforme Map<String,List<Long>>porque cada um Stringna lista representa um Long: Map<String,List<String>> input = ...; Map<String,List<Long>> output= input.entrySet() .stream()...
Estou tendo um mapa de hash com valores abaixo, em valores que eu tenho como tipo de dados string. Gostaria de comparar todas as datas disponíveis no mapa e extrair apenas um valor-chave com uma data muito recente. Eu gostaria de comparar com valores e não chaves. Eu incluí o código...
Eu tenho o seguinte código: Stream<String> lines = reader.lines(); Se a primeira corda for igual "email", quero remover a primeira do fluxo. Para outras seqüências de caracteres do fluxo, não preciso dessa verificação. Como eu consegui isso? PS Claro que posso transformá-lo na lista e,...
Encontrei um questionário sobre a API do Java 8 Stream do método peek, conforme abaixo Arrays.asList("Fred", "Jim", "Sheila") .stream() .peek(System.out::println) .allMatch(s -> s.startsWith("F")); A saída é Fred Jim Estou confuso como esse fluxo funciona? Meu resultado esperado deve...
Existe alguma maneira de que o abaixo possa ser executado como um conjunto de operações de fluxo, em vez de verificar explicitamente se recommendedProducts está vazio e retornar a lista padrão ou retornar a lista filtrada ? public List<Product> getRecommendedProducts() { List<Product>...
Eu tenho um CSVarquivo de 35GB . Quero ler cada linha e gravar a linha em um novo CSV, se corresponder a uma condição. try (BufferedWriter writer = Files.newBufferedWriter(Paths.get("source.csv"))) { try (BufferedReader br = Files.newBufferedReader(Paths.get("target.csv"))) {
Estou tentando processar o código abaixo usando multithreading no nível do pedido. List<String> orders = Arrays.asList("order1", "order2", "order3", "order4", "order1"); Execução sequencial atual: orders.stream().forEach(order -> { rules.forEach(rule -> {
Tenho Listde Employees com diferentes datas de união. Desejo obter funcionários antes e depois da data específica de ingresso na lista usando fluxos. eu tentei seguir o código, List<Employee> employeeListAfter = employeeList.stream() .filter(e -> e.joiningDate.isAfter(specificDate))...
Estou tentando filtrar um recurso e excluir alguns elementos com base em um campo. Para excluir, tenho um conjunto (que contém um ID que precisa ser excluído) e uma lista (contém vários intervalos de IDs que precisam ser excluídos). Eu escrevi a lógica abaixo e não estou satisfeito com a segunda...
Eu quero converter: Map<String, Map<String, List<Map<String, String>>>> inputMap para: Map<String, Map<String, CustomObject>> customMap inputMapé fornecido na configuração e está pronto, mas eu preciso customMapformatar. O CustomObject será derivado do...
Eu tenho uma lista do tipo List<A>e com a operação de mapa obtendo uma lista coletiva do tipo List<B>para todos os elementos A mesclados em uma lista. List<A> listofA = [A1, A2, A3, A4, A5, ...] List<B> listofB = listofA.stream() .map(a -> repo.getListofB(a))...
Estou aprendendo fluxos Java 8. Diga-me, como posso escrever um sortArraymétodo de forma mais compacta? import org.junit.Test; import java.util.ArrayList; import java.util.Arrays; import java.util.HashMap; import java.util.Map; import static org.junit.Assert.assertArrayEquals; public class...
De acordo com a documentação no site da Oracle : Os efeitos colaterais nos parâmetros comportamentais das operações de fluxo são, em geral, desencorajados, pois muitas vezes podem levar a violações involuntárias do requisito de apatridia, bem como a outros riscos de segurança da thread. Isso...