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

Class DiscardingSink<IN>

java.lang.Object

org.apache.flink.streaming.api.functions.sink.v2.DiscardingSink<IN>

Type Parameters:

IN - The type of elements received by the sink.

All Implemented Interfaces:

Serializable, SupportsConcurrentExecutionAttempts, Sink<IN>

@PublicEvolving
public class DiscardingSink<IN>
extends Object
implements Sink<IN>, SupportsConcurrentExecutionAttempts

A special sink that ignores all elements.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.api.connector.sink2.Sink

Sink.InitContext, Sink.InitContextWrapper

Constructor Summary

Constructors

Constructor and Description
DiscardingSink()

Method Summary

Modifier and Type	Method and Description
SinkWriter<IN>	createWriter(Sink.InitContext context) Creates a SinkWriter.

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.api.connector.sink2.Sink

createWriter

Constructor Detail

DiscardingSink

public DiscardingSink()

Method Detail

createWriter

public SinkWriter<IN> createWriter(Sink.InitContext context)
                            throws IOException

Description copied from interface: Sink

Creates a SinkWriter.

Specified by:

createWriter in interface Sink<IN>

Parameters:

context - the runtime context.

Returns:

A sink writer.

Throws:

IOException - for any failure during creation.