Uses of Interface
org.apache.flink.streaming.api.functions.sink.SinkFunction.Context
-
Packages that use SinkFunction.Context Package Description org.apache.flink.streaming.api.functions.sink org.apache.flink.streaming.api.functions.sink.filesystem org.apache.flink.streaming.api.operators.collect org.apache.flink.streaming.experimental This package holds classes that are experimental. -
-
Uses of SinkFunction.Context in org.apache.flink.streaming.api.functions.sink
Methods in org.apache.flink.streaming.api.functions.sink that return SinkFunction.Context Modifier and Type Method Description static SinkFunction.ContextSinkContextUtil. forTimestamp(long timestamp)Creates aSinkFunction.Contextthat throws an exception when trying to access the current watermark or processing time.Methods in org.apache.flink.streaming.api.functions.sink with parameters of type SinkFunction.Context Modifier and Type Method Description default voidSinkFunction. invoke(IN value, SinkFunction.Context context)Deprecated.Writes the given value to the sink.voidTwoPhaseCommitSinkFunction. invoke(IN value, SinkFunction.Context context)Deprecated.protected abstract voidTwoPhaseCommitSinkFunction. invoke(TXN transaction, IN value, SinkFunction.Context context)Deprecated.Write value within a transaction. -
Uses of SinkFunction.Context in org.apache.flink.streaming.api.functions.sink.filesystem
Methods in org.apache.flink.streaming.api.functions.sink.filesystem with parameters of type SinkFunction.Context Modifier and Type Method Description voidStreamingFileSink. invoke(IN value, SinkFunction.Context context)Deprecated.Bucket<IN,BucketID>Buckets. onElement(IN value, SinkFunction.Context context) -
Uses of SinkFunction.Context in org.apache.flink.streaming.api.operators.collect
Methods in org.apache.flink.streaming.api.operators.collect with parameters of type SinkFunction.Context Modifier and Type Method Description voidCollectSinkFunction. invoke(IN value, SinkFunction.Context context) -
Uses of SinkFunction.Context in org.apache.flink.streaming.experimental
Methods in org.apache.flink.streaming.experimental with parameters of type SinkFunction.Context Modifier and Type Method Description voidCollectSink. invoke(IN value, SinkFunction.Context context)
-