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

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

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

F.not介绍

暂无

代码示例

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

/**
 * Gets server nodes topology by specified version from snapshots history storage.
 *
 * @param topVer Topology version.
 * @return Server topology nodes.
 */
public Collection<ClusterNode> serverTopologyNodes(long topVer) {
  return F.view(topology(topVer), F.not(FILTER_CLI), FILTER_NOT_DAEMON);
}

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

/** {@inheritDoc} */
@Override public ClusterGroup forOthers(ClusterGroup grp) {
  A.notNull(grp, "grp");
  if (ids != null) {
    guard();
    try {
      Set<UUID> nodeIds = U.newHashSet(ids.size());
      for (UUID id : ids) {
        ClusterNode n = node(id);
        if (n != null && !grp.predicate().apply(n))
          nodeIds.add(id);
      }
      return new ClusterGroupAdapter(ctx, subjId, nodeIds);
    }
    finally {
      unguard();
    }
  }
  else
    return forPredicate(F.not(grp.predicate()));
}

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

/**
 * @return Cache configuration with query entities in {@code PUBLIC} schema.
 */
private CacheConfiguration cacheConfigurationForIndexingInPublicSchema() {
  return cacheConfigurationForIndexing()
    .setName(INDEXED_CACHE_NAME_2)
    .setSqlSchema(QueryUtils.DFLT_SCHEMA)
    .setNodeFilter(F.not(new DynamicIndexAbstractSelfTest.NodeFilter()));
}

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

Collection<ClusterNode> srvNodes = F.view(discoCache.allNodes(), F.not(FILTER_CLI));

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

cfg.setNodeFilter(F.not(NODE_FILTER));

代码示例来源:origin: org.apache.ignite/ignite-core

/**
 * Gets server nodes topology by specified version from snapshots history storage.
 *
 * @param topVer Topology version.
 * @return Server topology nodes.
 */
public Collection<ClusterNode> serverTopologyNodes(long topVer) {
  return F.view(topology(topVer), F.not(FILTER_CLI), FILTER_NOT_DAEMON);
}

代码示例来源:origin: org.apache.ignite/ignite-core

/** {@inheritDoc} */
@Override public ClusterGroup forOthers(ClusterGroup grp) {
  A.notNull(grp, "grp");
  if (ids != null) {
    guard();
    try {
      Set<UUID> nodeIds = U.newHashSet(ids.size());
      for (UUID id : ids) {
        ClusterNode n = node(id);
        if (n != null && !grp.predicate().apply(n))
          nodeIds.add(id);
      }
      return new ClusterGroupAdapter(ctx, subjId, nodeIds);
    }
    finally {
      unguard();
    }
  }
  else
    return forPredicate(F.not(grp.predicate()));
}

代码示例来源:origin: org.apache.ignite/ignite-core

Collection<ClusterNode> srvNodes = F.view(discoCache.allNodes(), F.not(FILTER_CLI));

相关文章