org.apache.flink.streaming.connectors.cassandra

Class CassandraSinkBaseConfig

java.lang.Object

org.apache.flink.streaming.connectors.cassandra.CassandraSinkBaseConfig

All Implemented Interfaces:

Serializable

public final class CassandraSinkBaseConfig
extends Object
implements Serializable

Configuration for CassandraSinkBase.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CassandraSinkBaseConfig.Builder Builder for the CassandraSinkBaseConfig.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_MAX_CONCURRENT_REQUESTS The default maximum number of concurrent requests.
static java.time.Duration	DEFAULT_MAX_CONCURRENT_REQUESTS_TIMEOUT The default timeout duration when acquiring a permit to execute.

Method Summary

Modifier and Type	Method and Description
int	getMaxConcurrentRequests()
java.time.Duration	getMaxConcurrentRequestsTimeout()
static CassandraSinkBaseConfig.Builder	newBuilder()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_MAX_CONCURRENT_REQUESTS

public static final int DEFAULT_MAX_CONCURRENT_REQUESTS

The default maximum number of concurrent requests. By default, Integer.MAX_VALUE.

See Also:

Constant Field Values

DEFAULT_MAX_CONCURRENT_REQUESTS_TIMEOUT

public static final java.time.Duration DEFAULT_MAX_CONCURRENT_REQUESTS_TIMEOUT

The default timeout duration when acquiring a permit to execute. By default, Long.MAX_VALUE.

Method Detail

getMaxConcurrentRequests

public int getMaxConcurrentRequests()

getMaxConcurrentRequestsTimeout

public java.time.Duration getMaxConcurrentRequestsTimeout()

toString

public String toString()

Overrides:

toString in class Object

newBuilder

public static CassandraSinkBaseConfig.Builder newBuilder()