org.apache.geode.cache.Region.keySet()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(5.0k)|赞(0)|评价(0)|浏览(159)

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

Region.keySet介绍

[英]Returns a set of keys in the region.

This Set is unmodifiable. It is backed by this region. Synchronization is not necessary to access or iterate over this set. No ConcurrentModificationExceptions will be thrown, but keys may be added or removed to this set while a thread is iterating. Iterators are intended to be used by one thread at a time. If a stable "snapshot" view of the set is required, then call one of the toArray methods on the set and iterate over the array. If you need to lock down the region so this set is not modified while it is being accessed, use global scope with a distributed lock.
[中]返回区域中的一组键。
这个Set是不可修改的。它得到了这个地区的支持。访问或迭代此集合不需要同步。不会抛出ConcurrentModificationExceptions,但在线程迭代时,可以向该集合添加或删除键。迭代器一次只能由一个线程使用。如果需要一个稳定的集合“快照”视图,那么调用集合上的一个toArray方法并迭代数组。如果需要锁定该区域,以便在访问该区域时不修改该集合,请使用带有分布式锁的全局作用域。

代码示例

代码示例来源:origin: apache/geode

@Override
public Set<K> keySet() {
 return region.keySet();
}

代码示例来源:origin: apache/geode

public Set keys() {
 return this.region.keySet();
}

代码示例来源:origin: apache/geode

public Set keySet() {
 return this.region.keySet();
}

代码示例来源:origin: apache/geode

public Set<String> metaKeySet() {
 return this.redisMetaRegion.keySet();
}

代码示例来源:origin: apache/geode

@Override
public Set keySet() {
 return map.keySet();
}

代码示例来源:origin: apache/geode

@Override
 public String description() {
  return "Expected region entries: " + regionSize + " but actual entries: "
    + r.keySet().size() + " present region keyset " + r.keySet();
 }
};

代码示例来源:origin: apache/geode

@Override
public boolean done() {
 if (r.keySet().size() == regionSize) {
  return true;
 }
 return false;
}

代码示例来源:origin: apache/geode

public String displayContent() {
  return this.region.keySet().toString();
 }
}

代码示例来源:origin: apache/geode

/**
 * Returns the number of keys in this index.
 */
@Override
public long getNumberOfKeys() {
 return getRegion().keySet().size();
}

代码示例来源:origin: apache/geode

@Override
public Set<String> keySet() {
 return getSessionRegion().keySet();
}

代码示例来源:origin: apache/geode

public void calcSize(Region r) {
 if (cancelled) {
  return;
 }
 Set nameSet = r.keySet();
 if (cancelled) {
  return;
 }
 this.entryCount = nameSet.size();
 Set subRegions = r.subregions(false);
 if (cancelled) {
  return;
 }
 this.subregionCount = subRegions.size();
}

代码示例来源:origin: apache/geode

public Set<String> getGroups() {
 return getConfigurationRegion().keySet();
}

代码示例来源:origin: apache/geode

public String dumpAllPartitionedRegions() {
 StringBuilder sb = new StringBuilder(this.prRoot.getFullPath());
 sb.append("\n");
 Object key = null;
 for (Iterator i = this.prRoot.keySet().iterator(); i.hasNext();) {
  key = i.next();
  sb.append(key).append("=>").append(this.prRoot.get(key));
  if (i.hasNext()) {
   sb.append("\n");
  }
 }
 return sb.toString();
}

代码示例来源:origin: apache/geode

@Override
public <K> Set<K> keySet(String regionName) {
 security.authorize(DATA, READ, regionName, ALL);
 return ((Region<K, ?>) getRegion(regionName)).keySet();
}

代码示例来源:origin: apache/geode

@Override
public Set keySet() {
 try {
  preOp();
  return this.realRegion.keySet();
 } finally {
  postOp();
 }
}

代码示例来源:origin: apache/geode

public Map<String, Configuration> getEntireConfiguration() {
 Set<String> keys = getConfigurationRegion().keySet();
 return getConfigurationRegion().getAll(keys);
}

代码示例来源:origin: apache/geode

@Before
public void setUp() throws Exception {
 Region regionStub = mock(Region.class);
 when(regionStub.keySet())
   .thenReturn(new HashSet<String>(Arrays.asList(TEST_KEY1, TEST_KEY2, TEST_KEY3)));
 when(cacheStub.getRegion(TEST_REGION)).thenReturn(regionStub);
 operationHandler = new KeySetOperationHandler();
}

代码示例来源:origin: apache/geode

@Test
public void keySet() {
 authorize(DATA, READ, REGION, ALL);
 authorizingCache.keySet(REGION);
 verify(region).keySet();
}

代码示例来源:origin: apache/geode

/**
 * Returns unmodifiable SelectResults for keys. When the "keys" attribute is accessed, this is the
 * preferred method that will be executed.
 */
public SelectResults getKeys() {
 ResultsCollectionWrapper res;
 if (this.region instanceof LocalDataSet) {
  LocalDataSet localData = (LocalDataSet) this.region;
  res = new ResultsCollectionWrapper(getKeyType(), localData.localKeys());
 } else {
  res = new ResultsCollectionWrapper(getKeyType(), this.region.keySet());
 }
 res.setModifiable(false);
 return res;
}

代码示例来源:origin: apache/geode

@Override
 public void executeCommand(Command command, ExecutionHandlerContext context) {
  List<byte[]> commandElems = command.getProcessedCommand();

  if (commandElems.size() < 2) {
   command.setResponse(Coder.getErrorResponse(context.getByteBufAllocator(), ArityDef.SMEMBERS));
   return;
  }

  ByteArrayWrapper key = command.getKey();
  checkDataType(key, RedisDataType.REDIS_SET, context);
  @SuppressWarnings("unchecked")
  Region<ByteArrayWrapper, Boolean> keyRegion =
    (Region<ByteArrayWrapper, Boolean>) context.getRegionProvider().getRegion(key);

  if (keyRegion == null) {
   command.setResponse(Coder.getEmptyArrayResponse(context.getByteBufAllocator()));
   return;
  }

  Set<ByteArrayWrapper> members = new HashSet(keyRegion.keySet()); // Emulate copy on read
  respondBulkStrings(command, context, members);
 }
}

相关文章

微信公众号

最新文章

更多