Interface DynamicFileEnumerator
-
- All Superinterfaces:
FileEnumerator
@PublicEvolving public interface DynamicFileEnumerator extends FileEnumerator
FileEnumerator
that supports dynamic filtering. The enumerator only enumerates splits that exist in the givenDynamicFilteringData
, while enumerates all splits if no DynamicFilteringData is provided when #enumerateSplits is called.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interface
DynamicFileEnumerator.Provider
Factory for theDynamicFileEnumerator
.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
setDynamicFilteringData(DynamicFilteringData data)
Provides aDynamicFilteringData
for filtering while the enumerator is enumerating splits.-
Methods inherited from interface org.apache.flink.connector.file.src.enumerate.FileEnumerator
enumerateSplits
-
-
-
-
Method Detail
-
setDynamicFilteringData
void setDynamicFilteringData(DynamicFilteringData data)
Provides aDynamicFilteringData
for filtering while the enumerator is enumerating splits.The
DynamicFilteringData
is typically collected by a collector operator, and transferred here by a coordinating event. The method should never be called directly by users.
-
-