Class WrappedSink<T>
- java.lang.Object
-
- org.apache.flink.api.connector.dsv2.WrappedSink<T>
-
- All Implemented Interfaces:
org.apache.flink.api.connector.dsv2.Sink<T>
@Internal public class WrappedSink<T> extends Object implements org.apache.flink.api.connector.dsv2.Sink<T>
A simpleSinkimplementation that wrap a sink-v2 based sink.
-
-
Constructor Summary
Constructors Constructor Description WrappedSink(Sink<T> wrappedSink)
-