本文整理了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
暂无
代码示例来源: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;
}
}
内容来源于网络,如有侵权,请联系作者删除!