AsyncStateProcessingOperator (Flink : Streaming Java 1.20.3-cp1 API)

All Superinterfaces:

AsyncStateProcessing

All Known Implementing Classes:

AbstractAsyncStateStreamOperator, AbstractAsyncStateStreamOperatorV2, AbstractAsyncStateUdfStreamOperator
```
@Internal
public interface AsyncStateProcessingOperator
extends AsyncStateProcessing
```
A more detailed interface based on AsyncStateProcessing, which gives the essential methods for an operator to perform async state processing.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`ElementOrder`	`getElementOrder()`	Get the `ElementOrder` of this operator.
`void`	`postProcessElement()`	A callback that will be triggered after an element finishes `processElement`.
`void`	`preserveRecordOrderAndProcess(org.apache.flink.util.function.ThrowingRunnable<Exception> processing)`	Check the order of same-key record, and then process the record.
`<T> void`	`setAsyncKeyedContextElement(StreamRecord<T> record, org.apache.flink.api.java.functions.KeySelector<T,?> keySelector)`	Set key context for async state processing.

Methods inherited from interface org.apache.flink.streaming.runtime.operators.asyncprocessing.AsyncStateProcessing
getRecordProcessor, isAsyncStateProcessingEnabled

- Method Detail
  - getElementOrder
```
ElementOrder getElementOrder()
```
    Get the ElementOrder of this operator.
  - setAsyncKeyedContextElement
```
<T> void setAsyncKeyedContextElement(StreamRecord<T> record,
                                     org.apache.flink.api.java.functions.KeySelector<T,?> keySelector)
                              throws Exception
```
    Set key context for async state processing.
    
    Type Parameters:
    
    T - the type of the record.
    
    Parameters:
    
    record - the record.
    
    keySelector - the key selector to select a key from record.
    
    Throws:
    
    Exception
  - postProcessElement
```
void postProcessElement()
```
    A callback that will be triggered after an element finishes processElement.
  - preserveRecordOrderAndProcess
```
void preserveRecordOrderAndProcess(org.apache.flink.util.function.ThrowingRunnable<Exception> processing)
```
    Check the order of same-key record, and then process the record. Mainly used when the getElementOrder() returns ElementOrder.RECORD_ORDER.
    
    Parameters:
    
    processing - the record processing logic.