Uses of Package
org.apache.flink.connector.file.src.enumerate
-
Classes in org.apache.flink.connector.file.src.enumerate used by org.apache.flink.connector.file.src Class Description FileEnumerator.Provider Factory for theFileEnumerator, to allow theFileEnumeratorto be eagerly initialized and to not be serializable. -
Classes in org.apache.flink.connector.file.src.enumerate used by org.apache.flink.connector.file.src.enumerate Class Description BlockSplittingRecursiveEnumerator ThisFileEnumeratorenumerates all files under the given paths recursively, and creates a separate split for each file block.DynamicFileEnumerator FileEnumeratorthat supports dynamic filtering.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.NonSplittingRecursiveEnumerator ThisFileEnumeratorenumerates all files under the given paths recursively. -
Classes in org.apache.flink.connector.file.src.enumerate used by org.apache.flink.connector.file.src.impl Class Description 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.