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 |
HybridSource.getBoundedness() |
Modifier and Type | Method and Description |
---|---|
<ToEnumT extends SplitEnumerator,NextSourceT extends Source<T,?,?>> |
HybridSource.HybridSourceBuilder.addSource(HybridSource.SourceFactory<T,NextSourceT,? super EnumT> sourceFactory,
Boundedness boundedness)
Add source with deferred instantiation based on previous enumerator.
|
Modifier and Type | Method and Description |
---|---|
Boundedness |
AbstractFileSource.getBoundedness() |
Modifier and Type | Method and Description |
---|---|
Boundedness |
KafkaSource.getBoundedness() |
Constructor and Description |
---|
KafkaSourceEnumerator(KafkaSubscriber subscriber,
OffsetsInitializer startingOffsetInitializer,
OffsetsInitializer stoppingOffsetInitializer,
Properties properties,
SplitEnumeratorContext<KafkaPartitionSplit> context,
Boundedness boundedness) |
KafkaSourceEnumerator(KafkaSubscriber subscriber,
OffsetsInitializer startingOffsetInitializer,
OffsetsInitializer stoppingOffsetInitializer,
Properties properties,
SplitEnumeratorContext<KafkaPartitionSplit> context,
Boundedness boundedness,
Set<org.apache.kafka.common.TopicPartition> assignedPartitions) |
Modifier and Type | Method and Description |
---|---|
Boundedness |
PulsarSource.getBoundedness() |
Modifier and Type | Method and Description |
---|---|
Boundedness |
TestingSourceSettings.getBoundedness()
Boundedness of the source.
|
Modifier and Type | Method and Description |
---|---|
TestingSourceSettings.Builder |
TestingSourceSettings.Builder.setBoundedness(Boundedness boundedness) |
Modifier and Type | Method and Description |
---|---|
Boundedness |
FromElementsSource.getBoundedness() |
Constructor and Description |
---|
FromElementsSource(Boundedness boundedness,
List<OUT> elements,
Integer emittedElementsNum) |
FromElementsSourceReader(Integer limitedNum,
List<T> elements,
Boundedness boundedness,
SourceReaderContext context) |
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 . |
Modifier and Type | Method and Description |
---|---|
void |
LegacySourceTransformation.setBoundedness(Boundedness boundedness)
Mutable for legacy sources in the Table API.
|
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–2023 The Apache Software Foundation. All rights reserved.