SqlServerTableFactory (flink-cdc-parent 3.8-SNAPSHOT API)

java.lang.Object
- org.apache.flink.cdc.connectors.sqlserver.table.SqlServerTableFactory

All Implemented Interfaces:

org.apache.flink.table.factories.DynamicTableFactory, org.apache.flink.table.factories.DynamicTableSourceFactory, org.apache.flink.table.factories.Factory
```
public class SqlServerTableFactory
extends Object
implements org.apache.flink.table.factories.DynamicTableSourceFactory
```
Factory for creating configured instance of SqlServerTableSource.

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.flink.table.factories.DynamicTableFactory
  org.apache.flink.table.factories.DynamicTableFactory.Context

Field Summary

Fields
Modifier and Type	Field	Description
`static org.apache.flink.configuration.ConfigOption<String>`	`SCAN_STARTUP_MODE`
`static org.apache.flink.configuration.ConfigOption<Long>`	`SCAN_STARTUP_TIMESTAMP_MILLIS`
`static org.apache.flink.configuration.ConfigOption<String>`	`SERVER_TIME_ZONE`

Constructor Summary

Constructors
Constructor Description

SqlServerTableFactory()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`org.apache.flink.table.connector.source.DynamicTableSource`	`createDynamicTableSource(org.apache.flink.table.factories.DynamicTableFactory.Context context)`
`String`	`factoryIdentifier()`
`Set<org.apache.flink.configuration.ConfigOption<?>>`	`optionalOptions()`
`Set<org.apache.flink.configuration.ConfigOption<?>>`	`requiredOptions()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.table.factories.DynamicTableFactory
forwardOptions

Field Detail

SERVER_TIME_ZONE

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

SCAN_STARTUP_MODE

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

SCAN_STARTUP_TIMESTAMP_MILLIS

public static final org.apache.flink.configuration.ConfigOption<Long> SCAN_STARTUP_TIMESTAMP_MILLIS

Constructor Detail
- SqlServerTableFactory
```
public SqlServerTableFactory()
```

Method Detail
- createDynamicTableSource
```
public org.apache.flink.table.connector.source.DynamicTableSource createDynamicTableSource(org.apache.flink.table.factories.DynamicTableFactory.Context context)
```
  Specified by:
  
  createDynamicTableSource in interface org.apache.flink.table.factories.DynamicTableSourceFactory
- factoryIdentifier
```
public String factoryIdentifier()
```
  Specified by:
  
  factoryIdentifier in interface org.apache.flink.table.factories.Factory
- requiredOptions
```
public Set<org.apache.flink.configuration.ConfigOption<?>> requiredOptions()
```
  Specified by:
  
  requiredOptions in interface org.apache.flink.table.factories.Factory
- optionalOptions
```
public Set<org.apache.flink.configuration.ConfigOption<?>> optionalOptions()
```
  Specified by:
  
  optionalOptions in interface org.apache.flink.table.factories.Factory