org.apache.flink.table.runtime.operators.aggregate.window.processors

Class SliceUnsharedWindowAggProcessor

java.lang.Object

org.apache.flink.table.runtime.operators.aggregate.window.processors.AbstractWindowAggProcessor

org.apache.flink.table.runtime.operators.aggregate.window.processors.SliceUnsharedWindowAggProcessor

All Implemented Interfaces:

Serializable, SlicingWindowProcessor<Long>

public final class SliceUnsharedWindowAggProcessor
extends AbstractWindowAggProcessor

An window aggregate processor implementation which works for SliceUnsharedAssigner, e.g. tumbling windows.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.runtime.operators.window.slicing.SlicingWindowProcessor

SlicingWindowProcessor.Context<W>

Field Summary

Fields inherited from class org.apache.flink.table.runtime.operators.aggregate.window.processors.AbstractWindowAggProcessor

accSerializer, aggregator, clockService, ctx, currentProgress, genAggsHandler, isEventTime, reuseOutput, shiftTimeZone, sliceAssigner, useDayLightSaving, windowBuffer, windowBufferFactory, windowInterval, windowState, windowTimerService

Constructor Summary

Constructors

Constructor and Description
SliceUnsharedWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, WindowBuffer.Factory windowBufferFactory, SliceUnsharedAssigner sliceAssigner, TypeSerializer<RowData> accSerializer, java.time.ZoneId shiftTimeZone)

Method Summary

Modifier and Type	Method and Description
void	fireWindow(Long windowEnd) Emit results of the given window.
protected long	sliceStateMergeTarget(long sliceToMerge) Returns the slice state target to merge the given slice into when firing windows.

Methods inherited from class org.apache.flink.table.runtime.operators.aggregate.window.processors.AbstractWindowAggProcessor

advanceProgress, clearWindow, close, collect, createWindowSerializer, initializeWatermark, open, prepareCheckpoint, processElement

Methods inherited from class java.lang.Object

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

Constructor Detail

SliceUnsharedWindowAggProcessor

public SliceUnsharedWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler,
                                       WindowBuffer.Factory windowBufferFactory,
                                       SliceUnsharedAssigner sliceAssigner,
                                       TypeSerializer<RowData> accSerializer,
                                       java.time.ZoneId shiftTimeZone)

Method Detail

fireWindow

public void fireWindow(Long windowEnd)
                throws Exception

Description copied from interface: SlicingWindowProcessor

Emit results of the given window.

Note: the key context has been set.

Parameters:

windowEnd - the window to emit

Throws:

Exception

sliceStateMergeTarget

protected long sliceStateMergeTarget(long sliceToMerge)
                              throws Exception

Description copied from class: AbstractWindowAggProcessor

Returns the slice state target to merge the given slice into when firing windows. For unshared windows, there should no merging happens, so the merge target should be just the given sliceToMerge. For shared windows, the merge target should be the shared slice state.

Specified by:

sliceStateMergeTarget in class AbstractWindowAggProcessor

Throws:

Exception

See Also:

SliceSharedAssigner.mergeSlices(long, SliceSharedAssigner.MergeCallback)