Interface StreamWindow<I,O>
-
- All Known Implementing Classes:
FixedTimeStreamWindow
public interface StreamWindow<I,O>
A StreamWindow governs buffering and sending rows to a sub-transformation. Windowing strategies could include sending buffered rows * after a given interval * on a sliding interval * after a fixed number of rows have been read. *
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Iterable<O>
buffer(io.reactivex.Flowable<I> flowable)
Takes an iterable (would typically be aStreamSource.flowable()
} call) and buffers it according to the window strategy.
-
-
-
Method Detail
-
buffer
Iterable<O> buffer(io.reactivex.Flowable<I> flowable)
Takes an iterable (would typically be aStreamSource.flowable()
} call) and buffers it according to the window strategy. Returns an iterable of data for the window. Depending on stream implementation, the output could also be transformed. For example, theFixedTimeStreamWindow
will pass windowed data to a subtransformation, and return the transformed results.
-
-