}
list.add(mutation);
}
for (Entry<String, List<RowMutation>> entry : mutationsByShard.entrySet()) {
BlurIndex index = indexes.get(entry.getKey());
index.enqueue(entry.getValue());
}
}
private void doMutates(final String table, List<RowMutation> mutations) throws IOException, BlurException {
final Map<String, BlurIndex> indexes = _indexServer.getIndexes(table);