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

Class RichSinkFunction<IN>

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.streaming.api.functions.sink.RichSinkFunction<IN>

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction, SinkFunction<IN>

Direct Known Subclasses:

CollectSink, CollectSinkFunction, OutputFormatSinkFunction, PrintSinkFunction, SocketClientSink, StreamingFileSink, TwoPhaseCommitSinkFunction

@Public
public abstract class RichSinkFunction<IN>
extends org.apache.flink.api.common.functions.AbstractRichFunction
implements SinkFunction<IN>

A RichFunction version of SinkFunction.

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	Description
RichSinkFunction()

Method Summary

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

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.common.functions.RichFunction

open

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

finish, invoke, invoke, writeWatermark

Constructor Detail

RichSinkFunction

public RichSinkFunction()