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

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

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

F.isAll介绍

暂无

代码示例

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

/**
 * @param p Predicate.
 * @param n Node.
 * @return {@code True} if filter passed or empty.
 */
private boolean apply(IgnitePredicate<N>[] p, N n) {
  return F.isAll(n, p);
}

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

@Override public boolean contains(Object o) {
  return F.isAll((Entry<K, V>)o, entryPred) && map.entrySet().contains(o);
}

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

@Override public boolean contains(Object o) {
  return F.isAll((Entry<K, V>)o, entryPred) && map.entrySet().contains(o);
}

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

@Override public boolean contains(Object o) {
  return F.isAll((Entry<K, V>)o, entryPred) && map.entrySet().contains(o);
}

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

@Override public boolean remove(Object o) {
  return F.isAll((Entry<K, V>)o, entryPred) && map.entrySet().remove(o);
}

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

/**
 * @param c Collection.
 * @param cap Initial capacity.
 * @param p Optional filters.
 * @return Resulting array list.
 */
public static <T extends R, R> List<R> arrayList(Iterable<T> c, int cap,
  @Nullable IgnitePredicate<? super T>... p) {
  assert c != null;
  assert cap >= 0;
  List<R> list = new ArrayList<>(cap);
  for (T t : c) {
    if (F.isAll(t, p))
      list.add(t);
  }
  return list;
}

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

@Override public boolean apply(ClusterNode node) {
    return F.isAll(node, filter);
  }
});

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

/**
 * @param map Map (out parameter).
 * @param dep Deployment.
 * @param p Predicate.
 */
private void tasks(Map<String, Class<? extends ComputeTask<?, ?>>> map, GridDeployment dep,
  IgnitePredicate<? super Class<? extends ComputeTask<?, ?>>>[] p) {
  assert map != null;
  assert dep != null;
  for (Map.Entry<String, Class<?>> clsEntry : dep.deployedClassMap().entrySet()) {
    if (ComputeTask.class.isAssignableFrom(clsEntry.getValue())) {
      Class<? extends ComputeTask<?, ?>> taskCls = (Class<? extends ComputeTask<?, ?>>)clsEntry.getValue();
      if (F.isAll(taskCls, p))
        map.put(clsEntry.getKey(), taskCls);
    }
  }
}

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

/**
 * Converts array of integers into list.
 *
 * @param arr Array of integers.
 * @param p Optional predicate array.
 * @return List of integers.
 */
public static List<Integer> toIntList(@Nullable int[] arr, IgnitePredicate<Integer>... p) {
  if (arr == null || arr.length == 0)
    return Collections.emptyList();
  List<Integer> ret = new ArrayList<>(arr.length);
  if (F.isEmpty(p))
    for (int i : arr)
      ret.add(i);
  else {
    for (int i : arr)
      if (F.isAll(i, p))
        ret.add(i);
  }
  return ret;
}

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

@Override public boolean apply(GridCacheEntryEx ex) {
    if (ex instanceof GridCacheMapEntry)
      return ((GridCacheMapEntry)ex).visitable(filter);
    else
      return !ex.deleted() && F.isAll(ex, filter);
  }
};

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

/** {@inheritDoc} */
  @Override public boolean contains(Object o) {
    A.notNull(o, "o");

    for (Cache.Entry<K, V> e : map.values())
      if (F.isAll(e, filter) && F.eq(e.getValue(), o))
        return true;

    return false;
  }
}

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

if (!F.isAll(e, p))
  res.put(e.getKey(), e.getValue());

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

/**
 * Same as {@link GridFunc#isAll(Object, IgnitePredicate[])}, but safely unwraps exceptions.
 *
 * @param e Element.
 * @param p Predicates.
 * @param <E> Element type.
 * @return {@code True} if predicates passed.
 * @throws IgniteCheckedException If failed.
 */
public <E> boolean isAll(E e, @Nullable IgnitePredicate<? super E>[] p) throws IgniteCheckedException {
  if (F.isEmpty(p))
    return true;
  try {
    boolean pass = F.isAll(e, p);
    if (log.isDebugEnabled())
      log.debug("Evaluated filters for entry [pass=" + pass + ", entry=" + e + ", filters=" +
        Arrays.toString(p) + ']');
    return pass;
  }
  catch (RuntimeException ex) {
    throw U.cast(ex);
  }
}

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

/** {@inheritDoc} */
@Override public boolean remove(Object o) {
  A.notNull(o, "o");
  boolean rmv = false;
  for (Iterator<Cache.Entry<K, V>> it = map.values().iterator(); it.hasNext();) {
    Cache.Entry<K, V> e = it.next();
    if (F.isAll(e, filter) && F.eq(o, e.getValue())) {
      it.remove();
      ctx.grid().cache(ctx.name()).remove(e.getKey(), e.getValue());
      rmv = true;
    }
  }
  return rmv;
}

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

/**
 * @param p Predicate.
 * @param n Node.
 * @return {@code True} if filter passed or empty.
 */
private boolean apply(IgnitePredicate<N>[] p, N n) {
  return F.isAll(n, p);
}

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

@SuppressWarnings({"unchecked"})
@Override public boolean contains(Object o) {
  return F.isAll((Entry<K, V>)o, entryPred) && map.entrySet().contains(o);
}

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

@SuppressWarnings({"unchecked"})
@Override public boolean contains(Object o) {
  return F.isAll((Entry<K, V>)o, entryPred) && map.entrySet().contains(o);
}

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

@SuppressWarnings({"unchecked"})
@Override public boolean contains(Object o) {
  return F.isAll((Entry<K, V>)o, entryPred) && map.entrySet().contains(o);
}

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

@Override public boolean apply(GridCacheEntryEx ex) {
    if (ex instanceof GridCacheMapEntry)
      return ((GridCacheMapEntry)ex).visitable(filter);
    else
      return !ex.deleted() && F.isAll(ex, filter);
  }
};

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

/** {@inheritDoc} */
  @Override public boolean contains(Object o) {
    A.notNull(o, "o");

    for (Cache.Entry<K, V> e : map.values())
      if (F.isAll(e, filter) && F.eq(e.getValue(), o))
        return true;

    return false;
  }
}

相关文章