return pendingMutations;
}
<<<<<<< HEAD
@Override
public Mutator addSubDelete(K key, String cf, SN sColumnName,
N columnName, Serializer sNameSerializer, Serializer nameSerializer) {
return addSubDelete(key, cf, sColumnName, columnName, sNameSerializer, nameSerializer, keyspace.createClock());
}
@Override
public Mutator addSubDelete(K key, String cf, SN sColumnName,
N columnName, Serializer sNameSerializer, Serializer nameSerializer, long clock) {
Deletion d = new Deletion(clock);
SlicePredicate predicate = new SlicePredicate();
predicate.addToColumn_names(nameSerializer.toByteBuffer(columnName));
d.setPredicate(predicate);
d.setSuper_column(sNameSerializer.toByteBuffer(sColumnName));
getPendingMutations().addDeletion(key, Arrays.asList(cf), d);
return this;
}
@Override
public Mutator addSuperDelete(K key, String cf, SN sColumnName,
Serializer sNameSerializer) {
Deletion d = new Deletion();
d.setSuper_column(sNameSerializer.toByteBuffer(sColumnName));
getPendingMutations().addDeletion(key, Arrays.asList(cf), d);
return this;
}
=======
>>>>>>> c85bb564040f60b32e5c5477d368649c792bf6fb
} |