org.apache.flink.statefun.flink.core.reqreply

Class ClassLoaderSafeRequestReplyClient

java.lang.Object

org.apache.flink.statefun.flink.core.reqreply.ClassLoaderSafeRequestReplyClient

All Implemented Interfaces:

RequestReplyClient

public final class ClassLoaderSafeRequestReplyClient
extends java.lang.Object
implements RequestReplyClient

Decorator for a RequestReplyClient that makes sure we always use the correct classloader. This is required since client implementation may be user provided.

Constructor Summary

Constructors

Constructor and Description
ClassLoaderSafeRequestReplyClient(RequestReplyClient delegate)

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.CompletableFuture<FromFunction>	call(ToFunctionRequestSummary requestSummary, RemoteInvocationMetrics metrics, ToFunction toFunction)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClassLoaderSafeRequestReplyClient

public ClassLoaderSafeRequestReplyClient(RequestReplyClient delegate)

Method Detail

call

public java.util.concurrent.CompletableFuture<FromFunction> call(ToFunctionRequestSummary requestSummary,
                                                                 RemoteInvocationMetrics metrics,
                                                                 ToFunction toFunction)

Specified by:

call in interface RequestReplyClient