Package org.apache.flink.runtime.rpc.pekko

Class PekkoRpcServiceConfiguration

java.lang.Object

org.apache.flink.runtime.rpc.pekko.PekkoRpcServiceConfiguration

public class PekkoRpcServiceConfiguration
extends Object

Configuration for the PekkoRpcService.

Method Summary

Modifier and Type	Method	Description
boolean	captureAskCallStack()
static PekkoRpcServiceConfiguration	defaultConfiguration()
static PekkoRpcServiceConfiguration	fromConfiguration(Configuration configuration)
Configuration	getConfiguration()
long	getMaximumFramesize()
Duration	getTimeout()
boolean	isForceRpcInvocationSerialization()

Methods inherited from class java.lang.Object

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

Method Detail

getConfiguration

@Nonnull
public Configuration getConfiguration()

getTimeout

@Nonnull
public Duration getTimeout()

getMaximumFramesize

public long getMaximumFramesize()

captureAskCallStack

public boolean captureAskCallStack()

isForceRpcInvocationSerialization

public boolean isForceRpcInvocationSerialization()

fromConfiguration

public static PekkoRpcServiceConfiguration fromConfiguration(Configuration configuration)

defaultConfiguration

public static PekkoRpcServiceConfiguration defaultConfiguration()