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 given DynamicFilteringData, while enumerates all splits if no DynamicFilteringData is provided when #enumerateSplits is called.
    • Method Detail

      • setDynamicFilteringData

        void setDynamicFilteringData​(DynamicFilteringData data)
        Provides a DynamicFilteringData 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.