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

Class DiscardingSink<T>

java.lang.Object

org.apache.flink.streaming.api.functions.sink.legacy.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, org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction<T>

@Internal
public class DiscardingSink<T>
extends Object
implements org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction<T>, org.apache.flink.api.common.SupportsConcurrentExecutionAttempts

Deprecated.

This interface will be removed in future versions. Use the new DiscardingSink interface instead.

A stream sink that ignores all elements.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction

org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction.Context

Constructor Summary

Constructors

Constructor	Description
DiscardingSink()	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	invoke(T value)	Deprecated.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction

finish, invoke, writeWatermark

Constructor Detail

DiscardingSink

public DiscardingSink()

Deprecated.

Method Detail

invoke

public void invoke(T value)

Deprecated.

Specified by:

invoke in interface org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction<T>