Class and Description |
---|
SliceAssigner
A
SliceAssigner assigns element into a single slice. |
Class and Description |
---|
SliceAssigner
A
SliceAssigner assigns element into a single slice. |
SlicingWindowOperator
The
SlicingWindowOperator implements an optimized processing for aligned windows which
can apply the slicing optimization. |
Class and Description |
---|
WindowTimerService
Interface for working with window time and timers which considers timezone for window splitting.
|
Class and Description |
---|
WindowTimerService
Interface for working with window time and timers which considers timezone for window splitting.
|
Class and 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
A processor that processes elements for slicing windows.
|
SlicingWindowProcessor.Context
Information available in an invocation of methods of
SlicingWindowProcessor . |
WindowTimerService
Interface for working with window time and timers which considers timezone for window splitting.
|
Class and Description |
---|
SlicingWindowOperator
The
SlicingWindowOperator implements an optimized processing for aligned windows which
can apply the slicing optimization. |
Class and Description |
---|
WindowTimerService
Interface for working with window time and timers which considers timezone for window splitting.
|
Class and Description |
---|
SlicingWindowProcessor
A processor that processes elements for slicing windows.
|
SlicingWindowProcessor.Context
Information available in an invocation of methods of
SlicingWindowProcessor . |
Class and Description |
---|
SlicingWindowOperator
The
SlicingWindowOperator implements an optimized processing for aligned windows which
can apply the slicing optimization. |
Class and Description |
---|
WindowTimerService
Interface for working with window time and timers which considers timezone for window splitting.
|
Class and Description |
---|
SlicingWindowProcessor
A processor that processes elements for slicing windows.
|
SlicingWindowProcessor.Context
Information available in an invocation of methods of
SlicingWindowProcessor . |
Class and Description |
---|
WindowTimerService
Interface for working with window time and timers which considers timezone for window splitting.
|
Class and Description |
---|
ClockService
A clock service which can get current processing time.
|
SliceAssigner
A
SliceAssigner assigns element into a single slice. |
SliceAssigners.CumulativeSliceAssigner
The
SliceAssigner for cumulative windows. |
SliceAssigners.HoppingSliceAssigner
The
SliceAssigner for hopping windows. |
SliceAssigners.TumblingSliceAssigner
The
SliceAssigner for tumbling windows. |
SliceAssigners.WindowedSliceAssigner
The
SliceAssigner for elements have been attached window start and end timestamps. |
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
A processor that processes elements for slicing windows.
|
SlicingWindowProcessor.Context
Information available in an invocation of methods of
SlicingWindowProcessor . |
WindowTimerService
Interface for working with window time and timers which considers timezone for window splitting.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.