Package org.apache.flink.api.connector.source

Interface SupportsSplitReassignmentOnRecovery

@PublicEvolving
public interface SupportsSplitReassignmentOnRecovery

A decorative interface for Source. Implementing this interface indicates that the source operator needs to report splits to the enumerator on start up and receive reassignment on recovery.