本文整理了Java中org.apache.ignite.internal.util.typedef.F.iterator()
方法的一些代码示例,展示了F.iterator()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。F.iterator()
方法的具体详情如下:
包路径:org.apache.ignite.internal.util.typedef.F
类名称:F
方法名:iterator
暂无
代码示例来源:origin: apache/ignite
/**
* Creates and returns iterator from given collection and optional filtering predicates.
* Returned iterator will only have elements for which all given predicates evaluates to
* {@code true} (if provided). Note that this method will not create new collection but
* will simply "skip" elements in the provided collection that given predicates doesn't
* evaluate to {@code true} for.
*
* @param c Input collection.
* @param readOnly If {@code true}, then resulting iterator will not allow modifications
* to the underlying collection.
* @param p Optional filtering predicates.
* @param <T> Type of the collection elements.
* @return Iterator from given collection and optional filtering predicate.
*/
@SuppressWarnings({"unchecked"})
public static <T> GridIterator<T> iterator0(Iterable<? extends T> c, boolean readOnly,
IgnitePredicate<? super T>... p) {
return F.iterator(c, IDENTITY, readOnly, p);
}
代码示例来源:origin: apache/ignite
/** {@inheritDoc} */
@NotNull @Override public Iterator<T1> iterator() {
return F.<T2, T1>iterator(col, clos, true, preds);
}
代码示例来源:origin: apache/ignite
/** {@inheritDoc} */
@Override public GridIterator<IgniteUuid> iterator() {
return F.iterator(Collections.singleton(this), F.<IgniteUuid>identity(), true);
}
代码示例来源:origin: apache/ignite
GridIterator<Integer> iter = F.iterator(l, c, true, p1, p2);
代码示例来源:origin: apache/ignite
rows = F.iterator(plainRows, new IgniteClosure<Object, Value[]>() {
@Override public Value[] apply(Object o) {
Value[] row = (Value[])o;
代码示例来源:origin: apache/ignite
return F.concat(F.iterator(nodes,
node -> F.iterator(node.attributes().entrySet(),
attr -> createRow(
ses,
代码示例来源:origin: apache/ignite
cacheGroups = ctx.cache().cacheGroupDescriptors().values();
return F.iterator(cacheGroups,
grp -> createRow(
ses,
代码示例来源:origin: apache/ignite
caches = ctx.cache().cacheDescriptors().values();
return F.iterator(caches,
cache -> createRow(
ses,
代码示例来源:origin: org.apache.ignite/ignite-core
/**
* Creates and returns iterator from given collection and optional filtering predicates.
* Returned iterator will only have elements for which all given predicates evaluates to
* {@code true} (if provided). Note that this method will not create new collection but
* will simply "skip" elements in the provided collection that given predicates doesn't
* evaluate to {@code true} for.
*
* @param c Input collection.
* @param readOnly If {@code true}, then resulting iterator will not allow modifications
* to the underlying collection.
* @param p Optional filtering predicates.
* @param <T> Type of the collection elements.
* @return Iterator from given collection and optional filtering predicate.
*/
@SuppressWarnings({"unchecked"})
public static <T> GridIterator<T> iterator0(Iterable<? extends T> c, boolean readOnly,
IgnitePredicate<? super T>... p) {
return F.iterator(c, IDENTITY, readOnly, p);
}
代码示例来源:origin: org.apache.ignite/ignite-core
/** {@inheritDoc} */
@NotNull @Override public Iterator<T1> iterator() {
return F.<T2, T1>iterator(col, clos, true, preds);
}
代码示例来源:origin: org.apache.ignite/ignite-core
/** {@inheritDoc} */
@Override public GridIterator<IgniteUuid> iterator() {
return F.iterator(Collections.singleton(this), F.<IgniteUuid>identity(), true);
}
代码示例来源:origin: org.apache.ignite/ignite-core
return F.iterator(iterator(),
new IgniteClosure<Cache.Entry<K, V>, Cache.Entry<K, V>>() {
private IgniteCacheExpiryPolicy expiryPlc =
代码示例来源:origin: org.apache.ignite/ignite-indexing
rows = F.iterator(plainRows, new IgniteClosure<Object, Value[]>() {
@Override public Value[] apply(Object o) {
Value[] row = (Value[])o;
代码示例来源:origin: org.apache.ignite/ignite-indexing
AtomicLong rowKey = new AtomicLong();
return F.concat(F.iterator(nodes,
node -> F.iterator(node.attributes().entrySet(),
attr -> createRow(ses,
rowKey.incrementAndGet(),
内容来源于网络,如有侵权,请联系作者删除!