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

Class ValuesDataSource

java.lang.Object

org.apache.flink.cdc.connectors.values.source.ValuesDataSource

All Implemented Interfaces:

DataSource

@Internal
public class ValuesDataSource
extends Object
implements DataSource

A DataSource for "values" connector that supports schema evolution.

Constructor Summary

Constructors

Constructor	Description
ValuesDataSource(ValuesDataSourceHelper.EventSetId eventSetId)
ValuesDataSource(ValuesDataSourceHelper.EventSetId eventSetId, int failAtPos)

Method Summary

Modifier and Type	Method	Description
EventSourceProvider	getEventSourceProvider()	Get the EventSourceProvider for reading events from external systems.
MetadataAccessor	getMetadataAccessor()	Get the MetadataAccessor for accessing metadata from external systems.
SupportedMetadataColumn[]	supportedMetadataColumns()	Get the SupportedMetadataColumns of the source.

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

Constructor Detail

ValuesDataSource

public ValuesDataSource(ValuesDataSourceHelper.EventSetId eventSetId)

ValuesDataSource

public ValuesDataSource(ValuesDataSourceHelper.EventSetId eventSetId,
                        int failAtPos)

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

supportedMetadataColumns

public SupportedMetadataColumn[] supportedMetadataColumns()

Description copied from interface: DataSource

Get the SupportedMetadataColumns of the source.

Specified by:

supportedMetadataColumns in interface DataSource