Package org.apache.flink.cdc.connectors.mongodb.source.config

Class MongoDBSourceOptions

java.lang.Object

org.apache.flink.cdc.connectors.mongodb.source.config.MongoDBSourceOptions

public class MongoDBSourceOptions
extends Object

Configurations for MongoDBSource.

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.flink.configuration.ConfigOption<Integer>	BATCH_SIZE
static org.apache.flink.configuration.ConfigOption<String>	COLLECTION
static org.apache.flink.configuration.ConfigOption<String>	CONNECTION_OPTIONS
static org.apache.flink.configuration.ConfigOption<String>	DATABASE
static org.apache.flink.configuration.ConfigOption<Boolean>	FULL_DOCUMENT_PRE_POST_IMAGE
static org.apache.flink.configuration.ConfigOption<Integer>	HEARTBEAT_INTERVAL_MILLIS
static org.apache.flink.configuration.ConfigOption<String>	HOSTS
static org.apache.flink.configuration.ConfigOption<Integer>	INITIAL_SNAPSHOTTING_MAX_THREADS
static org.apache.flink.configuration.ConfigOption<String>	INITIAL_SNAPSHOTTING_PIPELINE
static org.apache.flink.configuration.ConfigOption<Integer>	INITIAL_SNAPSHOTTING_QUEUE_SIZE
static org.apache.flink.configuration.ConfigOption<String>	PASSWORD
static org.apache.flink.configuration.ConfigOption<Integer>	POLL_AWAIT_TIME_MILLIS
static org.apache.flink.configuration.ConfigOption<Integer>	POLL_MAX_BATCH_SIZE
static org.apache.flink.configuration.ConfigOption<Integer>	SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SAMPLES
static org.apache.flink.configuration.ConfigOption<Integer>	SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE_MB
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_INCREMENTAL_SNAPSHOT_ENABLED
static org.apache.flink.configuration.ConfigOption<Boolean>	SCAN_NO_CURSOR_TIMEOUT
static org.apache.flink.configuration.ConfigOption<String>	SCHEME
static org.apache.flink.configuration.ConfigOption<Boolean>	SSL_ENABLED
static org.apache.flink.configuration.ConfigOption<Boolean>	SSL_INVALID_HOSTNAME_ALLOWED
static org.apache.flink.configuration.ConfigOption<String>	SSL_KEYSTORE
static org.apache.flink.configuration.ConfigOption<String>	SSL_KEYSTORE_PASSWORD
static org.apache.flink.configuration.ConfigOption<String>	SSL_KEYSTORE_TYPE
static org.apache.flink.configuration.ConfigOption<String>	SSL_TRUSTSTORE
static org.apache.flink.configuration.ConfigOption<String>	SSL_TRUSTSTORE_PASSWORD
static org.apache.flink.configuration.ConfigOption<String>	SSL_TRUSTSTORE_TYPE
static org.apache.flink.configuration.ConfigOption<String>	USERNAME

Constructor Summary

Constructors

Constructor	Description
MongoDBSourceOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

SCHEME

public static final org.apache.flink.configuration.ConfigOption<String> SCHEME

HOSTS

public static final org.apache.flink.configuration.ConfigOption<String> HOSTS

USERNAME

public static final org.apache.flink.configuration.ConfigOption<String> USERNAME

PASSWORD

public static final org.apache.flink.configuration.ConfigOption<String> PASSWORD

DATABASE

public static final org.apache.flink.configuration.ConfigOption<String> DATABASE

COLLECTION

public static final org.apache.flink.configuration.ConfigOption<String> COLLECTION

CONNECTION_OPTIONS

public static final org.apache.flink.configuration.ConfigOption<String> CONNECTION_OPTIONS

INITIAL_SNAPSHOTTING_QUEUE_SIZE

public static final org.apache.flink.configuration.ConfigOption<Integer> INITIAL_SNAPSHOTTING_QUEUE_SIZE

INITIAL_SNAPSHOTTING_MAX_THREADS

public static final org.apache.flink.configuration.ConfigOption<Integer> INITIAL_SNAPSHOTTING_MAX_THREADS

INITIAL_SNAPSHOTTING_PIPELINE

public static final org.apache.flink.configuration.ConfigOption<String> INITIAL_SNAPSHOTTING_PIPELINE

BATCH_SIZE

public static final org.apache.flink.configuration.ConfigOption<Integer> BATCH_SIZE

POLL_MAX_BATCH_SIZE

public static final org.apache.flink.configuration.ConfigOption<Integer> POLL_MAX_BATCH_SIZE

POLL_AWAIT_TIME_MILLIS

public static final org.apache.flink.configuration.ConfigOption<Integer> POLL_AWAIT_TIME_MILLIS

HEARTBEAT_INTERVAL_MILLIS

public static final org.apache.flink.configuration.ConfigOption<Integer> HEARTBEAT_INTERVAL_MILLIS

SCAN_INCREMENTAL_SNAPSHOT_ENABLED

@Experimental
public static final org.apache.flink.configuration.ConfigOption<Boolean> SCAN_INCREMENTAL_SNAPSHOT_ENABLED

SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE_MB

@Experimental
public static final org.apache.flink.configuration.ConfigOption<Integer> SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SIZE_MB

SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SAMPLES

@Experimental
public static final org.apache.flink.configuration.ConfigOption<Integer> SCAN_INCREMENTAL_SNAPSHOT_CHUNK_SAMPLES

FULL_DOCUMENT_PRE_POST_IMAGE

@Experimental
public static final org.apache.flink.configuration.ConfigOption<Boolean> FULL_DOCUMENT_PRE_POST_IMAGE

SCAN_NO_CURSOR_TIMEOUT

public static final org.apache.flink.configuration.ConfigOption<Boolean> SCAN_NO_CURSOR_TIMEOUT

SSL_ENABLED

public static final org.apache.flink.configuration.ConfigOption<Boolean> SSL_ENABLED

SSL_INVALID_HOSTNAME_ALLOWED

public static final org.apache.flink.configuration.ConfigOption<Boolean> SSL_INVALID_HOSTNAME_ALLOWED

SSL_KEYSTORE

public static final org.apache.flink.configuration.ConfigOption<String> SSL_KEYSTORE

SSL_KEYSTORE_PASSWORD

public static final org.apache.flink.configuration.ConfigOption<String> SSL_KEYSTORE_PASSWORD

SSL_KEYSTORE_TYPE

public static final org.apache.flink.configuration.ConfigOption<String> SSL_KEYSTORE_TYPE

SSL_TRUSTSTORE

public static final org.apache.flink.configuration.ConfigOption<String> SSL_TRUSTSTORE

SSL_TRUSTSTORE_PASSWORD

public static final org.apache.flink.configuration.ConfigOption<String> SSL_TRUSTSTORE_PASSWORD

SSL_TRUSTSTORE_TYPE

public static final org.apache.flink.configuration.ConfigOption<String> SSL_TRUSTSTORE_TYPE

Constructor Detail

MongoDBSourceOptions

public MongoDBSourceOptions()