Interface JobRetainedStrategy
-
- All Known Implementing Classes:
CompositeJobRetainedStrategy
public interface JobRetainedStrategyTo define the strategy interface to judge whether the file should be retained.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description booleanshouldRetain(org.apache.flink.core.fs.FileStatus file, int fileOrderedIndex)Judge whether the file should be retained.
-
-
-
Method Detail
-
shouldRetain
boolean shouldRetain(org.apache.flink.core.fs.FileStatus file, int fileOrderedIndex)Judge whether the file should be retained.- Parameters:
file- the target file to judge.fileOrderedIndex- the specified order index position of the target file,- Returns:
- The result that indicates whether the file should be retained.
-
-