Package io.confluent.flink.plugin
package io.confluent.flink.plugin
-
ClassDescriptionException thrown when an action (e.g., stop or delete) completes.Authentication mode for the Confluent Cloud.General exception for errors originating from the Confluent Flink plugin.Entry point of the ML Function Expression DSL for Confluent Flink ML functions.List of client-specific options.Entrypoint for Confluent-specific
EnvironmentSettings.Builder pattern for a fluent definition of Confluent-specificEnvironmentSettings.ATableDescriptorfor creating tables located in Confluent Cloud programmatically.Builder forConfluentTableDescriptor.Various tools that help developing and testing Table API programs on Confluent Cloud.An OAuth bearer token returned by anOAuthTokenProvider.Supplies OAuth bearer tokens to the plugin on demand.Behavior when updating a statement fails.Lifecycle actions for CI/CD integration.A handle to manage a Flink SQL statement on Confluent Cloud.Represents a non-fatal issue encountered during statement processing.Warning severity levels.