org.apache.flink.table.runtime.operators.window.slicing

Interface SlicingWindowProcessor.Context<W>

Enclosing interface:

SlicingWindowProcessor<W>

public static interface SlicingWindowProcessor.Context<W>

Information available in an invocation of methods of SlicingWindowProcessor.

Method Summary

Modifier and Type	Method and Description
KeyedStateBackend<RowData>	getKeyedStateBackend() Returns the current KeyedStateBackend.
MemoryManager	getMemoryManager() Returns the current MemoryManager.
long	getMemorySize() Returns the managed memory size can be used by this operator.
Object	getOperatorOwner() Returns the object instance of this operator which is used for tracking managed memories used by this operator.
RuntimeContext	getRuntimeContext() Returns the current RuntimeContext.
InternalTimerService<W>	getTimerService() Returns the current InternalTimerService.
void	output(RowData result) Outputs results to downstream operators.

Method Detail

getOperatorOwner

Object getOperatorOwner()

Returns the object instance of this operator which is used for tracking managed memories used by this operator.

getMemoryManager

MemoryManager getMemoryManager()

Returns the current MemoryManager.

getMemorySize

long getMemorySize()

Returns the managed memory size can be used by this operator.

getKeyedStateBackend

KeyedStateBackend<RowData> getKeyedStateBackend()

Returns the current KeyedStateBackend.

getTimerService

InternalTimerService<W> getTimerService()

Returns the current InternalTimerService.

getRuntimeContext

RuntimeContext getRuntimeContext()

Returns the current RuntimeContext.

output

void output(RowData result)

Outputs results to downstream operators.