Modifier and Type | Class and Description |
---|---|
class |
NumberSequenceSource
A data source that produces a sequence of numbers (longs).
|
Constructor and Description |
---|
SourceCoordinator(String operatorName,
ExecutorService coordinatorExecutor,
Source<?,SplitT,EnumChkT> source,
SourceCoordinatorContext<SplitT> context) |
SourceCoordinatorProvider(String operatorName,
OperatorID operatorID,
Source<?,SplitT,?> source,
int numWorkerThreads)
Construct the
SourceCoordinatorProvider . |
Constructor and Description |
---|
DataStreamSource(StreamExecutionEnvironment environment,
Source<T,?,?> source,
WatermarkStrategy<T> timestampsAndWatermarks,
TypeInformation<T> outTypeInfo,
String sourceName)
Constructor for new Sources (FLIP-27).
|
Modifier and Type | Method and Description |
---|---|
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.fromSource(Source<OUT,?,?> source,
WatermarkStrategy<OUT> timestampsAndWatermarks,
String sourceName)
Add a data
Source to the environment to get a DataStream . |
<OUT> DataStreamSource<OUT> |
StreamExecutionEnvironment.fromSource(Source<OUT,?,?> source,
WatermarkStrategy<OUT> timestampsAndWatermarks,
String sourceName,
TypeInformation<OUT> typeInfo)
Add a data
Source to the environment to get a DataStream . |
Constructor and Description |
---|
SourceOperatorFactory(Source<OUT,?,?> source,
WatermarkStrategy<OUT> watermarkStrategy) |
SourceOperatorFactory(Source<OUT,?,?> source,
WatermarkStrategy<OUT> watermarkStrategy,
int numCoordinatorWorkerThread) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.