Resultados da pesquisa a pedido "reduce"
saída de um programa de mapreduce como entrada para outro programa de mapreduce
Estou tentando um exemplo simples, no qual a saída de um trabalho MapReduce deve ser a entrada de outro trabalho MapReduce. O fluxo deve ser assim:Mapper1 --> Reducer1 --> Mapper2 --> Reducer2 (A saída do Mapper1 deve ser a entrada do Redutor1. ...
No método de redução de fluxo, a identidade deve sempre ser 0 para soma e 1 para multiplicação?
Prossigo o java 8 learning. Eu encontrei um comportamento interessante: vamos ver o exemplo de código: // identity value and accumulator and combiner Integer summaryAge = Person.getPersons().stream() //.parallel() //will return surprising ...
Mesclar Javascript / reduzir os mesmos objetos multidimensionais
com base na minha pergunta:https://stackoverflow.com/a/40661953/2392461 [https://stackoverflow.com/a/40661953/2392461], abro uma nova pergunta com dados de amostra. Quero mesclar / reduzir isso: var array = [{ 'key1': { 'key11': 0, 'key12': 1 ...
Reduza a matriz para definir no Swift
Estou tentando reduzir uma matriz de objetos para um conjunto no Swift e este é o meu código: objects.reduce(Set<String>()) { $0.insert($1.URL) }No entanto, recebo um erro: Type of expression is ambiguous without more context.Eu não entendo ...
Como implementar uma função de redução mais geral para permitir a saída antecipada?
reduce (akafoldL no FP) é a função iterativa de ordem superior mais geral em Javascript. Você pode implementar, por exemplo,map oufilter em termos dereduce. Eu usei um loop imperativo para ilustrar melhor o algoritmo: const foldL = f => acc => ...
RDD divide e faz agregação em novos RDDs
Eu tenho um RDD de(String,String,Int). Eu quero reduzi-lo com base nas duas primeiras cadeiasE então, com base na primeira String, quero agrupar o (String, Int) e classificá-losApós a classificação, preciso agrupá-los em pequenos grupos, cada um ...
Spark: diferença de semântica entre reduzir e reduzirByKey
Na documentação do Spark, diz que o método RDDsreduce [http://spark.apache.org/docs/latest/api/scala/index.html#org.apache.spark.rdd.RDD] requer uma função binária associativa e comutativa. No entanto, o ...
Usando a função reduzir para retornar uma matriz
Por que é que quando eu quero usar a função push dentro da função reduzir para retornar uma nova matriz, recebo um erro. No entanto, quando eu uso o método concat dentro da função de redução, ele retorna uma nova matriz sem nenhum problema. Tudo ...
Reduções em paralelo no tempo logarítmico
Dadon somas parciais é possível somar todos os somas parciais em etapas paralelas do log2. Por exemplo, suponha que haja oito threads com oito somas parciais:s0, s1, s2, s3, s4, s5, s6, s7. Isso pode ser reduzido emlog2(8) = 3 etapas seqüenciais ...
Como quebrar no método de redução
Como posso interromper a iteração no método de redução? para for (var i = Things.length - 1; i >= 0; i--) { if(Things[i] <= 0){ break; } }; reduzir Things.reduce(function(memo, current){ if(current <= 0){ //break ??? //return; <-- this will ...