Modifier and Type | Class and Description |
---|---|
static class |
FileSinkProgram.Generator
Data-generating source function.
|
Modifier and Type | Class and Description |
---|---|
class |
HBaseSinkFunction<T>
The sink function for HBase.
|
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 | Class and Description |
---|---|
static class |
StreamSQLTestProgram.Generator
Data-generating source function.
|
static class |
StreamSQLTestProgram.KillMapper
Kills the first execution attempt of an application when it receives the second record.
|
Modifier and Type | Class and Description |
---|---|
class |
StateBootstrapFunction<IN>
Interface for writing elements to operator state.
|
Modifier and Type | Class and Description |
---|---|
class |
TwoPhaseCommitSinkFunction<IN,TXN,CONTEXT>
This is a recommended base class for all of the
SinkFunction that intend to implement
exactly-once semantic. |
Modifier and Type | Class and Description |
---|---|
class |
StreamingFileSink<IN>
Deprecated.
Use
FileSink instead. |
Modifier and Type | Class and Description |
---|---|
class |
ContinuousFileMonitoringFunction<OUT>
This is the single (non-parallel) monitoring task which takes a
FileInputFormat and,
depending on the FileProcessingMode and the FilePathFilter , it is responsible
for:
Monitoring a user-provided path. |
class |
FromElementsFunction<T>
A stream source function that returns a sequence of elements.
|
class |
MessageAcknowledgingSourceBase<Type,UId>
Abstract base class for data sources that receive elements from a message queue and acknowledge
them back by IDs.
|
class |
MultipleIdsMessageAcknowledgingSourceBase<Type,UId,SessionId>
Abstract base class for data sources that receive elements from a message queue and acknowledge
them back by IDs.
|
class |
StatefulSequenceSource
A stateful streaming source that emits each number from a given interval exactly once, possibly
in parallel.
|
Modifier and Type | Class and Description |
---|---|
class |
DataGeneratorSource<T>
A data generator source that abstract data generator.
|
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 |
FlinkKafkaConsumer<T>
Deprecated.
|
class |
FlinkKafkaConsumerBase<T>
Base class of all Flink Kafka Consumer data sources.
|
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 |
FlinkKafkaShuffleConsumer<T>
Flink Kafka Shuffle Consumer Function.
|
class |
FlinkKafkaShuffleProducer<IN,KEY>
Flink Kafka Shuffle Producer Function.
|
Modifier and Type | Class and Description |
---|---|
class |
FlinkDynamoDBStreamsConsumer<T>
Consume events from DynamoDB streams.
|
class |
FlinkKinesisConsumer<T>
The Flink Kinesis Consumer is an exactly-once parallel streaming data source that subscribes to
multiple AWS Kinesis streams within the same AWS service region, and can handle resharding of
streams.
|
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 |
RMQSource<OUT>
RabbitMQ source (consumer) which reads from a queue and acknowledges messages on checkpoints.
|
Modifier and Type | Class and Description |
---|---|
class |
SimpleSource
A checkpointed source.
|
Modifier and Type | Class and Description |
---|---|
static class |
PeriodicStreamingJob.PeriodicSourceGenerator
Data-generating source function.
|
class |
SequenceGeneratorSource
This source function generates a sequence of long values per key.
|
Modifier and Type | Class and Description |
---|---|
class |
ArtificalOperatorStateMapper<IN,OUT>
A self-verifiable
RichMapFunction used to verify checkpointing and restore semantics for
various kinds of operator state. |
class |
ArtificialKeyedStateMapper<IN,OUT>
A generic, stateful
MapFunction that allows specifying what states to maintain based on a
provided list of ArtificialStateBuilder s. |
Modifier and Type | Class and Description |
---|---|
class |
ArrowSourceFunction
An Arrow
SourceFunction which takes the serialized arrow record batch data as input. |
Modifier and Type | Class and Description |
---|---|
class |
FastTop1Function
A more concise implementation for
AppendOnlyTopNFunction and UpdatableTopNFunction when only Top-1 is desired. |
class |
UpdatableTopNFunction
A TopN function could handle updating stream.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.