Uses of Interface
org.apache.flink.streaming.api.functions.sink.SinkFunction.Context

Packages that use SinkFunction.Context

Package	Description
org.apache.flink.connector.hbase.sink
org.apache.flink.connector.jdbc.internal
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.connectors.elasticsearch
org.apache.flink.streaming.connectors.gcp.pubsub
org.apache.flink.streaming.connectors.kafka
org.apache.flink.streaming.connectors.kafka.shuffle
org.apache.flink.streaming.connectors.kinesis
org.apache.flink.streaming.experimental	This package holds classes that are experimental.
org.apache.flink.walkthrough.common.sink

Uses of SinkFunction.Context in org.apache.flink.connector.hbase.sink

Methods in org.apache.flink.connector.hbase.sink with parameters of type SinkFunction.Context

Modifier and Type	Method and Description
void	HBaseSinkFunction.invoke(T value, SinkFunction.Context context)

Uses of SinkFunction.Context in org.apache.flink.connector.jdbc.internal

Methods in org.apache.flink.connector.jdbc.internal with parameters of type SinkFunction.Context

Modifier and Type	Method and Description
void	GenericJdbcSinkFunction.invoke(T value, SinkFunction.Context context)

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 and Description
static <T> SinkFunction.Context<T>	SinkContextUtil.forTimestamp(long timestamp) Creates a SinkFunction.Context that 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 and Description
default void	SinkFunction.invoke(IN value, SinkFunction.Context context) Writes the given value to the sink.
void	TwoPhaseCommitSinkFunction.invoke(IN value, SinkFunction.Context context)
protected abstract void	TwoPhaseCommitSinkFunction.invoke(TXN transaction, IN value, SinkFunction.Context context) 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 and Description
void	StreamingFileSink.invoke(IN value, SinkFunction.Context context)
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 and Description
void	CollectSinkFunction.invoke(IN value, SinkFunction.Context context)

Uses of SinkFunction.Context in org.apache.flink.streaming.connectors.elasticsearch

Methods in org.apache.flink.streaming.connectors.elasticsearch with parameters of type SinkFunction.Context

Modifier and Type	Method and Description
void	ElasticsearchSinkBase.invoke(T value, SinkFunction.Context context)

Uses of SinkFunction.Context in org.apache.flink.streaming.connectors.gcp.pubsub

Methods in org.apache.flink.streaming.connectors.gcp.pubsub with parameters of type SinkFunction.Context

Modifier and Type	Method and Description
void	PubSubSink.invoke(IN message, SinkFunction.Context context)

Uses of SinkFunction.Context in org.apache.flink.streaming.connectors.kafka

Methods in org.apache.flink.streaming.connectors.kafka with parameters of type SinkFunction.Context

Modifier and Type	Method and Description
void	FlinkKafkaProducer.invoke(FlinkKafkaProducer.KafkaTransactionState transaction, IN next, SinkFunction.Context context)
void	FlinkKafkaProducer011.invoke(FlinkKafkaProducer011.KafkaTransactionState transaction, IN next, SinkFunction.Context context)
void	FlinkKafkaProducerBase.invoke(IN next, SinkFunction.Context context) Called when new data arrives to the sink, and forwards it to Kafka.
void	FlinkKafkaProducer010.invoke(T value, SinkFunction.Context context)

Uses of SinkFunction.Context in org.apache.flink.streaming.connectors.kafka.shuffle

Methods in org.apache.flink.streaming.connectors.kafka.shuffle with parameters of type SinkFunction.Context

Modifier and Type	Method and Description
void	FlinkKafkaShuffleProducer.invoke(FlinkKafkaProducer.KafkaTransactionState transaction, IN next, SinkFunction.Context context) This is the function invoked to handle each element.

Uses of SinkFunction.Context in org.apache.flink.streaming.connectors.kinesis

Methods in org.apache.flink.streaming.connectors.kinesis with parameters of type SinkFunction.Context

Modifier and Type	Method and Description
void	FlinkKinesisProducer.invoke(OUT 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 and Description
void	CollectSink.invoke(IN value, SinkFunction.Context context)

Uses of SinkFunction.Context in org.apache.flink.walkthrough.common.sink

Methods in org.apache.flink.walkthrough.common.sink with parameters of type SinkFunction.Context

Modifier and Type	Method and Description
void	AlertSink.invoke(Alert value, SinkFunction.Context context)