org.apache.ignite.internal.util.typedef.F.size()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(3.9k)|赞(0)|评价(0)|浏览(69)

本文整理了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

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);
}

相关文章