Uses of Interface
org.apache.flink.streaming.api.functions.sink.SinkFunction
-
Packages that use SinkFunction Package Description org.apache.flink.streaming.api.datastream org.apache.flink.streaming.api.functions.sink org.apache.flink.streaming.api.functions.sink.filesystem org.apache.flink.streaming.api.operators org.apache.flink.streaming.api.operators.collect org.apache.flink.streaming.experimental This package holds classes that are experimental. -
-
Uses of SinkFunction in org.apache.flink.streaming.api.datastream
Methods in org.apache.flink.streaming.api.datastream with parameters of type SinkFunction Modifier and Type Method Description DataStreamSink<T>DataStream. addSink(SinkFunction<T> sinkFunction)Adds the given sink to this DataStream.DataStreamSink<T>KeyedStream. addSink(SinkFunction<T> sinkFunction) -
Uses of SinkFunction in org.apache.flink.streaming.api.functions.sink
Classes in org.apache.flink.streaming.api.functions.sink that implement SinkFunction Modifier and Type Class Description classDiscardingSink<T>Deprecated.This interface will be removed in future versions.classOutputFormatSinkFunction<IN>Deprecated.Please use theStreamingFileSinkfor writing to files from a streaming program.classPrintSinkFunction<IN>Deprecated.This interface will be removed in future versions.classRichSinkFunction<IN>Deprecated.This interface will be removed in future versions.classSocketClientSink<IN>Deprecated.This interface will be removed in future versions.classTwoPhaseCommitSinkFunction<IN,TXN,CONTEXT>Deprecated.This interface will be removed in future versions.classWriteSinkFunction<IN>Deprecated.Please use theStreamingFileSinkfor writing to files from a streaming program.classWriteSinkFunctionByMillis<IN>Deprecated.Please use theStreamingFileSinkfor writing to files from a streaming program. -
Uses of SinkFunction in org.apache.flink.streaming.api.functions.sink.filesystem
Classes in org.apache.flink.streaming.api.functions.sink.filesystem that implement SinkFunction Modifier and Type Class Description classStreamingFileSink<IN>Deprecated.Useorg.apache.flink.connector.file.sink.FileSinkinstead. -
Uses of SinkFunction in org.apache.flink.streaming.api.operators
Constructors in org.apache.flink.streaming.api.operators with parameters of type SinkFunction Constructor Description StreamSink(SinkFunction<IN> sinkFunction) -
Uses of SinkFunction in org.apache.flink.streaming.api.operators.collect
Classes in org.apache.flink.streaming.api.operators.collect that implement SinkFunction Modifier and Type Class Description classCollectSinkFunction<IN>A sink function that collects query results and sends them back to the client. -
Uses of SinkFunction in org.apache.flink.streaming.experimental
Classes in org.apache.flink.streaming.experimental that implement SinkFunction Modifier and Type Class Description classCollectSink<IN>A specialized data sink to be used by DataStreamUtils.collect().
-