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

Class ValuesDataSink

java.lang.Object

org.apache.flink.cdc.connectors.values.sink.ValuesDataSink

All Implemented Interfaces:

Serializable, DataSink

@Internal
public class ValuesDataSink
extends Object
implements DataSink, Serializable

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

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ValuesDataSink.SinkApi	SinkApi which sink based on.

Constructor Summary

Constructors

Constructor	Description
ValuesDataSink(boolean materializedInMemory, boolean print, ValuesDataSink.SinkApi sinkApi, boolean errorOnSchemaChange)

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.

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

ValuesDataSink

public ValuesDataSink(boolean materializedInMemory,
                      boolean print,
                      ValuesDataSink.SinkApi sinkApi,
                      boolean errorOnSchemaChange)

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