1. Packages
  2. Confluent Cloud
  3. API Docs
  4. FlinkStatement
Confluent v1.42.0 published on Friday, Apr 19, 2024 by Pulumi

confluentcloud.FlinkStatement

Explore with Pulumi AI

confluentcloud logo
Confluent v1.42.0 published on Friday, Apr 19, 2024 by Pulumi

    Import

    You can import a Flink statement by using the Flink Statement name, for example:

    Option #1: Manage multiple Flink Compute Pools in the same Terraform workspace

    $ export IMPORT_CONFLUENT_ORGANIZATION_ID="<organization_id>"

    $ export IMPORT_CONFLUENT_ENVIRONMENT_ID="<environment_id>"

    $ export IMPORT_FLINK_COMPUTE_POOL_ID="<flink_compute_pool_id>"

    $ export IMPORT_FLINK_API_KEY="<flink_api_key>"

    $ export IMPORT_FLINK_API_SECRET="<flink_api_secret>"

    $ export IMPORT_FLINK_REST_ENDPOINT="<flink_rest_endpoint>"

    $ export IMPORT_FLINK_PRINCIPAL_ID="<flink_rest_endpoint>"

    $ pulumi import confluentcloud:index/flinkStatement:FlinkStatement example cfeab4fe-b62c-49bd-9e99-51cc98c77a67
    

    Option #2: Manage a single Flink Compute Pool in the same Terraform workspace

    $ pulumi import confluentcloud:index/flinkStatement:FlinkStatement example cfeab4fe-b62c-49bd-9e99-51cc98c77a67
    

    !> Warning: Do not forget to delete terminal command history afterwards for security purposes.

    Create FlinkStatement Resource

    Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.

    Constructor syntax

    new FlinkStatement(name: string, args: FlinkStatementArgs, opts?: CustomResourceOptions);
    @overload
    def FlinkStatement(resource_name: str,
                       args: FlinkStatementArgs,
                       opts: Optional[ResourceOptions] = None)
    
    @overload
    def FlinkStatement(resource_name: str,
                       opts: Optional[ResourceOptions] = None,
                       statement: Optional[str] = None,
                       compute_pool: Optional[FlinkStatementComputePoolArgs] = None,
                       credentials: Optional[FlinkStatementCredentialsArgs] = None,
                       environment: Optional[FlinkStatementEnvironmentArgs] = None,
                       organization: Optional[FlinkStatementOrganizationArgs] = None,
                       principal: Optional[FlinkStatementPrincipalArgs] = None,
                       properties: Optional[Mapping[str, str]] = None,
                       rest_endpoint: Optional[str] = None,
                       statement_name: Optional[str] = None,
                       stopped: Optional[bool] = None)
    func NewFlinkStatement(ctx *Context, name string, args FlinkStatementArgs, opts ...ResourceOption) (*FlinkStatement, error)
    public FlinkStatement(string name, FlinkStatementArgs args, CustomResourceOptions? opts = null)
    public FlinkStatement(String name, FlinkStatementArgs args)
    public FlinkStatement(String name, FlinkStatementArgs args, CustomResourceOptions options)
    
    type: confluentcloud:FlinkStatement
    properties: # The arguments to resource properties.
    options: # Bag of options to control resource's behavior.
    
    

    Parameters

    name string
    The unique name of the resource.
    args FlinkStatementArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    resource_name str
    The unique name of the resource.
    args FlinkStatementArgs
    The arguments to resource properties.
    opts ResourceOptions
    Bag of options to control resource's behavior.
    ctx Context
    Context object for the current deployment.
    name string
    The unique name of the resource.
    args FlinkStatementArgs
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args FlinkStatementArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args FlinkStatementArgs
    The arguments to resource properties.
    options CustomResourceOptions
    Bag of options to control resource's behavior.

    Example

    The following reference example uses placeholder values for all input properties.

    var flinkStatementResource = new ConfluentCloud.FlinkStatement("flinkStatementResource", new()
    {
        Statement = "string",
        ComputePool = new ConfluentCloud.Inputs.FlinkStatementComputePoolArgs
        {
            Id = "string",
        },
        Credentials = new ConfluentCloud.Inputs.FlinkStatementCredentialsArgs
        {
            Key = "string",
            Secret = "string",
        },
        Environment = new ConfluentCloud.Inputs.FlinkStatementEnvironmentArgs
        {
            Id = "string",
        },
        Organization = new ConfluentCloud.Inputs.FlinkStatementOrganizationArgs
        {
            Id = "string",
        },
        Principal = new ConfluentCloud.Inputs.FlinkStatementPrincipalArgs
        {
            Id = "string",
        },
        Properties = 
        {
            { "string", "string" },
        },
        RestEndpoint = "string",
        StatementName = "string",
        Stopped = false,
    });
    
    example, err := confluentcloud.NewFlinkStatement(ctx, "flinkStatementResource", &confluentcloud.FlinkStatementArgs{
    	Statement: pulumi.String("string"),
    	ComputePool: &confluentcloud.FlinkStatementComputePoolArgs{
    		Id: pulumi.String("string"),
    	},
    	Credentials: &confluentcloud.FlinkStatementCredentialsArgs{
    		Key:    pulumi.String("string"),
    		Secret: pulumi.String("string"),
    	},
    	Environment: &confluentcloud.FlinkStatementEnvironmentArgs{
    		Id: pulumi.String("string"),
    	},
    	Organization: &confluentcloud.FlinkStatementOrganizationArgs{
    		Id: pulumi.String("string"),
    	},
    	Principal: &confluentcloud.FlinkStatementPrincipalArgs{
    		Id: pulumi.String("string"),
    	},
    	Properties: pulumi.StringMap{
    		"string": pulumi.String("string"),
    	},
    	RestEndpoint:  pulumi.String("string"),
    	StatementName: pulumi.String("string"),
    	Stopped:       pulumi.Bool(false),
    })
    
    var flinkStatementResource = new FlinkStatement("flinkStatementResource", FlinkStatementArgs.builder()        
        .statement("string")
        .computePool(FlinkStatementComputePoolArgs.builder()
            .id("string")
            .build())
        .credentials(FlinkStatementCredentialsArgs.builder()
            .key("string")
            .secret("string")
            .build())
        .environment(FlinkStatementEnvironmentArgs.builder()
            .id("string")
            .build())
        .organization(FlinkStatementOrganizationArgs.builder()
            .id("string")
            .build())
        .principal(FlinkStatementPrincipalArgs.builder()
            .id("string")
            .build())
        .properties(Map.of("string", "string"))
        .restEndpoint("string")
        .statementName("string")
        .stopped(false)
        .build());
    
    flink_statement_resource = confluentcloud.FlinkStatement("flinkStatementResource",
        statement="string",
        compute_pool=confluentcloud.FlinkStatementComputePoolArgs(
            id="string",
        ),
        credentials=confluentcloud.FlinkStatementCredentialsArgs(
            key="string",
            secret="string",
        ),
        environment=confluentcloud.FlinkStatementEnvironmentArgs(
            id="string",
        ),
        organization=confluentcloud.FlinkStatementOrganizationArgs(
            id="string",
        ),
        principal=confluentcloud.FlinkStatementPrincipalArgs(
            id="string",
        ),
        properties={
            "string": "string",
        },
        rest_endpoint="string",
        statement_name="string",
        stopped=False)
    
    const flinkStatementResource = new confluentcloud.FlinkStatement("flinkStatementResource", {
        statement: "string",
        computePool: {
            id: "string",
        },
        credentials: {
            key: "string",
            secret: "string",
        },
        environment: {
            id: "string",
        },
        organization: {
            id: "string",
        },
        principal: {
            id: "string",
        },
        properties: {
            string: "string",
        },
        restEndpoint: "string",
        statementName: "string",
        stopped: false,
    });
    
    type: confluentcloud:FlinkStatement
    properties:
        computePool:
            id: string
        credentials:
            key: string
            secret: string
        environment:
            id: string
        organization:
            id: string
        principal:
            id: string
        properties:
            string: string
        restEndpoint: string
        statement: string
        statementName: string
        stopped: false
    

    FlinkStatement Resource Properties

    To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.

    Inputs

    The FlinkStatement resource accepts the following input properties:

    Statement string
    The raw SQL text statement, for example, SELECT CURRENT_TIMESTAMP;.
    ComputePool Pulumi.ConfluentCloud.Inputs.FlinkStatementComputePool
    Credentials Pulumi.ConfluentCloud.Inputs.FlinkStatementCredentials
    The Cluster API Credentials.
    Environment Pulumi.ConfluentCloud.Inputs.FlinkStatementEnvironment
    Organization Pulumi.ConfluentCloud.Inputs.FlinkStatementOrganization
    Principal Pulumi.ConfluentCloud.Inputs.FlinkStatementPrincipal
    Properties Dictionary<string, string>
    The custom topic settings to set:
    RestEndpoint string
    The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud).
    StatementName string
    The ID of the Flink Statement, for example, cfeab4fe-b62c-49bd-9e99-51cc98c77a67.
    Stopped bool
    Indicates whether the statement should be stopped.
    Statement string
    The raw SQL text statement, for example, SELECT CURRENT_TIMESTAMP;.
    ComputePool FlinkStatementComputePoolArgs
    Credentials FlinkStatementCredentialsArgs
    The Cluster API Credentials.
    Environment FlinkStatementEnvironmentArgs
    Organization FlinkStatementOrganizationArgs
    Principal FlinkStatementPrincipalArgs
    Properties map[string]string
    The custom topic settings to set:
    RestEndpoint string
    The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud).
    StatementName string
    The ID of the Flink Statement, for example, cfeab4fe-b62c-49bd-9e99-51cc98c77a67.
    Stopped bool
    Indicates whether the statement should be stopped.
    statement String
    The raw SQL text statement, for example, SELECT CURRENT_TIMESTAMP;.
    computePool FlinkStatementComputePool
    credentials FlinkStatementCredentials
    The Cluster API Credentials.
    environment FlinkStatementEnvironment
    organization FlinkStatementOrganization
    principal FlinkStatementPrincipal
    properties Map<String,String>
    The custom topic settings to set:
    restEndpoint String
    The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud).
    statementName String
    The ID of the Flink Statement, for example, cfeab4fe-b62c-49bd-9e99-51cc98c77a67.
    stopped Boolean
    Indicates whether the statement should be stopped.
    statement string
    The raw SQL text statement, for example, SELECT CURRENT_TIMESTAMP;.
    computePool FlinkStatementComputePool
    credentials FlinkStatementCredentials
    The Cluster API Credentials.
    environment FlinkStatementEnvironment
    organization FlinkStatementOrganization
    principal FlinkStatementPrincipal
    properties {[key: string]: string}
    The custom topic settings to set:
    restEndpoint string
    The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud).
    statementName string
    The ID of the Flink Statement, for example, cfeab4fe-b62c-49bd-9e99-51cc98c77a67.
    stopped boolean
    Indicates whether the statement should be stopped.
    statement str
    The raw SQL text statement, for example, SELECT CURRENT_TIMESTAMP;.
    compute_pool FlinkStatementComputePoolArgs
    credentials FlinkStatementCredentialsArgs
    The Cluster API Credentials.
    environment FlinkStatementEnvironmentArgs
    organization FlinkStatementOrganizationArgs
    principal FlinkStatementPrincipalArgs
    properties Mapping[str, str]
    The custom topic settings to set:
    rest_endpoint str
    The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud).
    statement_name str
    The ID of the Flink Statement, for example, cfeab4fe-b62c-49bd-9e99-51cc98c77a67.
    stopped bool
    Indicates whether the statement should be stopped.
    statement String
    The raw SQL text statement, for example, SELECT CURRENT_TIMESTAMP;.
    computePool Property Map
    credentials Property Map
    The Cluster API Credentials.
    environment Property Map
    organization Property Map
    principal Property Map
    properties Map<String>
    The custom topic settings to set:
    restEndpoint String
    The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud).
    statementName String
    The ID of the Flink Statement, for example, cfeab4fe-b62c-49bd-9e99-51cc98c77a67.
    stopped Boolean
    Indicates whether the statement should be stopped.

    Outputs

    All input properties are implicitly available as output properties. Additionally, the FlinkStatement resource produces the following output properties:

    Id string
    The provider-assigned unique ID for this managed resource.
    Id string
    The provider-assigned unique ID for this managed resource.
    id String
    The provider-assigned unique ID for this managed resource.
    id string
    The provider-assigned unique ID for this managed resource.
    id str
    The provider-assigned unique ID for this managed resource.
    id String
    The provider-assigned unique ID for this managed resource.

    Look up Existing FlinkStatement Resource

    Get an existing FlinkStatement resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

    public static get(name: string, id: Input<ID>, state?: FlinkStatementState, opts?: CustomResourceOptions): FlinkStatement
    @staticmethod
    def get(resource_name: str,
            id: str,
            opts: Optional[ResourceOptions] = None,
            compute_pool: Optional[FlinkStatementComputePoolArgs] = None,
            credentials: Optional[FlinkStatementCredentialsArgs] = None,
            environment: Optional[FlinkStatementEnvironmentArgs] = None,
            organization: Optional[FlinkStatementOrganizationArgs] = None,
            principal: Optional[FlinkStatementPrincipalArgs] = None,
            properties: Optional[Mapping[str, str]] = None,
            rest_endpoint: Optional[str] = None,
            statement: Optional[str] = None,
            statement_name: Optional[str] = None,
            stopped: Optional[bool] = None) -> FlinkStatement
    func GetFlinkStatement(ctx *Context, name string, id IDInput, state *FlinkStatementState, opts ...ResourceOption) (*FlinkStatement, error)
    public static FlinkStatement Get(string name, Input<string> id, FlinkStatementState? state, CustomResourceOptions? opts = null)
    public static FlinkStatement get(String name, Output<String> id, FlinkStatementState state, CustomResourceOptions options)
    Resource lookup is not supported in YAML
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    resource_name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    name
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    state
    Any extra arguments used during the lookup.
    opts
    A bag of options that control this resource's behavior.
    The following state arguments are supported:
    ComputePool Pulumi.ConfluentCloud.Inputs.FlinkStatementComputePool
    Credentials Pulumi.ConfluentCloud.Inputs.FlinkStatementCredentials
    The Cluster API Credentials.
    Environment Pulumi.ConfluentCloud.Inputs.FlinkStatementEnvironment
    Organization Pulumi.ConfluentCloud.Inputs.FlinkStatementOrganization
    Principal Pulumi.ConfluentCloud.Inputs.FlinkStatementPrincipal
    Properties Dictionary<string, string>
    The custom topic settings to set:
    RestEndpoint string
    The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud).
    Statement string
    The raw SQL text statement, for example, SELECT CURRENT_TIMESTAMP;.
    StatementName string
    The ID of the Flink Statement, for example, cfeab4fe-b62c-49bd-9e99-51cc98c77a67.
    Stopped bool
    Indicates whether the statement should be stopped.
    ComputePool FlinkStatementComputePoolArgs
    Credentials FlinkStatementCredentialsArgs
    The Cluster API Credentials.
    Environment FlinkStatementEnvironmentArgs
    Organization FlinkStatementOrganizationArgs
    Principal FlinkStatementPrincipalArgs
    Properties map[string]string
    The custom topic settings to set:
    RestEndpoint string
    The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud).
    Statement string
    The raw SQL text statement, for example, SELECT CURRENT_TIMESTAMP;.
    StatementName string
    The ID of the Flink Statement, for example, cfeab4fe-b62c-49bd-9e99-51cc98c77a67.
    Stopped bool
    Indicates whether the statement should be stopped.
    computePool FlinkStatementComputePool
    credentials FlinkStatementCredentials
    The Cluster API Credentials.
    environment FlinkStatementEnvironment
    organization FlinkStatementOrganization
    principal FlinkStatementPrincipal
    properties Map<String,String>
    The custom topic settings to set:
    restEndpoint String
    The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud).
    statement String
    The raw SQL text statement, for example, SELECT CURRENT_TIMESTAMP;.
    statementName String
    The ID of the Flink Statement, for example, cfeab4fe-b62c-49bd-9e99-51cc98c77a67.
    stopped Boolean
    Indicates whether the statement should be stopped.
    computePool FlinkStatementComputePool
    credentials FlinkStatementCredentials
    The Cluster API Credentials.
    environment FlinkStatementEnvironment
    organization FlinkStatementOrganization
    principal FlinkStatementPrincipal
    properties {[key: string]: string}
    The custom topic settings to set:
    restEndpoint string
    The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud).
    statement string
    The raw SQL text statement, for example, SELECT CURRENT_TIMESTAMP;.
    statementName string
    The ID of the Flink Statement, for example, cfeab4fe-b62c-49bd-9e99-51cc98c77a67.
    stopped boolean
    Indicates whether the statement should be stopped.
    compute_pool FlinkStatementComputePoolArgs
    credentials FlinkStatementCredentialsArgs
    The Cluster API Credentials.
    environment FlinkStatementEnvironmentArgs
    organization FlinkStatementOrganizationArgs
    principal FlinkStatementPrincipalArgs
    properties Mapping[str, str]
    The custom topic settings to set:
    rest_endpoint str
    The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud).
    statement str
    The raw SQL text statement, for example, SELECT CURRENT_TIMESTAMP;.
    statement_name str
    The ID of the Flink Statement, for example, cfeab4fe-b62c-49bd-9e99-51cc98c77a67.
    stopped bool
    Indicates whether the statement should be stopped.
    computePool Property Map
    credentials Property Map
    The Cluster API Credentials.
    environment Property Map
    organization Property Map
    principal Property Map
    properties Map<String>
    The custom topic settings to set:
    restEndpoint String
    The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud).
    statement String
    The raw SQL text statement, for example, SELECT CURRENT_TIMESTAMP;.
    statementName String
    The ID of the Flink Statement, for example, cfeab4fe-b62c-49bd-9e99-51cc98c77a67.
    stopped Boolean
    Indicates whether the statement should be stopped.

    Supporting Types

    FlinkStatementComputePool, FlinkStatementComputePoolArgs

    Id string
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    Id string
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    id String
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    id string
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    id str
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    id String
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.

    FlinkStatementCredentials, FlinkStatementCredentialsArgs

    Key string
    The Flink API Key.
    Secret string

    The Flink API Secret.

    Note: A Flink API key consists of a key and a secret. Flink API keys are required to interact with Flink Statements in Confluent Cloud. Each Flink API key is valid for one specific Flink Region.

    Note: Use Option #2 to simplify the key rotation process. When using Option #1, to rotate a Flink API key, create a new Flink API key, update the credentials block in all configuration files to use the new Flink API key, run pulumi up -target="confluent_flink_statement.example", and remove the old Flink API key. Alternatively, in case the old Flink API Key was deleted already, you might need to run pulumi preview -refresh=false -target="confluent_flink_statement.example" -out=rotate-flink-api-key and pulumi up rotate-flink-api-key instead.

    Key string
    The Flink API Key.
    Secret string

    The Flink API Secret.

    Note: A Flink API key consists of a key and a secret. Flink API keys are required to interact with Flink Statements in Confluent Cloud. Each Flink API key is valid for one specific Flink Region.

    Note: Use Option #2 to simplify the key rotation process. When using Option #1, to rotate a Flink API key, create a new Flink API key, update the credentials block in all configuration files to use the new Flink API key, run pulumi up -target="confluent_flink_statement.example", and remove the old Flink API key. Alternatively, in case the old Flink API Key was deleted already, you might need to run pulumi preview -refresh=false -target="confluent_flink_statement.example" -out=rotate-flink-api-key and pulumi up rotate-flink-api-key instead.

    key String
    The Flink API Key.
    secret String

    The Flink API Secret.

    Note: A Flink API key consists of a key and a secret. Flink API keys are required to interact with Flink Statements in Confluent Cloud. Each Flink API key is valid for one specific Flink Region.

    Note: Use Option #2 to simplify the key rotation process. When using Option #1, to rotate a Flink API key, create a new Flink API key, update the credentials block in all configuration files to use the new Flink API key, run pulumi up -target="confluent_flink_statement.example", and remove the old Flink API key. Alternatively, in case the old Flink API Key was deleted already, you might need to run pulumi preview -refresh=false -target="confluent_flink_statement.example" -out=rotate-flink-api-key and pulumi up rotate-flink-api-key instead.

    key string
    The Flink API Key.
    secret string

    The Flink API Secret.

    Note: A Flink API key consists of a key and a secret. Flink API keys are required to interact with Flink Statements in Confluent Cloud. Each Flink API key is valid for one specific Flink Region.

    Note: Use Option #2 to simplify the key rotation process. When using Option #1, to rotate a Flink API key, create a new Flink API key, update the credentials block in all configuration files to use the new Flink API key, run pulumi up -target="confluent_flink_statement.example", and remove the old Flink API key. Alternatively, in case the old Flink API Key was deleted already, you might need to run pulumi preview -refresh=false -target="confluent_flink_statement.example" -out=rotate-flink-api-key and pulumi up rotate-flink-api-key instead.

    key str
    The Flink API Key.
    secret str

    The Flink API Secret.

    Note: A Flink API key consists of a key and a secret. Flink API keys are required to interact with Flink Statements in Confluent Cloud. Each Flink API key is valid for one specific Flink Region.

    Note: Use Option #2 to simplify the key rotation process. When using Option #1, to rotate a Flink API key, create a new Flink API key, update the credentials block in all configuration files to use the new Flink API key, run pulumi up -target="confluent_flink_statement.example", and remove the old Flink API key. Alternatively, in case the old Flink API Key was deleted already, you might need to run pulumi preview -refresh=false -target="confluent_flink_statement.example" -out=rotate-flink-api-key and pulumi up rotate-flink-api-key instead.

    key String
    The Flink API Key.
    secret String

    The Flink API Secret.

    Note: A Flink API key consists of a key and a secret. Flink API keys are required to interact with Flink Statements in Confluent Cloud. Each Flink API key is valid for one specific Flink Region.

    Note: Use Option #2 to simplify the key rotation process. When using Option #1, to rotate a Flink API key, create a new Flink API key, update the credentials block in all configuration files to use the new Flink API key, run pulumi up -target="confluent_flink_statement.example", and remove the old Flink API key. Alternatively, in case the old Flink API Key was deleted already, you might need to run pulumi preview -refresh=false -target="confluent_flink_statement.example" -out=rotate-flink-api-key and pulumi up rotate-flink-api-key instead.

    FlinkStatementEnvironment, FlinkStatementEnvironmentArgs

    Id string
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    Id string
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    id String
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    id string
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    id str
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    id String
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.

    FlinkStatementOrganization, FlinkStatementOrganizationArgs

    Id string
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    Id string
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    id String
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    id string
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    id str
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    id String
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.

    FlinkStatementPrincipal, FlinkStatementPrincipalArgs

    Id string
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    Id string
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    id String
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    id string
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    id str
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.
    id String
    The ID of the Principal the Flink Statement runs as, for example, sa-abc123.

    Package Details

    Repository
    Confluent Cloud pulumi/pulumi-confluentcloud
    License
    Apache-2.0
    Notes
    This Pulumi package is based on the confluent Terraform Provider.
    confluentcloud logo
    Confluent v1.42.0 published on Friday, Apr 19, 2024 by Pulumi