Package org.apache.flink.runtime.rest
Class RestClientConfiguration
- java.lang.Object
-
- org.apache.flink.runtime.rest.RestClientConfiguration
-
public final class RestClientConfiguration extends Object
A configuration object forRestClient
s.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static RestClientConfiguration
fromConfiguration(Configuration config)
Creates and returns a newRestClientConfiguration
from the givenConfiguration
.long
getConnectionTimeout()
{@see RestOptions#CONNECTION_TIMEOUT}.long
getIdlenessTimeout()
{@see RestOptions#IDLENESS_TIMEOUT}.int
getMaxContentLength()
Returns the max content length that the REST client endpoint could handle.SSLHandlerFactory
getSslHandlerFactory()
Returns theSSLEngine
that the REST client endpoint should use.
-
-
-
Method Detail
-
getSslHandlerFactory
@Nullable public SSLHandlerFactory getSslHandlerFactory()
Returns theSSLEngine
that the REST client endpoint should use.- Returns:
- SSLEngine that the REST client endpoint should use, or null if SSL was disabled
-
getConnectionTimeout
public long getConnectionTimeout()
{@see RestOptions#CONNECTION_TIMEOUT}.
-
getIdlenessTimeout
public long getIdlenessTimeout()
{@see RestOptions#IDLENESS_TIMEOUT}.
-
getMaxContentLength
public int getMaxContentLength()
Returns the max content length that the REST client endpoint could handle.- Returns:
- max content length that the REST client endpoint could handle
-
fromConfiguration
public static RestClientConfiguration fromConfiguration(Configuration config) throws ConfigurationException
Creates and returns a newRestClientConfiguration
from the givenConfiguration
.- Parameters:
config
- configuration from which the REST client endpoint configuration should be created from- Returns:
- REST client endpoint configuration
- Throws:
ConfigurationException
- if SSL was configured incorrectly
-
-