本文整理了Java中org.apache.ignite.internal.util.typedef.F.size()
方法的一些代码示例,展示了F.size()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。F.size()
方法的具体详情如下:
包路径:org.apache.ignite.internal.util.typedef.F
类名称:F
方法名:size
暂无
代码示例来源:origin: apache/ignite
/** {@inheritDoc} */
@Override public int size() {
return F.size(col, preds);
}
代码示例来源:origin: apache/ignite
@Override public int size() {
return F.size(set, preds);
}
代码示例来源:origin: apache/ignite
/** {@inheritDoc} */
@Override public int size() {
return F.size(map.values(), filter);
}
代码示例来源:origin: apache/ignite
@Override public int size() {
return F.size(map.keySet(), preds);
}
代码示例来源:origin: apache/ignite
@Override public int size() {
return F.size(map.keySet(), preds);
}
代码示例来源:origin: apache/ignite
@Override public int size() {
return hasPred ? F.size(map.keySet(), preds) : map.size();
}
代码示例来源:origin: apache/ignite
@Override public int size() {
return F.size(iterator());
}
代码示例来源:origin: apache/ignite
@Override public int size() {
return !sealed ? F.size(iterator()) : size == -1 ? size = F.size(iterator()) : size;
}
代码示例来源:origin: apache/ignite
/** {@inheritDoc} */
@Override public int size() {
return F.size(iterator());
}
代码示例来源:origin: apache/ignite
/** {@inheritDoc} */
@Override public int size() {
return F.isEmpty(preds) ? col.size() : F.size(iterator());
}
代码示例来源:origin: apache/ignite
/**
*
*/
private long nearTxNum() {
IgnitePredicate<IgniteInternalTx> pred = new IgnitePredicate<IgniteInternalTx>() {
@Override public boolean apply(IgniteInternalTx tx) {
return tx.local() && tx.near();
}
};
return F.size(gridKernalCtx.cache().context().tm().activeTransactions(), pred);
}
代码示例来源:origin: apache/ignite
@Override public void apply(IgniteInternalFuture<Collection<byte[]>> fut) {
try {
Collection<byte[]> grpKeys = fut.result();
if (F.size(grpKeys, F.alwaysTrue()) != keyCnt)
res.onDone(false, fut.error());
IgniteInternalFuture<Boolean> dynStartCacheFut = after.apply(grpKeys);
dynStartCacheFut.listen(new IgniteInClosure<IgniteInternalFuture<Boolean>>() {
@Override public void apply(IgniteInternalFuture<Boolean> fut) {
try {
res.onDone(fut.get(), fut.error());
}
catch (IgniteCheckedException e) {
res.onDone(false, e);
}
}
});
}
catch (Exception e) {
res.onDone(false, e);
}
}
});
代码示例来源:origin: apache/ignite
Iterable<Integer> keys = primaryKeys(cache, 100);
info("Values [cache=" + caches.indexOf(cache) + ", size=" + F.size(keys.iterator()) + ", keys=" + keys + "]");
代码示例来源:origin: apache/ignite
Set<KeyCacheObject> mappedKeys = mapped.getValue();
int cnt = F.size(mappedKeys);
代码示例来源:origin: apache/ignite
int cnt = F.size(dhtMapping);
代码示例来源:origin: apache/ignite
assert !nodeId.equals(locNodeId);
int cnt = F.size(req.keys());
代码示例来源:origin: apache/ignite
/**
* @throws Exception If failed.
*/
private void lightCheckDynamicCache() throws Exception {
int nodes = F.size(G.allGrids());
for (int i = 0; i < nodes; i++) {
IgniteCache<Object, Object> jcache = ignite(i).cache(DYNAMIC_CACHE_NAME);
for (int k = 0; k < 20; k++) {
int key = i + k * nodes;
jcache.put(key, key);
}
}
for (int i = 0; i < nodes; i++) {
IgniteCache<Object, Object> jcache = ignite(i).cache(DYNAMIC_CACHE_NAME);
for (int k = 0; k < 20 * nodes; k++)
assertEquals(k, jcache.get(k));
}
for (int i = 0; i < nodes; i++) {
IgniteCache<Object, Object> jcache = ignite(i).cache(DYNAMIC_CACHE_NAME);
for (int k = 0; k < 20; k++) {
int key = i + k * nodes;
assertEquals(key, jcache.getAndRemove(key));
}
}
for (int i = 0; i < nodes; i++) {
IgniteCache<Object, Object> jcache = ignite(i).cache(DYNAMIC_CACHE_NAME);
for (int k = 0; k < 20 * nodes; k++)
assertNull(jcache.get(k));
}
}
代码示例来源:origin: apache/ignite
GridNearAtomicUpdateResponse res
) {
if (F.size(res.failedKeys()) == req.size())
return;
代码示例来源:origin: apache/ignite
GridDhtTxRemote tx = null;
int size = F.size(keys);
代码示例来源:origin: org.apache.ignite/ignite-core
/**
*
*/
private long nearTxNum() {
IgnitePredicate<IgniteInternalTx> pred = new IgnitePredicate<IgniteInternalTx>() {
@Override public boolean apply(IgniteInternalTx tx) {
return tx.local() && tx.near();
}
};
return F.size(gridKernalCtx.cache().context().tm().activeTransactions(), pred);
}
内容来源于网络,如有侵权,请联系作者删除!