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

Class MySqlSourceConfig

java.lang.Object

org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceConfig

All Implemented Interfaces:

Serializable

public class MySqlSourceConfig
extends Object
implements Serializable

A MySql Source configuration which is used by MySqlSource.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static boolean	useLegacyJsonFormat

Method Summary

Modifier and Type	Method	Description
Map<org.apache.flink.table.catalog.ObjectPath,String>	getChunkKeyColumns()
int	getConnectionPoolSize()
int	getConnectMaxRetries()
java.time.Duration	getConnectTimeout()
java.util.function.Predicate<String>	getDatabaseFilter()
List<String>	getDatabaseList()
io.debezium.config.Configuration	getDbzConfiguration()
Properties	getDbzProperties()
double	getDistributionFactorLower()
double	getDistributionFactorUpper()
int	getFetchSize()
String	getHostname()
Properties	getJdbcProperties()
io.debezium.connector.mysql.MySqlConnectorConfig	getMySqlConnectorConfig()
String	getPassword()
int	getPort()
ServerIdRange	getServerIdRange()
String	getServerTimeZone()
int	getSplitMetaGroupSize()
int	getSplitSize()
StartupOptions	getStartupOptions()
java.util.function.Predicate<io.debezium.relational.TableId>	getTableFilter()
RelationalTableFilters	getTableFilters()	Deprecated.
List<String>	getTableList()
String	getUsername()
boolean	isAssignUnboundedChunkFirst()
boolean	isCloseIdleReaders()
boolean	isIncludeHeartbeatEvents()
boolean	isIncludeSchemaChanges()
boolean	isIncludeTransactionMetadataEvents()
boolean	isParseOnLineSchemaChanges()
boolean	isReleaseSnapshotMetadataEnabled()
boolean	isScanNewlyAddedTableEnabled()
boolean	isSkipSnapshotBackfill()
boolean	isTreatTinyInt1AsBoolean()

Methods inherited from class java.lang.Object

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

Field Detail

useLegacyJsonFormat

public static boolean useLegacyJsonFormat

Method Detail

getHostname

public String getHostname()

getPort

public int getPort()

getUsername

public String getUsername()

getPassword

public String getPassword()

getDatabaseList

public List<String> getDatabaseList()

getTableList

public List<String> getTableList()

getServerIdRange

@Nullable
public ServerIdRange getServerIdRange()

getStartupOptions

public StartupOptions getStartupOptions()

getSplitSize

public int getSplitSize()

getSplitMetaGroupSize

public int getSplitMetaGroupSize()

getDistributionFactorUpper

public double getDistributionFactorUpper()

getDistributionFactorLower

public double getDistributionFactorLower()

getFetchSize

public int getFetchSize()

getServerTimeZone

public String getServerTimeZone()

getConnectTimeout

public java.time.Duration getConnectTimeout()

getConnectMaxRetries

public int getConnectMaxRetries()

getConnectionPoolSize

public int getConnectionPoolSize()

isIncludeSchemaChanges

public boolean isIncludeSchemaChanges()

isIncludeHeartbeatEvents

public boolean isIncludeHeartbeatEvents()

isIncludeTransactionMetadataEvents

public boolean isIncludeTransactionMetadataEvents()

isScanNewlyAddedTableEnabled

public boolean isScanNewlyAddedTableEnabled()

isReleaseSnapshotMetadataEnabled

public boolean isReleaseSnapshotMetadataEnabled()

isCloseIdleReaders

public boolean isCloseIdleReaders()

isParseOnLineSchemaChanges

public boolean isParseOnLineSchemaChanges()

isAssignUnboundedChunkFirst

public boolean isAssignUnboundedChunkFirst()

getDbzProperties

public Properties getDbzProperties()

getDbzConfiguration

public io.debezium.config.Configuration getDbzConfiguration()

getMySqlConnectorConfig

public io.debezium.connector.mysql.MySqlConnectorConfig getMySqlConnectorConfig()

getTableFilters

@Deprecated
public RelationalTableFilters getTableFilters()

Deprecated.

getDatabaseFilter

public java.util.function.Predicate<String> getDatabaseFilter()

getTableFilter

public java.util.function.Predicate<io.debezium.relational.TableId> getTableFilter()

getJdbcProperties

public Properties getJdbcProperties()

getChunkKeyColumns

public Map<org.apache.flink.table.catalog.ObjectPath,String> getChunkKeyColumns()

isSkipSnapshotBackfill

public boolean isSkipSnapshotBackfill()

isTreatTinyInt1AsBoolean

public boolean isTreatTinyInt1AsBoolean()