Interface FileEnumerator

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Interface Description
      static interface  FileEnumerator.Provider
      Factory for the FileEnumerator, to allow the FileEnumerator to be eagerly initialized and to not be serializable.
    • Method Detail

      • enumerateSplits

        Collection<FileSourceSplit> enumerateSplits​(org.apache.flink.core.fs.Path[] paths,
                                                    int minDesiredSplits)
                                             throws IOException
        Generates all file splits for the relevant files under the given paths. The minDesiredSplits is an optional hint indicating how many splits would be necessary to exploit parallelism properly.
        Throws:
        IOException