org.apache.flink.api.common

Interface SupportsConcurrentExecutionAttempts

All Known Implementing Classes:

DiscardingSink, FileSink, FileSystemOutputFormat, PrintSink, PrintSinkFunction

@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.