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>
Simple implementation of the SinkFunction writing tuples in the specified
OutputFormat format.
|
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>
Simple implementation of the SinkFunction writing tuples as simple text to
the file specified by path.
|
class |
WriteSinkFunctionByMillis<IN>
Implementation of WriteSinkFunction.
|
Constructor and Description |
---|
StreamSink(SinkFunction<IN> sinkFunction) |
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 |
ElasticsearchSink<T>
Elasticsearch 1.x sink that requests multiple
ActionRequests
against a cluster for each incoming element. |
class |
ElasticsearchSinkBase<T>
Base class for all Flink Elasticsearch Sinks.
|
Modifier and Type | Class and Description |
---|---|
class |
RollingSink<T>
Deprecated.
use
BucketingSink instead. |
Modifier and Type | Class and Description |
---|---|
class |
BucketingSink<T>
Sink that emits its input elements to
FileSystem files within
buckets. |
Modifier and Type | Class and Description |
---|---|
class |
FlinkKafkaProducer<IN>
Deprecated.
Use
FlinkKafkaProducer08 . |
class |
FlinkKafkaProducer010<T>
Flink Sink to produce data into a Kafka topic.
|
class |
FlinkKafkaProducer011<IN>
Flink Sink to produce data into a Kafka topic.
|
class |
FlinkKafkaProducer08<IN>
Flink Sink to produce data into a Kafka topic.
|
class |
FlinkKafkaProducer09<IN>
Flink Sink to produce data into a Kafka topic.
|
class |
FlinkKafkaProducerBase<IN>
Flink Sink to produce data into a Kafka topic.
|
Modifier and Type | Class and Description |
---|---|
class |
NiFiSink<T>
A sink that delivers data to Apache NiFi using the NiFi Site-to-Site client.
|
Modifier and Type | Class and Description |
---|---|
class |
RMQSink<IN>
A Sink for publishing data into RabbitMQ.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.