Package | Description |
---|---|
org.apache.flink.streaming.api.functions.sink | |
org.apache.flink.streaming.api.functions.sink.filesystem | |
org.apache.flink.streaming.connectors.elasticsearch | |
org.apache.flink.streaming.connectors.kafka | |
org.apache.flink.streaming.experimental |
This package holds classes that are experimental.
|
org.apache.flink.streaming.python.api.functions |
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. |
Modifier and Type | Method and Description |
---|---|
void |
TwoPhaseCommitSinkFunction.invoke(IN value,
SinkFunction.Context context) |
default void |
SinkFunction.invoke(IN value,
SinkFunction.Context context)
Writes the given value to the sink.
|
protected abstract void |
TwoPhaseCommitSinkFunction.invoke(TXN transaction,
IN value,
SinkFunction.Context context)
Write value within a transaction.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamingFileSink.invoke(IN value,
SinkFunction.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
ElasticsearchSinkBase.invoke(T value,
SinkFunction.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
FlinkKafkaProducer.invoke(org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.KafkaTransactionState transaction,
IN next,
SinkFunction.Context context) |
void |
FlinkKafkaProducer011.invoke(org.apache.flink.streaming.connectors.kafka.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) |
Modifier and Type | Method and Description |
---|---|
void |
CollectSink.invoke(IN value,
SinkFunction.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
PythonSinkFunction.invoke(org.python.core.PyObject value,
SinkFunction.Context context) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.