Interface DynamicFileEnumerator
-
- All Superinterfaces:
FileEnumerator
@PublicEvolving public interface DynamicFileEnumerator extends FileEnumerator
FileEnumeratorthat 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 interfaceDynamicFileEnumerator.ProviderFactory for theDynamicFileEnumerator.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidsetDynamicFilteringData(org.apache.flink.table.connector.source.DynamicFilteringData data)Provides aDynamicFilteringDatafor 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(org.apache.flink.table.connector.source.DynamicFilteringData data)
Provides aDynamicFilteringDatafor filtering while the enumerator is enumerating splits.The
DynamicFilteringDatais typically collected by a collector operator, and transferred here by a coordinating event. The method should never be called directly by users.
-
-