Uses of Interface
org.apache.flink.connector.file.src.enumerate.FileEnumerator
-
Packages that use FileEnumerator Package Description org.apache.flink.connector.file.src.enumerate org.apache.flink.connector.file.src.impl -
-
Uses of FileEnumerator in org.apache.flink.connector.file.src.enumerate
Subinterfaces of FileEnumerator in org.apache.flink.connector.file.src.enumerate Modifier and Type Interface Description interfaceDynamicFileEnumeratorFileEnumeratorthat supports dynamic filtering.Classes in org.apache.flink.connector.file.src.enumerate that implement FileEnumerator Modifier and Type Class Description classBlockSplittingRecursiveAllDirEnumeratorThisFileEnumeratorenumerates all files under the given paths recursively except the hidden directories, and creates a separate split for each file block.classBlockSplittingRecursiveEnumeratorThisFileEnumeratorenumerates all files under the given paths recursively, and creates a separate split for each file block.classNonSplittingRecursiveAllDirEnumeratorThisFileEnumeratorenumerates all files under the given paths recursively except the hidden directories.classNonSplittingRecursiveEnumeratorThisFileEnumeratorenumerates all files under the given paths recursively.Methods in org.apache.flink.connector.file.src.enumerate that return FileEnumerator Modifier and Type Method Description FileEnumeratorFileEnumerator.Provider. create() -
Uses of FileEnumerator in org.apache.flink.connector.file.src.impl
Constructors in org.apache.flink.connector.file.src.impl with parameters of type FileEnumerator Constructor Description ContinuousFileSplitEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FileSourceSplit> context, FileEnumerator enumerator, FileSplitAssigner splitAssigner, org.apache.flink.core.fs.Path[] paths, Collection<org.apache.flink.core.fs.Path> alreadyDiscoveredPaths, long discoveryInterval)
-