Package | Description |
---|---|
org.apache.flink.connector.base.source.hybrid |
Modifier and Type | Method and Description |
---|---|
HybridSourceEnumeratorState |
HybridSourceEnumeratorStateSerializer.deserialize(int version,
byte[] serialized) |
HybridSourceEnumeratorState |
HybridSourceSplitEnumerator.snapshotState(long checkpointId) |
Modifier and Type | Method and Description |
---|---|
SplitEnumerator<HybridSourceSplit,HybridSourceEnumeratorState> |
HybridSource.createEnumerator(SplitEnumeratorContext<HybridSourceSplit> enumContext) |
SimpleVersionedSerializer<HybridSourceEnumeratorState> |
HybridSource.getEnumeratorCheckpointSerializer() |
SplitEnumerator<HybridSourceSplit,HybridSourceEnumeratorState> |
HybridSource.restoreEnumerator(SplitEnumeratorContext<HybridSourceSplit> enumContext,
HybridSourceEnumeratorState checkpoint) |
Modifier and Type | Method and Description |
---|---|
SplitEnumerator<HybridSourceSplit,HybridSourceEnumeratorState> |
HybridSource.restoreEnumerator(SplitEnumeratorContext<HybridSourceSplit> enumContext,
HybridSourceEnumeratorState checkpoint) |
byte[] |
HybridSourceEnumeratorStateSerializer.serialize(HybridSourceEnumeratorState enumState) |
Constructor and Description |
---|
HybridSourceSplitEnumerator(SplitEnumeratorContext<HybridSourceSplit> context,
List<org.apache.flink.connector.base.source.hybrid.HybridSource.SourceListEntry> sources,
int initialSourceIndex,
HybridSourceEnumeratorState restoredEnumeratorState) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.