org.apache.beam.sdk.fn.stream

Class PrefetchableIterables.Default<T>

java.lang.Object

org.apache.beam.sdk.fn.stream.PrefetchableIterables.Default<T>

All Implemented Interfaces:

java.lang.Iterable<T>, PrefetchableIterable<T>

Enclosing class:

PrefetchableIterables

public abstract static class PrefetchableIterables.Default<T>
extends java.lang.Object
implements PrefetchableIterable<T>

A default implementation that caches an iterator to be returned when prefetch() is invoked.

Constructor Summary

Constructors

Constructor and Description
Default()

Method Summary

Modifier and Type	Method and Description
protected abstract PrefetchableIterator<T>	createIterator()
PrefetchableIterator<T>	iterator()
void	prefetch() Ensures that the next iterator returned has been prefetched.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

Default

public Default()

Method Detail

prefetch

public final void prefetch()

Description copied from interface: PrefetchableIterable

Ensures that the next iterator returned has been prefetched.

Specified by:

prefetch in interface PrefetchableIterable<T>

iterator

public final PrefetchableIterator<T> iterator()

Specified by:

iterator in interface java.lang.Iterable<T>

Specified by:

iterator in interface PrefetchableIterable<T>

createIterator

protected abstract PrefetchableIterator<T> createIterator()