public class PaimonDataStreamSinkProvider extends Object implements org.apache.flink.table.connector.sink.DataStreamSinkProvider
DataStreamSinkProvider
.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) |
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) |
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)
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)
consumeDataStream
in interface org.apache.flink.table.connector.sink.DataStreamSinkProvider
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.