Package org.apache.flink.cdc.connectors.starrocks.sink

Class StarRocksDataSink

java.lang.Object

org.apache.flink.cdc.connectors.starrocks.sink.StarRocksDataSink

All Implemented Interfaces:

Serializable, DataSink

public class StarRocksDataSink
extends Object
implements DataSink, Serializable

A DataSink for StarRocks connector that supports schema evolution.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
StarRocksDataSink(com.starrocks.connector.flink.table.sink.StarRocksSinkOptions sinkOptions, TableCreateConfig tableCreateConfig, SchemaChangeConfig schemaChangeConfig, java.time.ZoneId zoneId)

Method Summary

Modifier and Type	Method	Description
EventSinkProvider	getEventSinkProvider()	Get the EventSinkProvider for writing changed data to external systems.
MetadataApplier	getMetadataApplier()	Get the MetadataApplier for applying metadata changes to external systems.
java.time.ZoneId	getZoneId()

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.sink.DataSink

getDataChangeEventHashFunctionProvider, getDataChangeEventHashFunctionProvider

Constructor Detail

StarRocksDataSink

public StarRocksDataSink(com.starrocks.connector.flink.table.sink.StarRocksSinkOptions sinkOptions,
                         TableCreateConfig tableCreateConfig,
                         SchemaChangeConfig schemaChangeConfig,
                         java.time.ZoneId zoneId)

Method Detail

getEventSinkProvider

public EventSinkProvider getEventSinkProvider()

Description copied from interface: DataSink

Get the EventSinkProvider for writing changed data to external systems.

Specified by:

getEventSinkProvider in interface DataSink

getMetadataApplier

public MetadataApplier getMetadataApplier()

Description copied from interface: DataSink

Get the MetadataApplier for applying metadata changes to external systems.

Specified by:

getMetadataApplier in interface DataSink

getZoneId

@VisibleForTesting
public java.time.ZoneId getZoneId()