Interface AiModelClient

  • All Superinterfaces:
    AutoCloseable, Serializable
    All Known Implementing Classes:
    DummyModelClient, OpenAiCompatibleModelClient

    @Experimental
    public interface AiModelClient
    extends Serializable, AutoCloseable
    Marker interface for a runtime AI model client. Concrete capabilities are declared via ability interfaces in org.apache.flink.cdc.common.model.abilities.

    Implementations must be Serializable so that they can be distributed across Flink task managers together with the operator that holds them.

    When transform.async-execution.enabled is enabled, the same client instance may be invoked concurrently. Implementations used in asynchronous transforms must therefore be thread-safe.