Resultados da pesquisa a pedido "mapreduce"
Hadoop: java.lang.IncompatibleClassChangeError: interface encontrada org.apache.hadoop.mapreduce.JobContext, mas a classe era esperada
Minhas tarefas MapReduce são executadas corretamente quando montadas no Eclipse com todos os possíveis frascos Hadoop e Hive incluídos no projeto Eclipse como dependências. (Esses são os frascos que vêm com o nó único, instalação local ...
O programa Wordcount está preso no hadoop-2.3.0
Instalei o hadoop-2.3.0 e tentei executar o exemplo de contagem de palavras Mas ele inicia o trabalho e fica ocioso hadoop@ubuntu:~$ $HADOOP_HOME/bin/hadoop jar $HADOOP_HOME/share/hadoop/mapreduce/hadoop-mapreduce-examples-2.3.0.jar wordcount ...
O Mongodb seleciona todos os campos agrupados por um campo e classifica por outro campo
Temos a coleção 'message' com os seguintes campos _id | messageId | chainId | createOn 1 | 1 | A | 155 2 | 2 | A | 185 3 | 3 | A | 225 4 | 4 | B | 226 5 | 5 | C | 228 6 | 6 | B | 300Queremos selecionar todos os campos do documento com os ...
Verifique se todos os elementos da matriz correspondem à condição
Eu tenho uma coleção de documentos: date: Date users: [ { user: 1, group: 1 } { user: 5, group: 2 } ] date: Date users: [ { user: 1, group: 1 } { user: 3, group: 2 } ]Eu gostaria de consultar essa coleção para encontrar todos os documentos em ...
Erro ao executar o Mapreduce (fios) no eclipse do windows
Estou executando um programa WordCount no meu eclipse. Eu tentei com o Hadoop1.x ele está funcionando bem. Problema enfrentado durante a execução no hadoop2.x Eu tentei 1) adicionou todos os xml no meu caminho de classe. 2) também ...
Grave em várias saídas com a chave Scalding Hadoop, uma tarefa MapReduce
Como você pode gravar em várias saídas dependentes da chave usando Scalding (/ em cascata) em um único trabalho de redução de mapa. Eu poderia, é claro, usar.filter para todas as chaves possíveis, mas esse é um truque horrível, que acionará ...
MongoDb: Encontre elemento comum de duas matrizes em uma consulta
Digamos que temos registros da seguinte estrutura no banco de dados. { "_id": 1234, "tags" : [ "t1", "t2", "t3" ] }Agora, quero verificar se o banco de dados contém um registro com alguma das tags especificadas na matriztagsArray which is [ ...
a saída da fase do mapa do trabalho de mapreduce está sempre classificada?
Estou um pouco confuso com a saída que recebo do Mapper. Por exemplo, quando executo um programa simples de contagem de palavras, com este texto de entrada: hello world Hadoop programming mapreduce wordcount lets see if this works 12345678 ...
Encadeando várias tarefas do MapReduce no Hadoop
Em muitas situações da vida real em que você aplica o MapReduce, os algoritmos finais acabam sendo várias etapas do MapReduce. ou seja, Mapa1, Reduzir1, Mapa2, Reduzir2 e assim por diante. Portanto, você tem a saída da última redução necessária ...
Retornar número limitado de registros de um determinado tipo, mas número ilimitado de outros registros?
Eu tenho uma consulta em que preciso retornar 10 dos registros "Tipo A", enquanto retorna todos os outros registros. Como posso fazer isso? Atualizar:É certo que eu poderia fazer isso com duas consultas, mas queria evitar que, se possível, ...