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(org.apache.flink.configuration.Configuration configuration)
org.apache.flink.configuration.Configuration	getConfiguration()
long	getMaximumFramesize()
java.time.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 org.apache.flink.configuration.Configuration getConfiguration()

getTimeout

@Nonnull
public java.time.Duration getTimeout()

getMaximumFramesize

public long getMaximumFramesize()

captureAskCallStack

public boolean captureAskCallStack()

isForceRpcInvocationSerialization

public boolean isForceRpcInvocationSerialization()

fromConfiguration

public static PekkoRpcServiceConfiguration fromConfiguration(org.apache.flink.configuration.Configuration configuration)

defaultConfiguration

public static PekkoRpcServiceConfiguration defaultConfiguration()