Interface JobRetainedStrategy

  • All Known Implementing Classes:
    CompositeJobRetainedStrategy

    public interface JobRetainedStrategy
    To 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
      boolean shouldRetain​(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.