org.janusgraph.diskstorage.keycolumnvalue.KCVMutation.hasDeletions()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(1.6k)|赞(0)|评价(0)|浏览(102)

本文整理了Java中org.janusgraph.diskstorage.keycolumnvalue.KCVMutation.hasDeletions()方法的一些代码示例,展示了KCVMutation.hasDeletions()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。KCVMutation.hasDeletions()方法的具体详情如下:
包路径:org.janusgraph.diskstorage.keycolumnvalue.KCVMutation
类名称:KCVMutation
方法名:hasDeletions

KCVMutation.hasDeletions介绍

暂无

代码示例

代码示例来源:origin: JanusGraph/janusgraph

@Override
public void mutateMany(Map<String, Map<StaticBuffer, KCVMutation>> mutations, StoreTransaction txh) throws BackendException {
  final Map<String, KVMutation> converted = new HashMap<>(mutations.size());
  for (Map.Entry<String, Map<StaticBuffer, KCVMutation>> storeEntry : mutations.entrySet()) {
    OrderedKeyValueStoreAdapter store = openDatabase(storeEntry.getKey());
    Preconditions.checkNotNull(store);
    KVMutation mut = new KVMutation();
    for (Map.Entry<StaticBuffer, KCVMutation> entry : storeEntry.getValue().entrySet()) {
      StaticBuffer key = entry.getKey();
      KCVMutation mutation = entry.getValue();
      if (mutation.hasAdditions()) {
        for (Entry addition : mutation.getAdditions()) {
          mut.addition(store.concatenate(key,addition));
        }
      }
      if (mutation.hasDeletions()) {
        for (StaticBuffer del : mutation.getDeletions()) {
          mut.deletion(store.concatenate(key, del));
        }
      }
    }
    converted.put(storeEntry.getKey(), mut);
  }
  manager.mutateMany(converted, txh);
}

代码示例来源:origin: org.apache.atlas/atlas-janusgraph-hbase2

if (mutation.hasDeletions()) {
  if (commands.getSecond() == null) {
    Delete d = new Delete(key);

代码示例来源:origin: awslabs/dynamodb-janusgraph-storage-backend

if (mutation.hasDeletions() && !mutation.hasAdditions()) {
  worker = new SingleUpdateWithCleanupWorker(request, client.getDelegate());
} else {

相关文章