Uses of Package
org.apache.flink.streaming.api.functions.sink
-
Packages that use org.apache.flink.streaming.api.functions.sink 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. -
Classes in org.apache.flink.streaming.api.functions.sink used by org.apache.flink.streaming.api.datastream Class Description SinkFunction Interface for implementing user defined sink functionality. -
Classes in org.apache.flink.streaming.api.functions.sink used by org.apache.flink.streaming.api.functions.sink Class Description RichSinkFunction ARichFunctionversion ofSinkFunction.SinkFunction Interface for implementing user defined sink functionality.SinkFunction.Context Context thatSinkFunctionscan use for getting additional data about an input record.TwoPhaseCommitSinkFunction This is a recommended base class for all of theSinkFunctionthat intend to implement exactly-once semantic.TwoPhaseCommitSinkFunction.State State POJO class coupling pendingTransaction, context and pendingCommitTransactions.TwoPhaseCommitSinkFunction.StateSerializer CustomTypeSerializerfor the sink state.TwoPhaseCommitSinkFunction.StateSerializerSnapshot Snapshot for theTwoPhaseCommitSinkFunction.StateSerializer.TwoPhaseCommitSinkFunction.TransactionHolder Adds metadata (currently only the start time of the transaction) to the transaction object.WriteFormat Deprecated.Please use theStreamingFileSinkfor writing to files from a streaming program.WriteSinkFunction Deprecated.Please use theStreamingFileSinkfor writing to files from a streaming program. -
Classes in org.apache.flink.streaming.api.functions.sink used by org.apache.flink.streaming.api.functions.sink.filesystem Class Description RichSinkFunction ARichFunctionversion ofSinkFunction.SinkFunction Interface for implementing user defined sink functionality.SinkFunction.Context Context thatSinkFunctionscan use for getting additional data about an input record. -
Classes in org.apache.flink.streaming.api.functions.sink used by org.apache.flink.streaming.api.operators Class Description SinkFunction Interface for implementing user defined sink functionality. -
Classes in org.apache.flink.streaming.api.functions.sink used by org.apache.flink.streaming.api.operators.collect Class Description RichSinkFunction ARichFunctionversion ofSinkFunction.SinkFunction Interface for implementing user defined sink functionality.SinkFunction.Context Context thatSinkFunctionscan use for getting additional data about an input record. -
Classes in org.apache.flink.streaming.api.functions.sink used by org.apache.flink.streaming.experimental Class Description RichSinkFunction ARichFunctionversion ofSinkFunction.SinkFunction Interface for implementing user defined sink functionality.SinkFunction.Context Context thatSinkFunctionscan use for getting additional data about an input record.