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

Class SliceSharedSyncStateWindowAggProcessor

java.lang.Object

org.apache.flink.table.runtime.operators.aggregate.window.processors.WindowAggProcessorBase<W,SyncStateWindowProcessor.SyncStateContext<W>>

org.apache.flink.table.runtime.operators.aggregate.window.processors.AbstractSyncStateWindowAggProcessor<Long>

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

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

All Implemented Interfaces:

Serializable, MergeCallback<Long,Iterable<Long>>, SyncStateWindowProcessor<Long>, WindowProcessor<Long,SyncStateWindowProcessor.SyncStateContext<Long>>, SlicingSyncStateWindowProcessor<Long>

public final class SliceSharedSyncStateWindowAggProcessor
extends AbstractSliceSyncStateWindowAggProcessor
implements MergeCallback<Long,Iterable<Long>>

A window aggregate processor implementation which works for SliceSharedAssigner, e.g. hopping windows and cumulative windows.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.table.runtime.operators.aggregate.window.processors.AbstractSyncStateWindowAggProcessor

AbstractSyncStateWindowAggProcessor.WindowIsEmptySupplier

Nested classes/interfaces inherited from interface org.apache.flink.table.runtime.operators.window.tvf.common.SyncStateWindowProcessor

SyncStateWindowProcessor.SyncStateContext<W>

Nested classes/interfaces inherited from interface org.apache.flink.table.runtime.operators.window.tvf.common.WindowProcessor

WindowProcessor.Context<W>

Field Summary

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

sliceAssigner, windowBuffer, windowBufferFactory, windowInterval

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

emptySupplier, windowState

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

accSerializer, aggregator, clockService, ctx, currentProgress, genAggsHandler, isEventTime, reuseOutput, shiftTimeZone, useDayLightSaving, windowTimerService

Constructor Summary

Constructors

Constructor	Description
SliceSharedSyncStateWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler, WindowBuffer.Factory bufferFactory, SliceSharedAssigner sliceAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer, int indexOfCountStar, ZoneId shiftTimeZone)

Method Summary

Modifier and Type	Method	Description
void	fireWindow(long timerTimestamp, Long windowEnd)	Emit results of the given window.
void	merge(Long mergeResult, Iterable<Long> toBeMerged)	Specifies that states of the given windows or slices should be merged into the result window or slice.
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.AbstractSliceSyncStateWindowAggProcessor

advanceProgress, clearWindow, close, createWindowSerializer, getWindowTimerService, open, prepareCheckpoint, processElement

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

collect, prepareAggregator

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

collect, initializeWatermark

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.runtime.operators.window.tvf.common.WindowProcessor

initializeWatermark

Constructor Detail

SliceSharedSyncStateWindowAggProcessor

public SliceSharedSyncStateWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler,
                                              WindowBuffer.Factory bufferFactory,
                                              SliceSharedAssigner sliceAssigner,
                                              org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer,
                                              int indexOfCountStar,
                                              ZoneId shiftTimeZone)

Method Detail

fireWindow

public void fireWindow(long timerTimestamp,
                       Long windowEnd)
                throws Exception

Description copied from interface: SyncStateWindowProcessor

Emit results of the given window.

Note: the key context has been set.

Specified by:

fireWindow in interface SyncStateWindowProcessor<Long>

Parameters:

timerTimestamp - the fired timestamp

windowEnd - the window to emit

Throws:

Exception

merge

public void merge(@Nullable
                  Long mergeResult,
                  Iterable<Long> toBeMerged)
           throws Exception

Description copied from interface: MergeCallback

Specifies that states of the given windows or slices should be merged into the result window or slice.

Specified by:

merge in interface MergeCallback<Long,Iterable<Long>>

Parameters:

mergeResult - The resulting merged window or slice, null if it represents a non-state namespace.

toBeMerged - Windows or slices that should be merged into one window or slice.

Throws:

Exception

sliceStateMergeTarget

protected long sliceStateMergeTarget(long sliceToMerge)
                              throws Exception

Description copied from class: AbstractSliceSyncStateWindowAggProcessor

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 AbstractSliceSyncStateWindowAggProcessor

Throws:

Exception

See Also:

SliceSharedAssigner.mergeSlices(long, MergeCallback)