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

Class DiscardingSink<T>

java.lang.Object

org.apache.flink.streaming.api.functions.sink.DiscardingSink<T>

Type Parameters:

T - The type of elements received by the sink.

All Implemented Interfaces:

Serializable, Function, SupportsConcurrentExecutionAttempts, SinkFunction<T>

@Public
public class DiscardingSink<T>
extends Object
implements SinkFunction<T>, SupportsConcurrentExecutionAttempts

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.SinkFunction

SinkFunction.Context

Constructor Summary

Constructors

Constructor and Description
DiscardingSink()

Method Summary

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

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.SinkFunction

finish, invoke, writeWatermark

Constructor Detail

DiscardingSink

public DiscardingSink()

Method Detail

invoke

public void invoke(T value)

Specified by:

invoke in interface SinkFunction<T>