Interface WindowProcessor.Context<W>
-
- All Known Subinterfaces:
AsyncStateWindowProcessor.AsyncStateContext<W>,SyncStateWindowProcessor.SyncStateContext<W>
- Enclosing interface:
- WindowProcessor<W,C extends WindowProcessor.Context<W>>
public static interface WindowProcessor.Context<W>Information available in an invocation of methods ofWindowProcessor.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description org.apache.flink.runtime.memory.MemoryManagergetMemoryManager()Returns the currentMemoryManager.longgetMemorySize()Returns the managed memory size can be used by this operator.ObjectgetOperatorOwner()Returns the object instance of this operator which is used for tracking managed memories used by this operator.org.apache.flink.api.common.functions.RuntimeContextgetRuntimeContext()Returns the currentRuntimeContext.org.apache.flink.streaming.api.operators.InternalTimerService<W>getTimerService()Returns the currentInternalTimerService.voidoutput(org.apache.flink.table.data.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
org.apache.flink.runtime.memory.MemoryManager getMemoryManager()
Returns the currentMemoryManager.
-
getMemorySize
long getMemorySize()
Returns the managed memory size can be used by this operator.
-
getTimerService
org.apache.flink.streaming.api.operators.InternalTimerService<W> getTimerService()
Returns the currentInternalTimerService.
-
getRuntimeContext
org.apache.flink.api.common.functions.RuntimeContext getRuntimeContext()
Returns the currentRuntimeContext.
-
output
void output(org.apache.flink.table.data.RowData result)
Outputs results to downstream operators.
-
-