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

Class AbstractAsyncStateWindowAggProcessor<W>

java.lang.Object

org.apache.flink.table.runtime.operators.aggregate.window.processors.WindowAggProcessorBase<W,AsyncStateWindowProcessor.AsyncStateContext<W>>

org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors.AbstractAsyncStateWindowAggProcessor<W>

All Implemented Interfaces:

Serializable, AsyncStateWindowProcessor<W>, WindowProcessor<W,AsyncStateWindowProcessor.AsyncStateContext<W>>

Direct Known Subclasses:

AbstractAsyncStateSliceWindowAggProcessor

public abstract class AbstractAsyncStateWindowAggProcessor<W>
extends WindowAggProcessorBase<W,AsyncStateWindowProcessor.AsyncStateContext<W>>
implements AsyncStateWindowProcessor<W>

A base class for window aggregate processors with async state.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	AbstractAsyncStateWindowAggProcessor.WindowIsEmptyChecker	A checker that checks whether the window is empty.

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

AsyncStateWindowProcessor.AsyncStateContext<W>

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

WindowProcessor.Context<W>

Field Summary

Fields

Modifier and Type	Field	Description
protected AbstractAsyncStateWindowAggProcessor.WindowIsEmptyChecker	emptyChecker
protected WindowAsyncValueState<W>	windowState	state schema: [key, window, accumulator].

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
AbstractAsyncStateWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<W> genAggsHandler, WindowAssigner sliceAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer, boolean isEventTime, int indexOfCountStar, ZoneId shiftTimeZone, W defaultWindow)

Method Summary

Modifier and Type	Method	Description
void	open(AsyncStateWindowProcessor.AsyncStateContext<W> context)	Initialization method for the function.
protected void	prepareAggregator()

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

close, collect, getWindowTimerService, 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.async.tvf.common.AsyncStateWindowProcessor

advanceProgress, clearWindow, fireWindow, prepareCheckpoint, processElement

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

close, createWindowSerializer, initializeWatermark

Field Detail

emptyChecker

protected final AbstractAsyncStateWindowAggProcessor.WindowIsEmptyChecker emptyChecker

windowState

protected transient WindowAsyncValueState<W> windowState

state schema: [key, window, accumulator].

Constructor Detail

AbstractAsyncStateWindowAggProcessor

public AbstractAsyncStateWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<W> genAggsHandler,
                                            WindowAssigner sliceAssigner,
                                            org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer,
                                            boolean isEventTime,
                                            int indexOfCountStar,
                                            ZoneId shiftTimeZone,
                                            W defaultWindow)

Method Detail

open

public void open(AsyncStateWindowProcessor.AsyncStateContext<W> context)
          throws Exception

Description copied from interface: WindowProcessor

Initialization method for the function. It is called before the actual working methods.

Specified by:

open in interface WindowProcessor<W,AsyncStateWindowProcessor.AsyncStateContext<W>>

Overrides:

open in class WindowAggProcessorBase<W,AsyncStateWindowProcessor.AsyncStateContext<W>>

Throws:

Exception

prepareAggregator

protected final void prepareAggregator()
                                throws Exception

Specified by:

prepareAggregator in class WindowAggProcessorBase<W,AsyncStateWindowProcessor.AsyncStateContext<W>>

Throws:

Exception