Modifier and Type | Method and Description |
---|---|
SplitEnumerator<SplitT,EnumChkT> |
Source.createEnumerator(SplitEnumeratorContext<SplitT> enumContext)
Creates a new SplitEnumerator for this source, starting a new input.
|
SplitEnumerator<SplitT,EnumChkT> |
Source.restoreEnumerator(SplitEnumeratorContext<SplitT> enumContext,
EnumChkT checkpoint)
Restores an enumerator from a checkpoint.
|
Modifier and Type | Method and Description |
---|---|
SplitEnumerator<NumberSequenceSource.NumberSequenceSplit,Collection<NumberSequenceSource.NumberSequenceSplit>> |
NumberSequenceSource.createEnumerator(SplitEnumeratorContext<NumberSequenceSource.NumberSequenceSplit> enumContext) |
SplitEnumerator<NumberSequenceSource.NumberSequenceSplit,Collection<NumberSequenceSource.NumberSequenceSplit>> |
NumberSequenceSource.restoreEnumerator(SplitEnumeratorContext<NumberSequenceSource.NumberSequenceSplit> enumContext,
Collection<NumberSequenceSource.NumberSequenceSplit> checkpoint) |
Constructor and Description |
---|
IteratorSourceEnumerator(SplitEnumeratorContext<SplitT> context,
Collection<SplitT> splits) |
Modifier and Type | Method and Description |
---|---|
SplitEnumerator<HybridSourceSplit,HybridSourceEnumeratorState> |
HybridSource.createEnumerator(SplitEnumeratorContext<HybridSourceSplit> enumContext) |
SplitEnumerator<HybridSourceSplit,HybridSourceEnumeratorState> |
HybridSource.restoreEnumerator(SplitEnumeratorContext<HybridSourceSplit> enumContext,
HybridSourceEnumeratorState checkpoint) |
Constructor and Description |
---|
HybridSourceSplitEnumerator(SplitEnumeratorContext<HybridSourceSplit> context,
List<org.apache.flink.connector.base.source.hybrid.HybridSource.SourceListEntry> sources,
int initialSourceIndex,
HybridSourceEnumeratorState restoredEnumeratorState) |
Modifier and Type | Method and Description |
---|---|
SplitEnumerator<SplitT,PendingSplitsCheckpoint<SplitT>> |
AbstractFileSource.createEnumerator(SplitEnumeratorContext<SplitT> enumContext) |
SplitEnumerator<SplitT,PendingSplitsCheckpoint<SplitT>> |
AbstractFileSource.restoreEnumerator(SplitEnumeratorContext<SplitT> enumContext,
PendingSplitsCheckpoint<SplitT> checkpoint) |
Constructor and Description |
---|
ContinuousFileSplitEnumerator(SplitEnumeratorContext<FileSourceSplit> context,
FileEnumerator enumerator,
FileSplitAssigner splitAssigner,
Path[] paths,
Collection<Path> alreadyDiscoveredPaths,
long discoveryInterval) |
StaticFileSplitEnumerator(SplitEnumeratorContext<FileSourceSplit> context,
FileSplitAssigner splitAssigner) |
Modifier and Type | Method and Description |
---|---|
SplitEnumerator<KafkaPartitionSplit,KafkaSourceEnumState> |
KafkaSource.createEnumerator(SplitEnumeratorContext<KafkaPartitionSplit> enumContext) |
SplitEnumerator<KafkaPartitionSplit,KafkaSourceEnumState> |
KafkaSource.restoreEnumerator(SplitEnumeratorContext<KafkaPartitionSplit> enumContext,
KafkaSourceEnumState checkpoint) |
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 | Class and Description |
---|---|
class |
TestingSplitEnumeratorContext<SplitT extends SourceSplit>
A test implementation of the
SplitEnumeratorContext , with manual, non-concurrent
interaction and intercepting of state. |
Modifier and Type | Method and Description |
---|---|
SplitEnumerator<HiveSourceSplit,PendingSplitsCheckpoint<HiveSourceSplit>> |
HiveSource.createEnumerator(SplitEnumeratorContext<HiveSourceSplit> enumContext) |
SplitEnumerator<HiveSourceSplit,PendingSplitsCheckpoint<HiveSourceSplit>> |
HiveSource.restoreEnumerator(SplitEnumeratorContext<HiveSourceSplit> enumContext,
PendingSplitsCheckpoint<HiveSourceSplit> checkpoint) |
Constructor and Description |
---|
ContinuousHiveSplitEnumerator(SplitEnumeratorContext<HiveSourceSplit> enumeratorContext,
T currentReadOffset,
Collection<List<String>> seenPartitionsSinceOffset,
FileSplitAssigner splitAssigner,
long discoveryInterval,
org.apache.hadoop.mapred.JobConf jobConf,
ObjectPath tablePath,
ContinuousPartitionFetcher<org.apache.hadoop.hive.metastore.api.Partition,T> fetcher,
HiveTableSource.HiveContinuousPartitionFetcherContext<T> fetcherContext) |
Modifier and Type | Class and Description |
---|---|
class |
SourceCoordinatorContext<SplitT extends SourceSplit>
A context class for the
OperatorCoordinator . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.