natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix flawed addToMutationMap in word count example. 

Patch by Dave Brosius, reviewed by Brandon Williams for CASSANDRA-3669
This commit is contained in:
Brandon Williams 2012-01-04 10:33:57 -06:00
parent 190fb8c8ea
commit de333791e8
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
examples/hadoop_word_count/src/WordCountSetup.java
View File

@ -106,16 +106,24 @@ public class WordCountSetup
private static void addToMutationMap(Map<ByteBuffer,Map<String,List<Mutation>>> mutationMap, ByteBuffer key, String cf, Column c)
{
Map<String,List<Mutation>> cfMutation = new HashMap<String,List<Mutation>>();
List<Mutation> mList = new ArrayList<Mutation>();
Map<String, List<Mutation>> cfMutation = mutationMap.get(key);
if (cfMutation == null) {
cfMutation = new HashMap<String, List<Mutation>>();
mutationMap.put(key, cfMutation);
}
List<Mutation> mutationList = cfMutation.get(cf);
if (mutationList == null) {
mutationList = new ArrayList<Mutation>();
cfMutation.put(cf, mutationList);
}
ColumnOrSuperColumn cc = new ColumnOrSuperColumn();
Mutation m = new Mutation();
cc.setColumn(c);
m.setColumn_or_supercolumn(cc);
mList.add(m);
cfMutation.put(cf, mList);
mutationMap.put(key, cfMutation);
mutationList.add(m);
}
private static void setupKeyspace(Cassandra.Iface client) throws TException, InvalidRequestException, SchemaDisagreementException {