import * as pulumi from "@pulumi/pulumi"; import * as inputs from "./types/input"; import * as outputs from "./types/output"; /** * Creates and manages the deployment of an Aiven for Apache Flink® application. If this resource is missing (for example, after a service power off), it's removed from the state and a new create plan is generated. * * ## Example Usage * * ```typescript * import * as pulumi from "@pulumi/pulumi"; * import * as aiven from "@pulumi/aiven"; * * const exampleApp = new aiven.FlinkApplication("example_app", { * project: exampleProject.project, * serviceName: "example-flink-service", * name: "example-app", * }); * const main = new aiven.FlinkApplicationVersion("main", { * sinks: [{ * createTable: ` CREATE TABLE kafka_known_pizza ( * shop STRING, * name STRING * ) WITH ( * 'connector' = 'kafka', * 'properties.bootstrap.servers' = '', * 'scan.startup.mode' = 'earliest-offset', * 'topic' = 'sink_topic', * 'value.format' = 'json' * ) * `, * integrationId: flinkToKafka.integrationId, * }], * sources: [{ * createTable: ` CREATE TABLE kafka_pizza ( * shop STRING, * name STRING * ) WITH ( * 'connector' = 'kafka', * 'properties.bootstrap.servers' = '', * 'scan.startup.mode' = 'earliest-offset', * 'topic' = 'source_topic', * 'value.format' = 'json' * ) * `, * integrationId: flinkToKafka.integrationId, * }], * project: exampleProject.project, * serviceName: exampleFlink.serviceName, * applicationId: exampleApp.applicationId, * statement: " INSERT INTO kafka_known_pizza SELECT * FROM kafka_pizza WHERE shop LIKE '%Luigis Pizza%'\n", * }); * const mainFlinkApplicationDeployment = new aiven.FlinkApplicationDeployment("main", { * project: exampleProject.project, * serviceName: exampleFlink.serviceName, * applicationId: exampleApp.applicationId, * versionId: main.applicationVersionId, * }); * ``` * * ## Import * * ```sh * $ pulumi import aiven:index/flinkApplicationDeployment:FlinkApplicationDeployment example PROJECT/SERVICE_NAME/APPLICATION_ID/DEPLOYMENT_ID * ``` */ export declare class FlinkApplicationDeployment extends pulumi.CustomResource { /** * Get an existing FlinkApplicationDeployment resource's state with the given name, ID, and optional extra * properties used to qualify the lookup. * * @param name The _unique_ name of the resulting resource. * @param id The _unique_ provider ID of the resource to lookup. * @param state Any extra arguments used during the lookup. * @param opts Optional settings to control the behavior of the CustomResource. */ static get(name: string, id: pulumi.Input, state?: FlinkApplicationDeploymentState, opts?: pulumi.CustomResourceOptions): FlinkApplicationDeployment; /** * Returns true if the given object is an instance of FlinkApplicationDeployment. This is designed to work even * when multiple copies of the Pulumi SDK have been loaded into the same process. */ static isInstance(obj: any): obj is FlinkApplicationDeployment; /** * Application Id. Changing this property forces recreation of the resource. */ readonly applicationId: pulumi.Output; /** * The creation timestamp of this entity in ISO 8601 format, always in UTC. */ readonly createdAt: pulumi.Output; /** * The creator of this entity. */ readonly createdBy: pulumi.Output; /** * Deployment ID. */ readonly deploymentId: pulumi.Output; /** * Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x number*of*task_slots), or every new job created will fail. Value must be between `1` and `128`. The default value is `1`. Changing this property forces recreation of the resource. */ readonly parallelism: pulumi.Output; /** * Project name. Changing this property forces recreation of the resource. */ readonly project: pulumi.Output; /** * Specifies whether a Flink Job is restarted in case it fails. The default value is `true`. Changing this property forces recreation of the resource. */ readonly restartEnabled: pulumi.Output; /** * Service name. Changing this property forces recreation of the resource. */ readonly serviceName: pulumi.Output; /** * Job savepoint. Length must be between `1` and `2048`. Changing this property forces recreation of the resource. */ readonly startingSavepoint: pulumi.Output; readonly timeouts: pulumi.Output; /** * ApplicationVersion ID. Length must be exactly `36`. Changing this property forces recreation of the resource. */ readonly versionId: pulumi.Output; /** * Create a FlinkApplicationDeployment resource with the given unique name, arguments, and options. * * @param name The _unique_ name of the resource. * @param args The arguments to use to populate this resource's properties. * @param opts A bag of options that control this resource's behavior. */ constructor(name: string, args: FlinkApplicationDeploymentArgs, opts?: pulumi.CustomResourceOptions); } /** * Input properties used for looking up and filtering FlinkApplicationDeployment resources. */ export interface FlinkApplicationDeploymentState { /** * Application Id. Changing this property forces recreation of the resource. */ applicationId?: pulumi.Input; /** * The creation timestamp of this entity in ISO 8601 format, always in UTC. */ createdAt?: pulumi.Input; /** * The creator of this entity. */ createdBy?: pulumi.Input; /** * Deployment ID. */ deploymentId?: pulumi.Input; /** * Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x number*of*task_slots), or every new job created will fail. Value must be between `1` and `128`. The default value is `1`. Changing this property forces recreation of the resource. */ parallelism?: pulumi.Input; /** * Project name. Changing this property forces recreation of the resource. */ project?: pulumi.Input; /** * Specifies whether a Flink Job is restarted in case it fails. The default value is `true`. Changing this property forces recreation of the resource. */ restartEnabled?: pulumi.Input; /** * Service name. Changing this property forces recreation of the resource. */ serviceName?: pulumi.Input; /** * Job savepoint. Length must be between `1` and `2048`. Changing this property forces recreation of the resource. */ startingSavepoint?: pulumi.Input; timeouts?: pulumi.Input; /** * ApplicationVersion ID. Length must be exactly `36`. Changing this property forces recreation of the resource. */ versionId?: pulumi.Input; } /** * The set of arguments for constructing a FlinkApplicationDeployment resource. */ export interface FlinkApplicationDeploymentArgs { /** * Application Id. Changing this property forces recreation of the resource. */ applicationId: pulumi.Input; /** * Reading of Flink parallel execution documentation is recommended before setting this value to other than 1. Please do not set this value higher than (total number of nodes x number*of*task_slots), or every new job created will fail. Value must be between `1` and `128`. The default value is `1`. Changing this property forces recreation of the resource. */ parallelism?: pulumi.Input; /** * Project name. Changing this property forces recreation of the resource. */ project: pulumi.Input; /** * Specifies whether a Flink Job is restarted in case it fails. The default value is `true`. Changing this property forces recreation of the resource. */ restartEnabled?: pulumi.Input; /** * Service name. Changing this property forces recreation of the resource. */ serviceName: pulumi.Input; /** * Job savepoint. Length must be between `1` and `2048`. Changing this property forces recreation of the resource. */ startingSavepoint?: pulumi.Input; timeouts?: pulumi.Input; /** * ApplicationVersion ID. Length must be exactly `36`. Changing this property forces recreation of the resource. */ versionId: pulumi.Input; } //# sourceMappingURL=flinkApplicationDeployment.d.ts.map