Modifier and Type | Method and Description |
---|---|
Boundedness |
Source.getBoundedness()
Get the boundedness of this source.
|
static Boundedness |
Boundedness.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static Boundedness[] |
Boundedness.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
Boundedness |
NumberSequenceSource.getBoundedness() |
Modifier and Type | Method and Description |
---|---|
Boundedness |
AbstractFileSource.getBoundedness() |
Modifier and Type | Method and Description |
---|---|
Boundedness |
KafkaSource.getBoundedness() |
Modifier and Type | Method and Description |
---|---|
protected abstract SplitT |
SourceReaderTestBase.getSplit(int splitId,
int numRecords,
Boundedness boundedness) |
protected abstract List<SplitT> |
SourceReaderTestBase.getSplits(int numSplits,
int numRecordsPerSplit,
Boundedness boundedness) |
Constructor and Description |
---|
DataStreamSource(StreamExecutionEnvironment environment,
TypeInformation<T> outTypeInfo,
StreamSource<T,?> operator,
boolean isParallel,
String sourceName,
Boundedness boundedness)
The constructor used to create legacy sources.
|
Modifier and Type | Method and Description |
---|---|
Boundedness |
SourceOperatorFactory.getBoundedness() |
Modifier and Type | Method and Description |
---|---|
Boundedness |
LegacySourceTransformation.getBoundedness() |
Boundedness |
SourceTransformation.getBoundedness() |
Boundedness |
WithBoundedness.getBoundedness()
Returns the
Boundedness of this Transformation . |
Constructor and Description |
---|
LegacySourceTransformation(String name,
StreamOperatorFactory<T> operatorFactory,
TypeInformation<T> outputType,
int parallelism,
Boundedness boundedness) |
LegacySourceTransformation(String name,
StreamSource<T,?> operator,
TypeInformation<T> outputType,
int parallelism,
Boundedness boundedness)
Creates a new
LegacySourceTransformation from the given operator. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.