Class DiscardingSink<T>

  • Type Parameters:
    T - The type of elements received by the sink.
    All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.SupportsConcurrentExecutionAttempts, SinkFunction<T>

    @Public
    public class DiscardingSink<T>
    extends Object
    implements SinkFunction<T>, org.apache.flink.api.common.SupportsConcurrentExecutionAttempts
    A stream sink that ignores all elements.
    See Also:
    Serialized Form
    • Constructor Detail

      • DiscardingSink

        public DiscardingSink()