Modifier and Type | Class and Description |
---|---|
class |
SpoutWrapper<OUT>
A
SpoutWrapper wraps an IRichSpout in order to execute it within a Flink Streaming program. |
Modifier and Type | Method and Description |
---|---|
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.addSource(SourceFunction<OUT> function)
Adds a Data Source to the streaming topology.
|
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.addSource(SourceFunction<OUT> function,
String sourceName)
Ads a data source with a custom type information thus opening a
DataStream . |
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.addSource(SourceFunction<OUT> function,
String sourceName,
TypeInformation<OUT> typeInfo)
Ads a data source with a custom type information thus opening a
DataStream . |
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.addSource(SourceFunction<OUT> function,
TypeInformation<OUT> typeInfo)
Ads a data source with a custom type information thus opening a
DataStream . |
Modifier and Type | Interface and Description |
---|---|
interface |
ParallelSourceFunction<OUT>
A stream data source that is executed in parallel.
|
Modifier and Type | Class and Description |
---|---|
class |
ConnectorSource<OUT> |
class |
FileMonitoringFunction |
class |
FileSourceFunction<OUT> |
class |
FromElementsFunction<T>
A stream source function that returns a sequence of elements.
|
class |
FromIteratorFunction<T> |
class |
FromSplittableIteratorFunction<T> |
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 |
RichParallelSourceFunction<OUT>
Base class for implementing a parallel data source.
|
class |
RichSourceFunction<OUT>
Base class for implementing a parallel data source that has access to context information
(via
AbstractRichFunction.getRuntimeContext() ) and additional life-cycle methods
(AbstractRichFunction.open(org.apache.flink.configuration.Configuration) and AbstractRichFunction.close() . |
class |
SocketTextStreamFunction
A source function that reads strings from a socket.
|
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 |
StoppableStreamSource<OUT,SRC extends SourceFunction<OUT> & StoppableFunction>
|
class |
StreamSource<OUT,SRC extends SourceFunction<OUT>>
StreamOperator for streaming sources. |
Modifier and Type | Method and Description |
---|---|
<T> DataStream<T> |
StreamExecutionEnvironment.addSource(SourceFunction<T> function,
TypeInformation<T> evidence$7)
Create a DataStream using a user defined source function for arbitrary
source functionality.
|
Modifier and Type | Class and Description |
---|---|
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> |
Modifier and Type | Class and Description |
---|---|
class |
NiFiSource
A source that pulls data from Apache NiFi using the NiFi Site-to-Site client.
|
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 |
TwitterFilterSource
An extension of
TwitterSource by filter parameters. |
class |
TwitterSource
Implementation of
SourceFunction specialized to emit tweets from
Twitter. |
Modifier and Type | Class and Description |
---|---|
class |
WikipediaEditsSource |
Modifier and Type | Class and Description |
---|---|
static class |
WindowJoin.GradeSource
Continuously emit tuples with random names and integers (grades).
|
static class |
WindowJoin.SalarySource
Continuously emit tuples with random names and integers (salaries).
|
Modifier and Type | Class and Description |
---|---|
static class |
IncrementalLearningSkeleton.FiniteNewDataSource
Feeds new data for newData.
|
static class |
IncrementalLearningSkeleton.FiniteTrainingDataSource
Feeds new training data for the partial model builder.
|
Modifier and Type | Class and Description |
---|---|
class |
SourceStreamTask<OUT,SRC extends SourceFunction<OUT>,OP extends StreamSource<OUT,SRC>>
Task for executing streaming sources.
|
class |
StoppableSourceStreamTask<OUT,SRC extends SourceFunction<OUT> & StoppableFunction>
Stoppable task for executing stoppable streaming sources.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.