Package org.apache.flink.cdc.connectors.vitess.table

Class VitessTableSource

java.lang.Object

org.apache.flink.cdc.connectors.vitess.table.VitessTableSource

All Implemented Interfaces:

org.apache.flink.table.connector.source.DynamicTableSource, org.apache.flink.table.connector.source.ScanTableSource

public class VitessTableSource
extends Object
implements org.apache.flink.table.connector.source.ScanTableSource

A DynamicTableSource that describes how to create a Vitess source from a logical description.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.source.DynamicTableSource

org.apache.flink.table.connector.source.DynamicTableSource.Context, org.apache.flink.table.connector.source.DynamicTableSource.DataStructureConverter

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.source.ScanTableSource

org.apache.flink.table.connector.source.ScanTableSource.ScanContext, org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider

Constructor Summary

Constructors

Constructor	Description
VitessTableSource(org.apache.flink.table.catalog.ResolvedSchema physicalSchema, int port, String hostname, String keyspace, String tableName, String username, String password, String shard, String gtid, Boolean stopOnReshard, Boolean tombstonesOnDelete, SchemaAdjustmentMode schemaNameAdjustmentMode, TabletType tabletType, String pluginName, String name, Properties dbzProperties)

Method Summary

Modifier and Type	Method	Description
String	asSummaryString()
org.apache.flink.table.connector.source.DynamicTableSource	copy()
boolean	equals(Object o)
org.apache.flink.table.connector.ChangelogMode	getChangelogMode()
org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider	getScanRuntimeProvider(org.apache.flink.table.connector.source.ScanTableSource.ScanContext scanContext)
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

VitessTableSource

public VitessTableSource(org.apache.flink.table.catalog.ResolvedSchema physicalSchema,
                         int port,
                         String hostname,
                         String keyspace,
                         String tableName,
                         @Nullable
                         String username,
                         @Nullable
                         String password,
                         @Nullable
                         String shard,
                         String gtid,
                         Boolean stopOnReshard,
                         Boolean tombstonesOnDelete,
                         SchemaAdjustmentMode schemaNameAdjustmentMode,
                         TabletType tabletType,
                         String pluginName,
                         String name,
                         Properties dbzProperties)

Method Detail

getChangelogMode

public org.apache.flink.table.connector.ChangelogMode getChangelogMode()

Specified by:

getChangelogMode in interface org.apache.flink.table.connector.source.ScanTableSource

getScanRuntimeProvider

public org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider getScanRuntimeProvider(org.apache.flink.table.connector.source.ScanTableSource.ScanContext scanContext)

Specified by:

getScanRuntimeProvider in interface org.apache.flink.table.connector.source.ScanTableSource

copy

public org.apache.flink.table.connector.source.DynamicTableSource copy()

Specified by:

copy in interface org.apache.flink.table.connector.source.DynamicTableSource

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

asSummaryString

public String asSummaryString()

Specified by:

asSummaryString in interface org.apache.flink.table.connector.source.DynamicTableSource