@Override
public void updatingValues(TransactionBase tx,
Iterator<org.apache.fluo.recipes.core.map.Update<String, Long>> updates) {
TypedTransactionBase ttx = tl.wrap(tx);
Map<String, Long> expectedOld = new HashMap<>();
while (updates.hasNext()) {
org.apache.fluo.recipes.core.map.Update<String, Long> update = updates.next();
if (update.getOldValue().isPresent()) {
expectedOld.put("side:" + update.getKey(), update.getOldValue().get());
}
ttx.mutate().row("side:" + update.getKey()).col(DSCOL).set(update.getNewValue().get());
}
// get last values set to verify same as passed in old value
Map<String, Long> actualOld = Maps.transformValues(
ttx.get().rowsString(expectedOld.keySet()).columns(ImmutableSet.of(DSCOL)).toStringMap(),
m -> m.get(DSCOL).toLong());
MapDifference<String, Long> diff = Maps.difference(expectedOld, actualOld);
Assert.assertTrue(diff.toString(), diff.areEqual());
globalUpdates.incrementAndGet();
}
java类com.google.common.collect.MapDifference的实例源码
BigUpdateIT.java 文件源码
项目:fluo-recipes
阅读 15
收藏 0
点赞 0
评论 0
OptionsConfigurationBlock.java 文件源码
项目:bts
阅读 50
收藏 0
点赞 0
评论 0
public Map<String, ValueDifference<String>> getPreferenceChanges() {
Map<String, String> currentSettings = Maps.newHashMapWithExpectedSize(keys.length);
for (String key : keys) {
currentSettings.put(key, preferenceStore.getString(key));
}
MapDifference<String, String> mapDifference = Maps.difference(currentSettings, originalSettings);
Map<String, ValueDifference<String>> entriesDiffering = mapDifference.entriesDiffering();
return entriesDiffering;
}
ParametersWrapperBase.java 文件源码
项目:r01fb
阅读 16
收藏 0
点赞 0
评论 0
@Override
public boolean equals(final Object other) {
if (other instanceof ParametersWrapperBase
&& other.getClass() == this.getClass()) {
ParametersWrapperBase<?> pw = (ParametersWrapperBase<?>)other;
Map<String,String> otherParams = pw.getParams();
MapDifference<String,String> diff = Maps.difference(_params,otherParams);
return diff.entriesInCommon().size() == _params.size() && diff.entriesInCommon().size() == otherParams.size();
}
return false;
}
SchemaKeyspace.java 文件源码
项目:scylla-tools-java
阅读 15
收藏 0
点赞 0
评论 0
private static MapDifference<String, IndexMetadata> indexesDiff(Indexes before, Indexes after)
{
Map<String, IndexMetadata> beforeMap = new HashMap<>();
before.forEach(i -> beforeMap.put(i.name, i));
Map<String, IndexMetadata> afterMap = new HashMap<>();
after.forEach(i -> afterMap.put(i.name, i));
return Maps.difference(beforeMap, afterMap);
}
SchemaKeyspace.java 文件源码
项目:scylla-tools-java
阅读 15
收藏 0
点赞 0
评论 0
private static MapDifference<String, TriggerMetadata> triggersDiff(Triggers before, Triggers after)
{
Map<String, TriggerMetadata> beforeMap = new HashMap<>();
before.forEach(t -> beforeMap.put(t.name, t));
Map<String, TriggerMetadata> afterMap = new HashMap<>();
after.forEach(t -> afterMap.put(t.name, t));
return Maps.difference(beforeMap, afterMap);
}
MapTuple.java 文件源码
项目:motherbrain
阅读 20
收藏 0
点赞 0
评论 0
public final boolean equalsTuple(Object oo, boolean print) {
if (oo != null && oo instanceof MapTuple) {
MapTuple t = (MapTuple)oo;
MapDifference<String, Object> diff = Maps.difference(t._values, this._values);
if (diff.areEqual()) {
return true;
} else {
if (print) {
System.err.println(diff);
}
}
}
return false;
}
GoogleCloudStorageTest.java 文件源码
项目:bigdata-interop
阅读 20
收藏 0
点赞 0
评论 0
static <K, V> void assertMapsEqual(
Map<K, V> expected, Map<K, V> result, Equivalence<V> valueEquivalence) {
MapDifference<K, V> difference = Maps.difference(expected, result, valueEquivalence);
if (!difference.areEqual()) {
StringBuilder builder = new StringBuilder();
builder.append("Maps differ. ");
builder.append("Entries differing: ").append(difference.entriesDiffering()).append("\n");
builder.append("Missing entries: ").append(difference.entriesOnlyOnLeft()).append("\n");
builder.append("Extra entries: ").append(difference.entriesOnlyOnRight()).append("\n");
fail(builder.toString());
}
}
MapDifferenceExample.java 文件源码
项目:java-util-examples
阅读 15
收藏 0
点赞 0
评论 0
@Test
public void entries_only_on_left() {
MapDifference<Integer, Student> mapDifference = Maps.difference(
geometryClass, gymClass);
Map<Integer, Student> studentsOnLeft = mapDifference
.entriesOnlyOnLeft();
logger.info(studentsOnLeft);
assertThat(studentsOnLeft, hasKey(new Integer(456)));
assertThat(studentsOnLeft, hasKey(new Integer(912)));
}
MapDifferenceExample.java 文件源码
项目:java-util-examples
阅读 15
收藏 0
点赞 0
评论 0
@Test
public void entries_only_on_right() {
MapDifference<Integer, Student> mapDifference = Maps.difference(
geometryClass, gymClass);
Map<Integer, Student> studentsOnTheRight = mapDifference
.entriesOnlyOnRight();
logger.info(studentsOnTheRight);
assertThat(studentsOnTheRight, hasKey(new Integer(478)));
assertThat(studentsOnTheRight, hasKey(new Integer(937)));
}
SheetAliasDependencyManager.java 文件源码
项目:netxilia
阅读 14
收藏 0
点赞 0
评论 0
public void saveSheet(SheetData sheetData, Collection<SheetData.Property> properties) {
if (properties != null && properties.contains(SheetData.Property.aliases)) {
// check which alias changed
// make a diff between the stored version of aliases and the new list
MapDifference<Alias, AreaReference> diff = Maps.difference(previousAliases, sheetData.getAliases());
previousAliases = new HashMap<Alias, AreaReference>(sheetData.getAliases());
workbookAliasDependencyManager.refreshAliases(sheet.getName(), diff.entriesDiffering().keySet(), diff
.entriesOnlyOnLeft().keySet());
}
}