org.apache.beam.sdk.fn.stream

Class PrefetchableIterables

java.lang.Object

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

public class PrefetchableIterables
extends java.lang.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 and 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 and Description
PrefetchableIterables()

Method Summary

Modifier and Type	Method and Description
static <T> PrefetchableIterable<T>	concat(java.lang.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(java.lang.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 Detail

PrefetchableIterables

public PrefetchableIterables()

Method Detail

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(java.lang.Iterable<T>... iterables)

Concatentates the Iterables.

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

limit

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

Limits the PrefetchableIterable to the specified number of elements.