org.apache.flink.statefun.flink.core.backpressure

Interface InternalContext

All Superinterfaces:

Context

@Internal
public interface InternalContext
extends Context

Method Summary

Modifier and Type	Method and Description
void	awaitAsyncOperationComplete() Signals the runtime to stop invoking the currently executing function with new input until at least one AsyncOperationResult belonging to this function would be delivered.
FunctionTypeMetrics	functionTypeMetrics() Returns the metrics handle for the current invoked function's type.

Methods inherited from interface org.apache.flink.statefun.sdk.Context

caller, cancelDelayedMessage, metrics, registerAsyncOperation, reply, self, send, send, send, sendAfter, sendAfter, sendAfter

Method Detail

awaitAsyncOperationComplete

void awaitAsyncOperationComplete()

Signals the runtime to stop invoking the currently executing function with new input until at least one AsyncOperationResult belonging to this function would be delivered.

NOTE: If a function would request to block without actually registering any async operations either previously or during its current invocation, then it would remain blocked. Since this is an internal API to be used by the remote functions we don't do anything to prevent that.

If we would like it to be a part of the SDK then we would have to make sure that we track every async operation registered per each address.

functionTypeMetrics

FunctionTypeMetrics functionTypeMetrics()

Returns the metrics handle for the current invoked function's type.

Returns:

the metrics handle for the current invoked function's type.