Uses of Class
org.apache.flink.table.runtime.operators.window.async.tvf.state.AsyncStateKeyContext
-
Packages that use AsyncStateKeyContext Package Description org.apache.flink.table.runtime.operators.aggregate.asyncwindow.buffers org.apache.flink.table.runtime.operators.window.async.tvf.common -
-
Uses of AsyncStateKeyContext in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.buffers
Methods in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.buffers with parameters of type AsyncStateKeyContext Modifier and Type Method Description AsyncStateWindowBufferAsyncStateRecordsWindowBuffer.Factory. create(Object operatorOwner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, AsyncStateKeyContext keyContext, WindowAsyncState<Long> windowState, boolean isEventTime, ZoneId shiftTimeZone)AsyncStateWindowBufferAsyncStateWindowBuffer.Factory. create(Object operatorOwner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, AsyncStateKeyContext keyContext, WindowAsyncState<Long> windowState, boolean isEventTime, ZoneId shiftTimeZone)Creates aWindowBufferthat buffers elements in memory before flushing.Constructors in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.buffers with parameters of type AsyncStateKeyContext Constructor Description AsyncStateRecordsWindowBuffer(Object operatorOwner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, AsyncStateRecordsCombiner combineFunction, PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSer, RecordEqualiser keyEqualiser, AsyncStateKeyContext keyContext, ZoneId shiftTimeZone) -
Uses of AsyncStateKeyContext in org.apache.flink.table.runtime.operators.window.async.tvf.common
Methods in org.apache.flink.table.runtime.operators.window.async.tvf.common that return AsyncStateKeyContext Modifier and Type Method Description AsyncStateKeyContextAsyncStateWindowProcessor.AsyncStateContext. getAsyncKeyContext()Returns the currentAsyncStateKeyContext.
-