本文整理了Java中org.apache.geode.cache.Region.keySet
方法的一些代码示例,展示了Region.keySet
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Region.keySet
方法的具体详情如下:
包路径:org.apache.geode.cache.Region
类名称: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 ConcurrentModificationException
s 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
是不可修改的。它得到了这个地区的支持。访问或迭代此集合不需要同步。不会抛出ConcurrentModificationException
s,但在线程迭代时,可以向该集合添加或删除键。迭代器一次只能由一个线程使用。如果需要一个稳定的集合“快照”视图,那么调用集合上的一个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);
}
}
内容来源于网络,如有侵权,请联系作者删除!