THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
@PublicEvolving
public interface SourceReader<T, SplitT extends SourceSplit>
extends AutoCloseable, CheckpointListener, CheckpointAvailabilityProvider {
/**
* This method has a default implementation of returning SNAPSHOT_AVAILABLE, which means that
* the default behavior is to take a snapshot under any scenario.
*/
@Override
default SnapshotAvailability isSnapshotAvailable(long checkpointID) {
return SnapshotAvailability.AVAILABLE;
}
} |
...