Package org.apache.beam.sdk.fn.stream

Class PrefetchableIterables

java.lang.Object

org.apache.beam.sdk.fn.stream.PrefetchableIterables

public class PrefetchableIterables
extends Object

This class contains static utility functions that operate on or return objects of type PrefetchableIterable.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PrefetchableIterables.Default<T>	A default implementation that caches an iterator to be returned when PrefetchableIterables.Default.prefetch() is invoked.

Constructor Summary

Constructors

Constructor	Description
PrefetchableIterables()

Method Summary

Modifier and Type	Method	Description
static <T> PrefetchableIterable<T>	concat(Iterable<T>... iterables)	Concatentates the Iterables.
static <T> PrefetchableIterable<T>	emptyIterable()	Returns an empty PrefetchableIterable.
static <T> PrefetchableIterable<T>	fromArray(T... values)	Returns a PrefetchableIterable over the specified values.
static <T> PrefetchableIterable<T>	limit(Iterable<T> iterable, int limit)	Limits the PrefetchableIterable to the specified number of elements.

Methods inherited from class java.lang.Object

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

Constructor Details

PrefetchableIterables

public PrefetchableIterables()

Method Details

emptyIterable

public static <T> PrefetchableIterable<T> emptyIterable()

Returns an empty PrefetchableIterable.

fromArray

public static <T> PrefetchableIterable<T> fromArray(T... values)

Returns a PrefetchableIterable over the specified values.

PrefetchableIterator.prefetch() is a no-op and PrefetchableIterator.isReady() always returns true.

concat

public static <T> PrefetchableIterable<T> concat(Iterable<T>... iterables)

Concatentates the Iterables.

See PrefetchableIterators.concat(java.util.Iterator<T>...) for additional details.

limit

public static <T> PrefetchableIterable<T> limit(Iterable<T> iterable,
 int limit)

Limits the PrefetchableIterable to the specified number of elements.