org.apache.flink.streaming.runtime.operators.asyncprocessing

接口 AsyncStateProcessing

所有已知子接口:

AsyncStateProcessingOperator

所有已知实现类:

AbstractAsyncStateStreamOperator, AbstractAsyncStateStreamOperatorV2, AbstractAsyncStateUdfStreamOperator, AbstractInput

@Internal
public interface AsyncStateProcessing

This class defines the basic interfaces to process a state in operator/input layer.

方法概要

限定符和类型	方法和说明
<T> org.apache.flink.util.function.ThrowingConsumer<StreamRecord<T>,Exception>	getRecordProcessor(int inputId) Get the record processor that could process record from input, which is the only entry for async processing.
boolean	isAsyncStateProcessingEnabled() Get if the async state processing is enabled for this input/operator.
static <T> org.apache.flink.util.function.ThrowingConsumer<StreamRecord<T>,Exception>	makeRecordProcessor(AsyncStateProcessingOperator asyncOperator, org.apache.flink.api.java.functions.KeySelector<T,?> keySelector, org.apache.flink.util.function.ThrowingConsumer<StreamRecord<T>,Exception> processor) Static method helper to make a record processor with given infos.

方法详细资料

isAsyncStateProcessingEnabled

boolean isAsyncStateProcessingEnabled()

Get if the async state processing is enabled for this input/operator.

返回:

ture if async state processing is enabled.

getRecordProcessor

<T> org.apache.flink.util.function.ThrowingConsumer<StreamRecord<T>,Exception> getRecordProcessor(int inputId)

Get the record processor that could process record from input, which is the only entry for async processing.

参数:

inputId - the input identifier, start from 1. Borrow the design from org.apache.flink.streaming.api.operators.AbstractInput#inputId. This is only relevant if there is multiple inputs for the instance.

makeRecordProcessor

static <T> org.apache.flink.util.function.ThrowingConsumer<StreamRecord<T>,Exception> makeRecordProcessor(AsyncStateProcessingOperator asyncOperator,
                                                                                                          org.apache.flink.api.java.functions.KeySelector<T,?> keySelector,
                                                                                                          org.apache.flink.util.function.ThrowingConsumer<StreamRecord<T>,Exception> processor)

Static method helper to make a record processor with given infos.

参数:

asyncOperator - the operator that can process state asynchronously.

keySelector - the key selector.

processor - the record processing logic.

返回:

the built record processor that can returned by getRecordProcessor(int).