java类com.google.common.collect.MapDifference的实例源码

BigUpdateIT.java 文件源码 项目:fluo-recipes 阅读 15 收藏 0 点赞 0 评论 0
@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();
}
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());

    }
}


问题


面经


文章

微信
公众号

扫码关注公众号