Package org.apache.flink.connector.file.src.enumerate
-
Interface Summary Interface Description DynamicFileEnumerator FileEnumeratorthat supports dynamic filtering.DynamicFileEnumerator.Provider Factory for theDynamicFileEnumerator.FileEnumerator TheFileEnumerator's task is to discover all files to be read and to split them into a set ofFileSourceSplit.FileEnumerator.Provider Factory for theFileEnumerator, to allow theFileEnumeratorto be eagerly initialized and to not be serializable. -
Class Summary Class Description BlockSplittingRecursiveAllDirEnumerator ThisFileEnumeratorenumerates all files under the given paths recursively except the hidden directories, and creates a separate split for each file block.BlockSplittingRecursiveEnumerator ThisFileEnumeratorenumerates all files under the given paths recursively, and creates a separate split for each file block.DefaultFileFilter A file filter that filters out hidden files based on common naming patterns, i.e., files where the filename starts with '.' or with '_'.NonSplittingRecursiveAllDirEnumerator ThisFileEnumeratorenumerates all files under the given paths recursively except the hidden directories.NonSplittingRecursiveEnumerator ThisFileEnumeratorenumerates all files under the given paths recursively.RegexFileFilter A file filter that filters out hidden files, seeDefaultFileFilterand the files whose path doesn't match the given regex pattern.