Package org.apache.flink.cdc.connectors.oracle.source

Class OracleDataSource

java.lang.Object

org.apache.flink.cdc.connectors.oracle.source.OracleDataSource

All Implemented Interfaces:

DataSource, org.apache.flink.table.connector.source.abilities.SupportsReadingMetadata

public class OracleDataSource
extends Object
implements DataSource, org.apache.flink.table.connector.source.abilities.SupportsReadingMetadata

A DynamicTableSource that describes how to create a Oracle redo log from a logical description.

Field Summary

Fields

Modifier and Type	Field	Description
protected List<String>	metadataKeys	Metadata that is appended at the end of a physical source row.
protected org.apache.flink.table.types.DataType	producedDataType	Data type that describes the final output of the source.

Constructor Summary

Constructors

Constructor	Description
OracleDataSource(OracleSourceConfigFactory configFactory, Configuration config, List<OracleReadableMetaData> readableMetadataList)

Method Summary

Modifier and Type	Method	Description
void	applyReadableMetadata(List<String> metadataKeys, org.apache.flink.table.types.DataType producedDataType)
EventSourceProvider	getEventSourceProvider()	Get the EventSourceProvider for reading events from external systems.
MetadataAccessor	getMetadataAccessor()	Get the MetadataAccessor for accessing metadata from external systems.
OracleSourceConfig	getSourceConfig()
Map<String,org.apache.flink.table.types.DataType>	listReadableMetadata()

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.cdc.common.source.DataSource

isParallelMetadataSource, supportedMetadataColumns

Methods inherited from interface org.apache.flink.table.connector.source.abilities.SupportsReadingMetadata

supportsMetadataProjection

Field Detail

producedDataType

protected org.apache.flink.table.types.DataType producedDataType

Data type that describes the final output of the source.

metadataKeys

protected List<String> metadataKeys

Metadata that is appended at the end of a physical source row.

Constructor Detail

OracleDataSource

public OracleDataSource(OracleSourceConfigFactory configFactory,
                        Configuration config,
                        List<OracleReadableMetaData> readableMetadataList)

Method Detail

getEventSourceProvider

public EventSourceProvider getEventSourceProvider()

Description copied from interface: DataSource

Get the EventSourceProvider for reading events from external systems.

Specified by:

getEventSourceProvider in interface DataSource

getMetadataAccessor

public MetadataAccessor getMetadataAccessor()

Description copied from interface: DataSource

Get the MetadataAccessor for accessing metadata from external systems.

Specified by:

getMetadataAccessor in interface DataSource

listReadableMetadata

public Map<String,org.apache.flink.table.types.DataType> listReadableMetadata()

Specified by:

listReadableMetadata in interface org.apache.flink.table.connector.source.abilities.SupportsReadingMetadata

applyReadableMetadata

public void applyReadableMetadata(List<String> metadataKeys,
                                  org.apache.flink.table.types.DataType producedDataType)

Specified by:

applyReadableMetadata in interface org.apache.flink.table.connector.source.abilities.SupportsReadingMetadata

getSourceConfig

@VisibleForTesting
public OracleSourceConfig getSourceConfig()