io.druid.java.util.common.guava

Class Sequences

java.lang.Object

io.druid.java.util.common.guava.Sequences

public class Sequences
extends Object

Constructor Summary

Constructors

Constructor and Description
Sequences()

Method Summary

Modifier and Type	Method and Description
static <T> Sequence<T>	concat(Iterable<Sequence<T>> sequences)
static <T> Sequence<T>	concat(Sequence<Sequence<T>> sequences)
static <T> Sequence<T>	concat(Sequence<T>... sequences)
static <T> Sequence<T>	empty()
static <T> Sequence<T>	filter(Sequence<T> sequence, com.google.common.base.Predicate<T> pred)
static <T> Sequence<T>	limit(Sequence<T> sequence, int limit)
static <From,To> Sequence<To>	map(Sequence<From> sequence, com.google.common.base.Function<From,To> fn)
static <T> Sequence<T>	simple(Iterable<T> iterable)
static <T> Sequence<T>	sort(Sequence<T> sequence, Comparator<T> comparator)
static <T,ListType extends List<T>> ListType	toList(Sequence<T> seq, ListType list)
static <T> Sequence<T>	withBaggage(Sequence<T> seq, Closeable baggage)
static <T> Sequence<T>	withEffect(Sequence<T> seq, Runnable effect, Executor exec)
static <T> Sequence<T>	wrap(Sequence<T> seq, SequenceWrapper wrapper) Allows to execute something before, after or around the processing of the given sequence.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Sequences

public Sequences()

Method Detail

simple

public static <T> Sequence<T> simple(Iterable<T> iterable)

empty

public static <T> Sequence<T> empty()

concat

public static <T> Sequence<T> concat(Sequence<T>... sequences)

concat

public static <T> Sequence<T> concat(Iterable<Sequence<T>> sequences)

concat

public static <T> Sequence<T> concat(Sequence<Sequence<T>> sequences)

map

public static <From,To> Sequence<To> map(Sequence<From> sequence,
                                         com.google.common.base.Function<From,To> fn)

filter

public static <T> Sequence<T> filter(Sequence<T> sequence,
                                     com.google.common.base.Predicate<T> pred)

limit

public static <T> Sequence<T> limit(Sequence<T> sequence,
                                    int limit)

withBaggage

public static <T> Sequence<T> withBaggage(Sequence<T> seq,
                                          Closeable baggage)

wrap

public static <T> Sequence<T> wrap(Sequence<T> seq,
                                   SequenceWrapper wrapper)

Allows to execute something before, after or around the processing of the given sequence. See documentation to SequenceWrapper methods for some details.

withEffect

public static <T> Sequence<T> withEffect(Sequence<T> seq,
                                         Runnable effect,
                                         Executor exec)

sort

public static <T> Sequence<T> sort(Sequence<T> sequence,
                                   Comparator<T> comparator)

toList

public static <T,ListType extends List<T>> ListType toList(Sequence<T> seq,
                                                           ListType list)