Pipeline<E> |
Pipeline.add(E e) |
<C extends Collection<E>>
Pipeline<E> |
Pipeline.addAll(C collection) |
Pipeline<E> |
Pipeline.clearNulls() |
<C extends Collection<E>>
Pipeline<E> |
Pipeline.concat(C another) |
Pipeline<E> |
Pipeline.concat(Pipeline<E> another) |
Pipeline<E> |
Pipeline.distinct() |
Pipeline<E> |
Pipeline.filter(Predicate<E> predicate) |
Pipeline<E> |
Pipeline.filter(Predicate<E> predicate,
Predicate<E> breakPredicate) |
Pipeline<E> |
Pipeline.findN(int n) |
Pipeline<E> |
Pipeline.findN(Predicate<E> predicate,
int n) |
<I,O> Pipeline<O> |
Pipeline.flatMap(Function<I,O> mapper) |
Pipeline<E> |
Pipeline.limit(int maxSize) |
Pipeline<E> |
Pipeline.listized() |
<O> Pipeline<O> |
Pipeline.map(Function<E,O> mapper) |
static <T> Pipeline<T> |
Pipeline.of(Iterable<T> iterable) |
static <T> Pipeline<T> |
Pipeline.of(Object anyObject) |
static <T> Pipeline<T> |
Pipeline.of(T... array) |
<K> Pipeline<List<E>> |
Pipeline.partitionBy(Function<E,K> classifier) |
<K> Pipeline<List<E>> |
Pipeline.partitionBy(Function2<Integer,E,K> classifier) |
Pipeline<E> |
Pipeline.shuffle() |
Pipeline<E> |
Pipeline.shuffle(Random random) |
Pipeline<E> |
Pipeline.skip(int n) |
Pipeline<E> |
Pipeline.sort(Comparator<E> comparator) |
Pipeline<E> |
Pipeline.sorted(Comparator<E> comparator) |
Pipeline<E> |
Pipeline.subPipeline(int offset,
int limit) |
Pipeline<E> |
Pipeline.swap(int i,
int j) |