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) |
Modifier and Type | Class and Description |
---|---|
class |
IteratorSourceEnumerator<SplitT extends IteratorSourceSplit<?,?>>
A
SplitEnumerator for iterator sources. |
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) |
Modifier and Type | Class and Description |
---|---|
class |
ContinuousFileSplitEnumerator
A continuously monitoring enumerator.
|
class |
StaticFileSplitEnumerator
A SplitEnumerator implementation for bounded / batch
FileSource input. |
Modifier and Type | Method and Description |
---|---|
SplitEnumerator<KafkaPartitionSplit,KafkaSourceEnumState> |
KafkaSource.createEnumerator(SplitEnumeratorContext<KafkaPartitionSplit> enumContext) |
SplitEnumerator<KafkaPartitionSplit,KafkaSourceEnumState> |
KafkaSource.restoreEnumerator(SplitEnumeratorContext<KafkaPartitionSplit> enumContext,
KafkaSourceEnumState checkpoint) |
Modifier and Type | Class and Description |
---|---|
class |
KafkaSourceEnumerator
The enumerator class for Kafka source.
|
Modifier and Type | Class and Description |
---|---|
class |
ContinuousHiveSplitEnumerator<T extends Comparable<T>>
A continuously monitoring
SplitEnumerator for hive source. |
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) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.