Resultados da pesquisa a pedido "java-stream"
Existe uma boa maneira de extrair pedaços de dados de um fluxo java 8?
Em um processo ETL, estou recuperando muitas entidades de um repositório de dados do Spring. Estou então usando um fluxo paralelo para mapear as entidades para diferentes. Posso usar um consumidor para armazenar essas novas entidades em outro ...
Executar várias consultas em paralelo via Streams
Estou tendo o seguinte método: public String getResult() { List<String> serversList = getServerListFromDB(); List<String> appList = getAppListFromDB(); List<String> userList = getUserFromDB(); return getResult(serversList, appList, userList); ...
Usando várias funções de mapa vs. uma instrução de bloco em um mapa em um fluxo java
Digamos que tenho o seguinte código data.stream() .map(x -> { Object a = maybeReturnsNull(x); return a == null ? defaultValue : a; })Eu tenho alguma função que pode estar retornandonulle estou aplicando-o a um elemento do fluxo. Eu quero ter ...
Java 8 Spliterator (ou similar) que retorna um valor se houver apenas um único valor
Eu sou um grande fã dosingleOrEmpty operador de fluxo. Não está na lib std, mas acho muito útil. Se um fluxo tiver apenas um único valor, ele retornará esse valor em umOptional. Se não tiver valores ou mais de um valor, ...
Em fluxos Java, é realmente espiada apenas para depuração?
Estou lendo sobre fluxos Java e descobrindo coisas novas à medida que avança. Uma das coisas novas que encontrei foi apeek() função. Quase tudo o que li na espiada diz que deve ser usado para depurar seus Streams. E se eu tivesse um Stream em ...
Collectors.toSet () e HashSet
Pegue a seguinte linha de código de exemplo: Set<String> someSet = someColletion.stream().map(p -> p.toString()).collect(Collectors.toSet());eu quero umHashSet. Tomando um depurador para o código, estou realmente recebendo umHashSet. Eu dei ...
No Java 8, como faço para transformar um mapa <K, V> em outro mapa <K, V> usando um lambda?
Acabei de começar a olhar para o Java 8 e experimentar lambdas. Pensei em tentar reescrever uma coisa muito simples que escrevi recentemente. Preciso transformar um mapa de seqüência de caracteres em coluna em outro mapa de seqüência ...
Por que o fluxo paralelo Files.list () está executando muito mais lentamente do que usando Collection.parallelStream ()?
O fragmento de código a seguir faz parte de um método que obtém uma listagem de diretório, chama um método de extração em cada arquivo e serializa o objeto de droga resultante para xml. try(Stream<Path> paths = Files.list(infoDir)) { paths ...
Fechar fluxos no meio de tubulações
Quando executo esse código que abre muitos arquivos durante um pipeline de fluxo: public static void main(String[] args) throws IOException { Files.find(Paths.get("JAVA_DOCS_DIR/docs/api/"), 100, (path, attr) ...
Expressões Java 8 Lambda para resolver fibonacci (maneira não recursiva)
Eu sou iniciante no uso do recurso de expressão Lambda no Java 8. As expressões Lambda são muito úteis na resolução de programas como verificação de número Prime, fatorial etc. No entanto, eles podem ser utilizados efetivamente na resolução de ...