Confluent v1.46.0, May 10 24

Confluent v1.46.0 published on Friday, May 10, 2024 by Pulumi

confluentcloud.FlinkStatement

Explore with Pulumi AI

Confluent v1.46.0 published on Friday, May 10, 2024 by Pulumi

pulumi/pulumi-confluentcloud

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 Flink Compute Pool, for example, lfcp-abc123.

Id string: The ID of the Flink Compute Pool, for example, lfcp-abc123.

id String: The ID of the Flink Compute Pool, for example, lfcp-abc123.

id string: The ID of the Flink Compute Pool, for example, lfcp-abc123.

id str: The ID of the Flink Compute Pool, for example, lfcp-abc123.

id String: The ID of the Flink Compute Pool, for example, lfcp-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 Environment, for example, env-abc123.

Id string: The ID of the Environment, for example, env-abc123.

id String: The ID of the Environment, for example, env-abc123.

id string: The ID of the Environment, for example, env-abc123.

id str: The ID of the Environment, for example, env-abc123.

id String: The ID of the Environment, for example, env-abc123.

FlinkStatementOrganization, FlinkStatementOrganizationArgs

Id string: The ID of the Organization, for example, 1111aaaa-11aa-11aa-11aa-111111aaaaaa.

Id string: The ID of the Organization, for example, 1111aaaa-11aa-11aa-11aa-111111aaaaaa.

id String: The ID of the Organization, for example, 1111aaaa-11aa-11aa-11aa-111111aaaaaa.

id string: The ID of the Organization, for example, 1111aaaa-11aa-11aa-11aa-111111aaaaaa.

id str: The ID of the Organization, for example, 1111aaaa-11aa-11aa-11aa-111111aaaaaa.

id String: The ID of the Organization, for example, 1111aaaa-11aa-11aa-11aa-111111aaaaaa.

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.

Confluent v1.46.0 published on Friday, May 10, 2024 by Pulumi

pulumi/pulumi-confluentcloud

confluentcloud.FlinkStatement

On this page

On this page

Import

Create FlinkStatement Resource

Constructor syntax

Parameters

Example

FlinkStatement Resource Properties

Inputs

Outputs

Look up Existing FlinkStatement Resource

Supporting Types

FlinkStatementComputePool, FlinkStatementComputePoolArgs

FlinkStatementCredentials, FlinkStatementCredentialsArgs

FlinkStatementEnvironment, FlinkStatementEnvironmentArgs

FlinkStatementOrganization, FlinkStatementOrganizationArgs

FlinkStatementPrincipal, FlinkStatementPrincipalArgs

Package Details

On this page

On this page