| Package | Description |
|---|---|
| com.ververica.cdc.connectors.oracle | |
| com.ververica.cdc.connectors.oracle.table |
| Modifier and Type | Method and Description |
|---|---|
OracleSource.Builder<T> |
OracleSource.Builder.startupOptions(StartupOptions startupOptions)
Specifies the startup options.
|
| Modifier and Type | Method and Description |
|---|---|
static StartupOptions |
StartupOptions.initial()
Performs an initial snapshot on the monitored database tables upon first startup, and
continue to read the latest logminer.
|
static StartupOptions |
StartupOptions.latest()
Never to perform snapshot on the monitored database tables upon first startup, just read from
the end of the logminer which means only have the changes since the connector was started.
|
| Constructor and Description |
|---|
OracleTableSource(org.apache.flink.table.catalog.ResolvedSchema physicalSchema,
int port,
String hostname,
String database,
String tableName,
String schemaName,
String username,
String password,
Properties dbzProperties,
StartupOptions startupOptions) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.