org.apache.flink.api.connector.source.SplitEnumerator<RewriteFileIndexSource.Split,RewriteFileIndexSource.CheckpointState> |
RewriteFileIndexSource.createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<RewriteFileIndexSource.Split> splitEnumeratorContext) |
org.apache.flink.core.io.SimpleVersionedSerializer<RewriteFileIndexSource.CheckpointState> |
RewriteFileIndexSource.getEnumeratorCheckpointSerializer() |
org.apache.flink.api.connector.source.SplitEnumerator<RewriteFileIndexSource.Split,RewriteFileIndexSource.CheckpointState> |
RewriteFileIndexSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<RewriteFileIndexSource.Split> splitEnumeratorContext,
RewriteFileIndexSource.CheckpointState checkpointState) |