Interface SupportsConcurrentExecutionAttempts


  • @PublicEvolving
    public interface SupportsConcurrentExecutionAttempts
    The interface indicates that it supports multiple attempts executing at the same time.

    Currently, the interface is used for speculative execution. If a sink implementation (SinkV2, OutputFormat or SinkFunction) inherits this interface, the sink operator would be considered to support speculative execution.