com.splicemachine.stream

Interface MeasuredStream<T,V extends Stats>

All Superinterfaces:

java.lang.AutoCloseable, Stream<T>

All Known Implementing Classes:

AbstractMeasuredStream, ForwardingMeasuredStream, MeasuredStreams.FilteredMeasuredStream, MeasuredStreams.LimitedStream, MeasuredStreams.TransformingMeasuredStream

public interface MeasuredStream<T,V extends Stats>
extends Stream<T>

Method Summary

Modifier and Type	Method and Description
MeasuredStream<T,V>	filter(Predicate<T> predicate) Filter elements out of the stream which do not match the supplied predicate.
V	getStats()
MeasuredStream<T,V>	limit(long maxSize) Limit the number of elements returned by the stream.
<R> MeasuredStream<R,V>	transform(Transformer<T,R> transformer) Transform the stream in an arbitrary way.

Methods inherited from interface com.splicemachine.stream.Stream

asIterator, close, forEach, next

Method Detail

getStats

V getStats()

Returns:

stats collected as of this point in time. If the stream has not been exhausted, then calling next() may change the value of the returned stats. This change may or may not be reflected in the stats returned, depending on the implementation.

transform

<R> MeasuredStream<R,V> transform(Transformer<T,R> transformer)

Description copied from interface: Stream

Transform the stream in an arbitrary way. Implementations are allowed to be lazy--i.e. not actually performing the transform until next() is called.

The returned Stream is also Autocloseable; closing the returned Stream should also close this stream. This is to simplify close-handling.

Specified by:

transform in interface Stream<T>

Type Parameters:

R - the new type of the returned stream.

Parameters:

transformer - the transformer to use.

Returns:

a Stream representing the transformed stream of data.

filter

MeasuredStream<T,V> filter(Predicate<T> predicate)

Description copied from interface: Stream

Filter elements out of the stream which do not match the supplied predicate. The returned Stream is also AutoCloseable; closing the returned Stream should also close this stream, so as to make resource-handling simpler.

Specified by:

filter in interface Stream<T>

Parameters:

predicate - the predicate to apply

Returns:

a Stream representing the filtered stream of data.

limit

MeasuredStream<T,V> limit(long maxSize)

Description copied from interface: Stream

Limit the number of elements returned by the stream. The returned Stream is also AutoCloseable; closing the returned Stream should also close this stream, so as to make resource-handling simpler.

Specified by:

limit in interface Stream<T>

Parameters:

maxSize - the maximum number of elements to return in the stream

Returns:

a Stream representing the first maxSize elements in the stream (or less, if fewer than maxSize is present in the original stream).