Class CompositeJobRetainedStrategy

    • Method Detail

      • createFrom

        public static JobRetainedStrategy createFrom​(org.apache.flink.configuration.ReadableConfig config)
      • shouldRetain

        public boolean shouldRetain​(org.apache.flink.core.fs.FileStatus file,
                                    int fileOrderedIndex)
        Description copied from interface: JobRetainedStrategy
        Judge whether the file should be retained.
        Specified by:
        shouldRetain in interface JobRetainedStrategy
        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.