Package org.apache.flink.table.runtime.operators.window.async.tvf.state

Class AsyncStateKeyContext

java.lang.Object

org.apache.flink.table.runtime.operators.window.async.tvf.state.AsyncStateKeyContext

public class AsyncStateKeyContext
extends Object

Context to switch current key in async state backend.

Constructor Summary

Constructors

Constructor	Description
AsyncStateKeyContext(org.apache.flink.runtime.asyncprocessing.operators.AbstractAsyncStateStreamOperator<org.apache.flink.table.data.RowData> asyncStateProcessingOperator, org.apache.flink.runtime.state.AsyncKeyedStateBackend<?> asyncKeyedStateBackend)

Method Summary

Modifier and Type	Method	Description
void	asyncProcessWithKey(org.apache.flink.table.data.RowData key, org.apache.flink.util.function.ThrowingRunnable<Exception> processing)
org.apache.flink.runtime.state.AsyncKeyedStateBackend<?>	getAsyncKeyedStateBackend()
org.apache.flink.table.data.RowData	getCurrentKey()

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncStateKeyContext

public AsyncStateKeyContext(org.apache.flink.runtime.asyncprocessing.operators.AbstractAsyncStateStreamOperator<org.apache.flink.table.data.RowData> asyncStateProcessingOperator,
                            org.apache.flink.runtime.state.AsyncKeyedStateBackend<?> asyncKeyedStateBackend)

Method Detail

asyncProcessWithKey

public void asyncProcessWithKey(org.apache.flink.table.data.RowData key,
                                org.apache.flink.util.function.ThrowingRunnable<Exception> processing)

getAsyncKeyedStateBackend

public org.apache.flink.runtime.state.AsyncKeyedStateBackend<?> getAsyncKeyedStateBackend()

getCurrentKey

public org.apache.flink.table.data.RowData getCurrentKey()