Package | Description |
---|---|
org.apache.flink.table.store.connector.source |
Modifier and Type | Method and Description |
---|---|
PendingSplitsCheckpoint |
PendingSplitsCheckpointSerializer.deserialize(int version,
byte[] serialized) |
PendingSplitsCheckpoint |
StaticFileStoreSplitEnumerator.snapshotState(long checkpointId) |
PendingSplitsCheckpoint |
ContinuousFileSplitEnumerator.snapshotState(long checkpointId) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint> |
FlinkSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context) |
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint> |
StaticFileStoreSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context,
PendingSplitsCheckpoint checkpoint) |
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint> |
SimpleSystemSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context,
PendingSplitsCheckpoint checkpoint) |
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint> |
ContinuousFileStoreSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context,
PendingSplitsCheckpoint checkpoint) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint> |
StaticFileStoreSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context,
PendingSplitsCheckpoint checkpoint) |
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint> |
SimpleSystemSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context,
PendingSplitsCheckpoint checkpoint) |
org.apache.flink.api.connector.source.SplitEnumerator<FileStoreSourceSplit,PendingSplitsCheckpoint> |
ContinuousFileStoreSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileStoreSourceSplit> context,
PendingSplitsCheckpoint checkpoint) |
byte[] |
PendingSplitsCheckpointSerializer.serialize(PendingSplitsCheckpoint pendingSplitsCheckpoint) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.