本文整理了Java中org.apache.geode.cache.Region.keySetOnServer
方法的一些代码示例,展示了Region.keySetOnServer
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Region.keySetOnServer
方法的具体详情如下:
包路径:org.apache.geode.cache.Region
类名称:Region
方法名:keySetOnServer
[英]Returns a set of keys in the region on the server.
[中]返回服务器上区域中的一组密钥。
代码示例来源:origin: apache/geode
@Override
public Set<String> keySet() {
return getSessionRegion().keySetOnServer();
}
代码示例来源:origin: apache/geode
@Override
public Set keySetOnServer() {
try {
preOp();
return this.realRegion.keySetOnServer();
} finally {
postOp();
}
}
代码示例来源:origin: apache/geode
keySet = region.keySet();
} else {
keySet = region.keySetOnServer();
代码示例来源:origin: apache/geode-examples
Set<Integer> getValues() {
return new HashSet<>(region.keySetOnServer());
}
代码示例来源:origin: apache/geode-examples
Set<EmployeeKey> getValues() {
return new HashSet<>(region.keySetOnServer());
}
代码示例来源:origin: apache/geode-examples
Set<Integer> getValues() {
return new HashSet<>(region.keySetOnServer());
}
代码示例来源:origin: apache/geode-examples
Set<String> getKeys() {
return new HashSet<>(region.keySetOnServer());
}
代码示例来源:origin: apache/geode-examples
Set<Integer> getValues() {
return new HashSet<>(region.keySetOnServer());
}
代码示例来源:origin: org.apache.geode/geode-modules
@Override
public Set<String> keySet() {
return getSessionRegion().keySetOnServer();
}
代码示例来源:origin: apache/geode-examples
public void checkWords(Region<Integer, String> incomingRegion,
Region<String, String> outgoingRegion, List<String> words) {
int key = 0;
for (String word : words) {
incomingRegion.put(key++, word);
}
// Give the process a chance to work.
while (outgoingRegion.sizeOnServer() < words.size()) {
try {
Thread.sleep(500);
} catch (InterruptedException ie) {
// NOP
}
}
for (String candidate : outgoingRegion.keySetOnServer()) {
System.out.println(candidate + " -> " + outgoingRegion.get(candidate));
}
}
}
代码示例来源:origin: apache/geode-examples
public static void main(String[] args) throws NameResolutionException, TypeMismatchException,
QueryInvocationTargetException, FunctionDomainException {
// connect to the locator using default port 10334
ClientCache cache = new ClientCacheFactory().addPoolLocator("127.0.0.1", 10334)
.set("log-level", "WARN").create();
// create a region on the server
Region<Integer, EmployeeData> region =
cache.<Integer, EmployeeData>createClientRegionFactory(ClientRegionShortcut.PROXY)
.create(REGIONNAME);
// create a set of employee data and put it into the region
Map<Integer, EmployeeData> employees = createEmployeeData();
region.putAll(employees);
// count the values in the region
int inserted = region.keySetOnServer().size();
System.out.println(String.format("Counted %d keys in region %s", inserted, region.getName()));
// fetch and print all values in the region (without using a query)
region.keySetOnServer().forEach(key -> System.out.println(region.get(key)));
// do a set of queries, printing the results of each query
doQueries(cache);
cache.close();
}
内容来源于网络,如有侵权,请联系作者删除!