Tag: astyanax

Cassandra更新不一致

我在本地(mac)机器和远程unix服务器上运行以下代码: public void deleteValue(final String id, final String value) { log.info(“Removing value ” + value); final Collection valuesBeforeRemoval = getValues(id); final MutationBatch m = keyspace.prepareMutationBatch(); m.withRow(VALUES_CF, id).deleteColumn(value); try { m.execute(); } catch (final ConnectionException e) { log.error(“Unable to delete location ” + value, e); } final Collection valuesAfterRemoval = getValues(id); if (valuesAfterRemoval.size()!=(valuesBeforeRemoval.size()-1)) { log.error(“value ” […]