Interface | Description |
---|---|
ClockService |
A clock service which can get current processing time.
|
SliceAssigner |
A
SliceAssigner assigns element into a single slice. |
SliceSharedAssigner |
A
SliceAssigner which shares slices for windows, which means a window is divided into
multiple slices and need to merge the slices into windows when emitting windows. |
SliceSharedAssigner.MergeCallback |
Callback to be used in
SliceSharedAssigner.mergeSlices(long, MergeCallback) for specifying which slices
should be merged. |
SliceUnsharedAssigner |
A
SliceAssigner which doesn't share slices for windows, which means a window is divided
into only one slice and doesn't need to merge the slices when emitting windows. |
SlicingWindowProcessor<W> |
A processor that processes elements for slicing windows.
|
SlicingWindowProcessor.Context<W> |
Information available in an invocation of methods of
SlicingWindowProcessor . |
WindowTimerService<W> |
Interface for working with window time and timers which considers timezone for window splitting.
|
Class | Description |
---|---|
SliceAssigners |
Utilities to create
SliceAssigner s. |
SliceAssigners.CumulativeSliceAssigner |
The
SliceAssigner for cumulative windows. |
SliceAssigners.HoppingSliceAssigner |
The
SliceAssigner for hopping windows. |
SliceAssigners.SlicedSharedSliceAssigner |
The
SliceAssigner for elements have been attached slice end timestamp, and the slices
are shared. |
SliceAssigners.SlicedUnsharedSliceAssigner |
The
SliceAssigner for elements have been attached slice end timestamp, but the slices
are not shared, i.e. |
SliceAssigners.TumblingSliceAssigner |
The
SliceAssigner for tumbling windows. |
SliceAssigners.WindowedSliceAssigner |
The
SliceAssigner for elements have been attached window start and end timestamps. |
SlicingWindowOperator<K,W> |
The
SlicingWindowOperator implements an optimized processing for aligned windows which
can apply the slicing optimization. |
WindowTimerServiceImpl |
Simple Implements of
WindowTimerService . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.