Modifier and Type | Class and Description |
---|---|
class |
HBaseSinkFunction<T>
The sink function for HBase.
|
Modifier and Type | Method and Description |
---|---|
static <T> SinkFunction<T> |
JdbcSink.exactlyOnceSink(String sql,
JdbcStatementBuilder<T> statementBuilder,
JdbcExecutionOptions executionOptions,
JdbcExactlyOnceOptions exactlyOnceOptions,
SerializableSupplier<XADataSource> dataSourceSupplier)
Create JDBC sink which provides exactly-once guarantee.
|
static <T> SinkFunction<T> |
JdbcSink.sink(String sql,
JdbcStatementBuilder<T> statementBuilder,
JdbcConnectionOptions connectionOptions)
Create a JDBC sink with the default
JdbcExecutionOptions . |
static <T> SinkFunction<T> |
JdbcSink.sink(String sql,
JdbcStatementBuilder<T> statementBuilder,
JdbcExecutionOptions executionOptions,
JdbcConnectionOptions connectionOptions)
Create a JDBC sink.
|
Modifier and Type | Class and Description |
---|---|
class |
GenericJdbcSinkFunction<T>
A generic SinkFunction for JDBC.
|
Modifier and Type | Class and Description |
---|---|
class |
JdbcXaSinkFunction<T>
JDBC sink function that uses XA transactions to provide exactly once guarantees.
|
Modifier and Type | Method and Description |
---|---|
DataStreamSink<T> |
DataStream.addSink(SinkFunction<T> sinkFunction)
Adds the given sink to this DataStream.
|
DataStreamSink<T> |
KeyedStream.addSink(SinkFunction<T> sinkFunction) |
Modifier and Type | Class and Description |
---|---|
class |
DiscardingSink<T>
A stream sink that ignores all elements.
|
class |
OutputFormatSinkFunction<IN>
Deprecated.
Please use the
StreamingFileSink
for writing to files from a streaming program. |
class |
PrintSinkFunction<IN>
Implementation of the SinkFunction writing every tuple to the standard output or standard error
stream.
|
class |
RichSinkFunction<IN>
A
RichFunction version of SinkFunction . |
class |
SocketClientSink<IN>
Socket client that acts as a streaming sink.
|
class |
TwoPhaseCommitSinkFunction<IN,TXN,CONTEXT>
This is a recommended base class for all of the
SinkFunction that intend to implement
exactly-once semantic. |
class |
WriteSinkFunction<IN>
Deprecated.
Please use the
StreamingFileSink
for writing to files from a streaming program. |
class |
WriteSinkFunctionByMillis<IN>
Deprecated.
Please use the
StreamingFileSink
for writing to files from a streaming program. |
Modifier and Type | Class and Description |
---|---|
class |
StreamingFileSink<IN>
Deprecated.
Use
FileSink instead. |
Constructor and Description |
---|
StreamSink(SinkFunction<IN> sinkFunction) |
Modifier and Type | Class and Description |
---|---|
class |
CollectSinkFunction<IN>
A sink function that collects query results and sends them back to the client.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractCassandraTupleSink<IN>
Abstract sink to write tuple-like values into a Cassandra cluster.
|
class |
CassandraPojoSink<IN>
Flink Sink to save data into a Cassandra cluster using Mapper,
which it uses annotations from
com.datastax.driver.mapping.annotations.
|
class |
CassandraRowSink
A SinkFunction to write Row records into a Cassandra table.
|
class |
CassandraScalaProductSink<IN extends scala.Product>
Sink to write scala tuples and case classes into a Cassandra cluster.
|
class |
CassandraSinkBase<IN,V>
CassandraSinkBase is the common abstract class of
CassandraPojoSink and CassandraTupleSink . |
class |
CassandraTupleSink<IN extends Tuple>
Sink to write Flink
Tuple s into a Cassandra cluster. |
Modifier and Type | Class and Description |
---|---|
class |
ElasticsearchSinkBase<T,C extends AutoCloseable>
Base class for all Flink Elasticsearch Sinks.
|
Modifier and Type | Class and Description |
---|---|
class |
ElasticsearchSink<T>
Deprecated.
This sink has been deprecated in favor of
ElasticsearchSink |
Modifier and Type | Class and Description |
---|---|
class |
PubSubSink<IN>
A sink function that outputs to PubSub.
|
Modifier and Type | Class and Description |
---|---|
class |
FlinkKafkaProducer<IN>
Deprecated.
Please use
KafkaSink . |
class |
FlinkKafkaProducerBase<IN>
Flink Sink to produce data into a Kafka topic.
|
Modifier and Type | Class and Description |
---|---|
class |
FlinkKafkaShuffleProducer<IN,KEY>
Flink Kafka Shuffle Producer Function.
|
Modifier and Type | Class and Description |
---|---|
class |
FlinkKinesisProducer<OUT>
Deprecated.
This producer based on the Kinesis Producer Library KPL has been superseded. The new
sink can be found in the module
flink-connectors/flink-connector-aws-kinesis-streams
and package KinesisStreamsSink . It is based on the AWS SDK for Java 2.x. The work to
replace this sink was carried out in FLINK-24227. |
Modifier and Type | Class and Description |
---|---|
class |
RMQSink<IN>
A Sink for publishing data into RabbitMQ.
|
Modifier and Type | Class and Description |
---|---|
class |
CollectSink<IN>
A specialized data sink to be used by DataStreamUtils.collect().
|
Modifier and Type | Method and Description |
---|---|
SinkFunction<RowData> |
SinkFunctionProvider.createSinkFunction()
Creates a
SinkFunction instance. |
Modifier and Type | Method and Description |
---|---|
static SinkFunctionProvider |
SinkFunctionProvider.of(SinkFunction<RowData> sinkFunction)
Helper method for creating a static provider.
|
static SinkFunctionProvider |
SinkFunctionProvider.of(SinkFunction<RowData> sinkFunction,
Integer sinkParallelism)
Helper method for creating a SinkFunction provider with a provided sink parallelism.
|
Constructor and Description |
---|
SinkOperator(SinkFunction<RowData> sinkFunction,
int rowtimeFieldIndex) |
Modifier and Type | Class and Description |
---|---|
class |
TestListResultSink<T>
Thread-safe sink for collecting elements into an on-heap list.
|
Modifier and Type | Class and Description |
---|---|
class |
AlertSink
A sink for outputting alerts.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.