org.apache.flink.table.toolbox

Class TestScanTableSourceWithWatermarkPushDown

java.lang.Object

org.apache.flink.table.toolbox.TestScanTableSourceWithWatermarkPushDown

All Implemented Interfaces:

SupportsWatermarkPushDown, DynamicTableSource, ScanTableSource

public class TestScanTableSourceWithWatermarkPushDown
extends Object
implements ScanTableSource, SupportsWatermarkPushDown

A source used to test SupportsWatermarkPushDown.

For simplicity, the deprecated source function method is used to create the source.

Nested Class Summary

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

ScanTableSource.ScanContext, ScanTableSource.ScanRuntimeProvider

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

DynamicTableSource.Context, DynamicTableSource.DataStructureConverter

Constructor Summary

Constructors

Constructor and Description
TestScanTableSourceWithWatermarkPushDown()

Method Summary

Modifier and Type	Method and Description
void	applyWatermark(WatermarkStrategy<RowData> watermarkStrategy) Provides a WatermarkStrategy which defines how to generate Watermarks in the stream source.
String	asSummaryString() Returns a string that summarizes this source for printing to a console or log.
DynamicTableSource	copy() Creates a copy of this instance during planning.
ChangelogMode	getChangelogMode() Returns the set of changes that the planner can expect during runtime.
ScanTableSource.ScanRuntimeProvider	getScanRuntimeProvider(ScanTableSource.ScanContext runtimeProviderContext) Returns a provider of runtime implementation for reading the data.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TestScanTableSourceWithWatermarkPushDown

public TestScanTableSourceWithWatermarkPushDown()

Method Detail

applyWatermark

public void applyWatermark(WatermarkStrategy<RowData> watermarkStrategy)

Description copied from interface: SupportsWatermarkPushDown

Provides a WatermarkStrategy which defines how to generate Watermarks in the stream source.

The WatermarkStrategy is a builder/factory for the actual runtime implementation consisting of TimestampAssigner (assigns the event-time timestamps to each record) and the WatermarkGenerator (generates the watermarks).

Note: If necessary, the watermark strategy will contain required computed column expressions and consider metadata columns (if SupportsReadingMetadata is implemented).

Specified by:

applyWatermark in interface SupportsWatermarkPushDown

copy

public DynamicTableSource copy()

Description copied from interface: DynamicTableSource

Creates a copy of this instance during planning. The copy should be a deep copy of all mutable members.

Specified by:

copy in interface DynamicTableSource

asSummaryString

public String asSummaryString()

Description copied from interface: DynamicTableSource

Returns a string that summarizes this source for printing to a console or log.

Specified by:

asSummaryString in interface DynamicTableSource

getChangelogMode

public ChangelogMode getChangelogMode()

Description copied from interface: ScanTableSource

Returns the set of changes that the planner can expect during runtime.

Specified by:

getChangelogMode in interface ScanTableSource

See Also:

RowKind

getScanRuntimeProvider

public ScanTableSource.ScanRuntimeProvider getScanRuntimeProvider(ScanTableSource.ScanContext runtimeProviderContext)

Description copied from interface: ScanTableSource

Returns a provider of runtime implementation for reading the data.

There might exist different interfaces for runtime implementation which is why ScanTableSource.ScanRuntimeProvider serves as the base interface. Concrete ScanTableSource.ScanRuntimeProvider interfaces might be located in other Flink modules.

Independent of the provider interface, the table runtime expects that a source implementation emits internal data structures (see RowData for more information).

The given ScanTableSource.ScanContext offers utilities by the planner for creating runtime implementation with minimal dependencies to internal data structures.

SourceProvider is the recommended core interface. SourceFunctionProvider in flink-table-api-java-bridge and InputFormatProvider are available for backwards compatibility.

Specified by:

getScanRuntimeProvider in interface ScanTableSource

See Also:

SourceProvider