RowMutation rowMutation = new RowMutation(table, key);
for (ColumnFamily cf : diffRow.getColumnFamilies())
{
rowMutation.add(cf);
}
RowMutationMessage rowMutationMessage = new RowMutationMessage(rowMutation);
ReadRepairManager.instance().schedule(endPoints.get(i),rowMutationMessage);
}
logger_.info("resolve: " + (System.currentTimeMillis() - startTime) + " ms.");
return retRow;
}