Class 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 simple Sink implementation that wrap a sink-v2 based sink.
    • Constructor Detail

      • WrappedSink

        public WrappedSink​(Sink<T> wrappedSink)
    • Method Detail

      • getWrappedSink

        public Sink<T> getWrappedSink()