@Internal public interface AsyncStateProcessingOperator extends AsyncStateProcessing
AsyncStateProcessing
, which gives the essential
methods for an operator to perform async state processing.Modifier and Type | Method and Description |
---|---|
ElementOrder |
getElementOrder()
Get the
ElementOrder of this operator. |
void |
postProcessElement()
A callback that will be triggered after an element finishes
processElement . |
void |
preserveRecordOrderAndProcess(ThrowingRunnable<Exception> processing)
Check the order of same-key record, and then process the record.
|
<T> void |
setAsyncKeyedContextElement(StreamRecord<T> record,
KeySelector<T,?> keySelector)
Set key context for async state processing.
|
getRecordProcessor, isAsyncStateProcessingEnabled, makeRecordProcessor
ElementOrder getElementOrder()
ElementOrder
of this operator.<T> void setAsyncKeyedContextElement(StreamRecord<T> record, KeySelector<T,?> keySelector) throws Exception
T
- the type of the record.record
- the record.keySelector
- the key selector to select a key from record.Exception
void postProcessElement()
processElement
.void preserveRecordOrderAndProcess(ThrowingRunnable<Exception> processing)
getElementOrder()
returns ElementOrder.RECORD_ORDER
.processing
- the record processing logic.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.