org.apache.paimon.flink

Class PaimonDataStreamSinkProvider

java.lang.Object

org.apache.paimon.flink.PaimonDataStreamSinkProvider

All Implemented Interfaces:

org.apache.flink.table.connector.ParallelismProvider, org.apache.flink.table.connector.sink.DataStreamSinkProvider, org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider

public class PaimonDataStreamSinkProvider
extends Object
implements org.apache.flink.table.connector.sink.DataStreamSinkProvider

Paimon DataStreamSinkProvider.

Constructor Summary

Constructors

Constructor and Description
PaimonDataStreamSinkProvider(java.util.function.Function<org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData>,org.apache.flink.streaming.api.datastream.DataStreamSink<?>> producer)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	consumeDataStream(org.apache.flink.table.connector.ProviderContext providerContext, org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> dataStream)

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.table.connector.sink.DataStreamSinkProvider

consumeDataStream, getParallelism

Constructor Detail

PaimonDataStreamSinkProvider

public PaimonDataStreamSinkProvider(java.util.function.Function<org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData>,org.apache.flink.streaming.api.datastream.DataStreamSink<?>> producer)

Method Detail

consumeDataStream

public org.apache.flink.streaming.api.datastream.DataStreamSink<?> consumeDataStream(org.apache.flink.table.connector.ProviderContext providerContext,
                                                                                     org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> dataStream)

Specified by:

consumeDataStream in interface org.apache.flink.table.connector.sink.DataStreamSinkProvider