Modifier and Type | Interface and Description |
---|---|
interface |
Checkpointed<T extends Serializable>
Deprecated.
Please use
ListCheckpointed as illustrated above, or
CheckpointedFunction for more control over the checkpointing process. |
interface |
CheckpointedAsynchronously<T extends Serializable>
Deprecated.
Please use
ListCheckpointed and CheckpointedFunction instead,
as illustrated in the example above. |
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.
Deciding which files should be further read and processed.
Creating the splits corresponding to those files.
Assigning them to downstream tasks for further processing.
|
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 |
FlinkKafkaConsumer010<T>
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from
Apache Kafka 0.10.x.
|
class |
FlinkKafkaConsumer08<T>
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from
Apache Kafka 0.8.x.
|
class |
FlinkKafkaConsumer081<T>
Deprecated.
|
class |
FlinkKafkaConsumer082<T>
Deprecated.
|
class |
FlinkKafkaConsumer09<T>
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from
Apache Kafka 0.9.x.
|
class |
FlinkKafkaConsumerBase<T>
Base class of all Flink Kafka Consumer data sources.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.