Package | Description |
---|---|
org.apache.flink.connector.hbase.sink | |
org.apache.flink.connector.jdbc.internal | |
org.apache.flink.connector.jdbc.xa |
Provides exactly-once JDBC sink implementation using Java XA transactions API (JTA).
|
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.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 |
Modifier and Type | Method and Description |
---|---|
void |
HBaseSinkFunction.invoke(T value,
SinkFunction.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
GenericJdbcSinkFunction.invoke(T value,
SinkFunction.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
JdbcXaSinkFunction.invoke(T value,
SinkFunction.Context context) |
Modifier and Type | Method and Description |
---|---|
static SinkFunction.Context |
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 |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamingFileSink.invoke(IN value,
SinkFunction.Context context)
Deprecated.
|
Bucket<IN,BucketID> |
Buckets.onElement(IN value,
SinkFunction.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
CollectSinkFunction.invoke(IN value,
SinkFunction.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
PubSubSink.invoke(IN message,
SinkFunction.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
FlinkKafkaProducer.invoke(FlinkKafkaProducer.KafkaTransactionState transaction,
IN next,
SinkFunction.Context context)
Deprecated.
|
void |
FlinkKafkaProducerBase.invoke(IN next,
SinkFunction.Context context)
Called when new data arrives to the sink, and forwards it to Kafka.
|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
FlinkKinesisProducer.invoke(OUT value,
SinkFunction.Context context)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
CollectSink.invoke(IN value,
SinkFunction.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
AlertSink.invoke(Alert value,
SinkFunction.Context context) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.