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 boolean	DEFAULT_IGNORE_NULL_FIELDS The default option to ignore null fields on insertion.
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
boolean	getIgnoreNullFields()
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.

DEFAULT_IGNORE_NULL_FIELDS

public static final boolean DEFAULT_IGNORE_NULL_FIELDS

The default option to ignore null fields on insertion. By default, false.

See Also:

Constant Field Values

Method Detail

getMaxConcurrentRequests

public int getMaxConcurrentRequests()

getMaxConcurrentRequestsTimeout

public java.time.Duration getMaxConcurrentRequestsTimeout()

getIgnoreNullFields

public boolean getIgnoreNullFields()

toString

public String toString()

Overrides:

toString in class Object

newBuilder

public static CassandraSinkBaseConfig.Builder newBuilder()