Package org.apache.flink.streaming.api.functions.sink.v2

Class DiscardingSink<IN>

  • Type Parameters:
    IN - The type of elements received by the sink.
    All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.SupportsConcurrentExecutionAttempts, org.apache.flink.api.connector.sink2.Sink<IN>
    @PublicEvolving
public class DiscardingSink<IN>
extends Object
implements org.apache.flink.api.connector.sink2.Sink<IN>, org.apache.flink.api.common.SupportsConcurrentExecutionAttempts
    A special sink that ignores all elements.
    See Also:
    Serialized Form

    • Constructor Detail

      • DiscardingSink

        public DiscardingSink()

    • Method Detail

      • createWriter

        public org.apache.flink.api.connector.sink2.SinkWriter<IN> createWriter​(org.apache.flink.api.connector.sink2.WriterInitContext context)
                                                                 throws IOException
        Specified by:
        createWriter in interface org.apache.flink.api.connector.sink2.Sink<IN>
        Throws:
        IOException