confluentcloud.getFlinkMaterializedTable

Confluent v2.69.0, May 15 26

Viewing docs for Confluent v2.69.0
published on Friday, May 15, 2026 by Pulumi

Schema (JSON)

pulumi/pulumi-confluentcloud

Viewing docs for Confluent v2.69.0
published on Friday, May 15, 2026 by Pulumi

Schema (JSON)

pulumi/pulumi-confluentcloud

Example Usage

Option #1: Manage multiple Flink Materialized Tables in the same Pulumi Stack

import * as pulumi from "@pulumi/pulumi";
import * as confluentcloud from "@pulumi/confluentcloud";

const example = confluentcloud.getFlinkMaterializedTable({
    organization: {
        id: main.id,
    },
    environment: {
        id: staging.id,
    },
    computePool: {
        id: exampleConfluentFlinkComputePool.id,
    },
    restEndpoint: mainConfluentFlinkRegion.restEndpoint,
    credentials: {
        key: flink.id,
        secret: flink.secret,
    },
    displayName: "my_materialized_table",
});
export const materializedTableOutput = example;

import pulumi
import pulumi_confluentcloud as confluentcloud

example = confluentcloud.get_flink_materialized_table(organization={
        "id": main["id"],
    },
    environment={
        "id": staging["id"],
    },
    compute_pool={
        "id": example_confluent_flink_compute_pool["id"],
    },
    rest_endpoint=main_confluent_flink_region["restEndpoint"],
    credentials={
        "key": flink["id"],
        "secret": flink["secret"],
    },
    display_name="my_materialized_table")
pulumi.export("materializedTableOutput", example)

package main

import (
	"github.com/pulumi/pulumi-confluentcloud/sdk/v2/go/confluentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		example, err := confluentcloud.GetFlinkMaterializedTable(ctx, &confluentcloud.LookupFlinkMaterializedTableArgs{
			Organization: confluentcloud.GetFlinkMaterializedTableOrganization{
				Id: main.Id,
			},
			Environment: confluentcloud.GetFlinkMaterializedTableEnvironment{
				Id: staging.Id,
			},
			ComputePool: confluentcloud.GetFlinkMaterializedTableComputePool{
				Id: exampleConfluentFlinkComputePool.Id,
			},
			RestEndpoint: pulumi.StringRef(mainConfluentFlinkRegion.RestEndpoint),
			Credentials: confluentcloud.GetFlinkMaterializedTableCredentials{
				Key:    flink.Id,
				Secret: flink.Secret,
			},
			DisplayName: "my_materialized_table",
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("materializedTableOutput", example)
		return nil
	})
}

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using ConfluentCloud = Pulumi.ConfluentCloud;

return await Deployment.RunAsync(() => 
{
    var example = ConfluentCloud.GetFlinkMaterializedTable.Invoke(new()
    {
        Organization = new ConfluentCloud.Inputs.GetFlinkMaterializedTableOrganizationInputArgs
        {
            Id = main.Id,
        },
        Environment = new ConfluentCloud.Inputs.GetFlinkMaterializedTableEnvironmentInputArgs
        {
            Id = staging.Id,
        },
        ComputePool = new ConfluentCloud.Inputs.GetFlinkMaterializedTableComputePoolInputArgs
        {
            Id = exampleConfluentFlinkComputePool.Id,
        },
        RestEndpoint = mainConfluentFlinkRegion.RestEndpoint,
        Credentials = new ConfluentCloud.Inputs.GetFlinkMaterializedTableCredentialsInputArgs
        {
            Key = flink.Id,
            Secret = flink.Secret,
        },
        DisplayName = "my_materialized_table",
    });

    return new Dictionary<string, object?>
    {
        ["materializedTableOutput"] = example,
    };
});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.confluentcloud.ConfluentcloudFunctions;
import com.pulumi.confluentcloud.inputs.GetFlinkMaterializedTableArgs;
import com.pulumi.confluentcloud.inputs.GetFlinkMaterializedTableOrganizationArgs;
import com.pulumi.confluentcloud.inputs.GetFlinkMaterializedTableEnvironmentArgs;
import com.pulumi.confluentcloud.inputs.GetFlinkMaterializedTableComputePoolArgs;
import com.pulumi.confluentcloud.inputs.GetFlinkMaterializedTableCredentialsArgs;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        final var example = ConfluentcloudFunctions.getFlinkMaterializedTable(GetFlinkMaterializedTableArgs.builder()
            .organization(GetFlinkMaterializedTableOrganizationArgs.builder()
                .id(main.id())
                .build())
            .environment(GetFlinkMaterializedTableEnvironmentArgs.builder()
                .id(staging.id())
                .build())
            .computePool(GetFlinkMaterializedTableComputePoolArgs.builder()
                .id(exampleConfluentFlinkComputePool.id())
                .build())
            .restEndpoint(mainConfluentFlinkRegion.restEndpoint())
            .credentials(GetFlinkMaterializedTableCredentialsArgs.builder()
                .key(flink.id())
                .secret(flink.secret())
                .build())
            .displayName("my_materialized_table")
            .build());

        ctx.export("materializedTableOutput", example);
    }
}

variables:
  example:
    fn::invoke:
      function: confluentcloud:getFlinkMaterializedTable
      arguments:
        organization:
          id: ${main.id}
        environment:
          id: ${staging.id}
        computePool:
          id: ${exampleConfluentFlinkComputePool.id}
        restEndpoint: ${mainConfluentFlinkRegion.restEndpoint}
        credentials:
          key: ${flink.id}
          secret: ${flink.secret}
        displayName: my_materialized_table
outputs:
  materializedTableOutput: ${example}

Example coming soon!

Option #2: Manage a single Flink Materialized Table in the same Pulumi Stack

import * as pulumi from "@pulumi/pulumi";
import * as confluentcloud from "@pulumi/confluentcloud";

const example = confluentcloud.getFlinkMaterializedTable({
    displayName: "my_materialized_table",
});
export const materializedTableOutput = example;

import pulumi
import pulumi_confluentcloud as confluentcloud

example = confluentcloud.get_flink_materialized_table(display_name="my_materialized_table")
pulumi.export("materializedTableOutput", example)

package main

import (
	"github.com/pulumi/pulumi-confluentcloud/sdk/v2/go/confluentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		example, err := confluentcloud.GetFlinkMaterializedTable(ctx, &confluentcloud.LookupFlinkMaterializedTableArgs{
			DisplayName: "my_materialized_table",
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("materializedTableOutput", example)
		return nil
	})
}

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using ConfluentCloud = Pulumi.ConfluentCloud;

return await Deployment.RunAsync(() => 
{
    var example = ConfluentCloud.GetFlinkMaterializedTable.Invoke(new()
    {
        DisplayName = "my_materialized_table",
    });

    return new Dictionary<string, object?>
    {
        ["materializedTableOutput"] = example,
    };
});

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.confluentcloud.ConfluentcloudFunctions;
import com.pulumi.confluentcloud.inputs.GetFlinkMaterializedTableArgs;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        final var example = ConfluentcloudFunctions.getFlinkMaterializedTable(GetFlinkMaterializedTableArgs.builder()
            .displayName("my_materialized_table")
            .build());

        ctx.export("materializedTableOutput", example);
    }
}

variables:
  example:
    fn::invoke:
      function: confluentcloud:getFlinkMaterializedTable
      arguments:
        displayName: my_materialized_table
outputs:
  materializedTableOutput: ${example}

Example coming soon!

Using getFlinkMaterializedTable

Two invocation forms are available. The direct form accepts plain arguments and either blocks until the result value is available, or returns a Promise-wrapped result. The output form accepts Input-wrapped arguments and returns an Output-wrapped result.

function getFlinkMaterializedTable(args: GetFlinkMaterializedTableArgs, opts?: InvokeOptions): Promise<GetFlinkMaterializedTableResult>
function getFlinkMaterializedTableOutput(args: GetFlinkMaterializedTableOutputArgs, opts?: InvokeOptions): Output<GetFlinkMaterializedTableResult>

def get_flink_materialized_table(compute_pool: Optional[GetFlinkMaterializedTableComputePool] = None,
                                 credentials: Optional[GetFlinkMaterializedTableCredentials] = None,
                                 display_name: Optional[str] = None,
                                 environment: Optional[GetFlinkMaterializedTableEnvironment] = None,
                                 organization: Optional[GetFlinkMaterializedTableOrganization] = None,
                                 principal: Optional[GetFlinkMaterializedTablePrincipal] = None,
                                 rest_endpoint: Optional[str] = None,
                                 opts: Optional[InvokeOptions] = None) -> GetFlinkMaterializedTableResult
def get_flink_materialized_table_output(compute_pool: pulumi.Input[Optional[GetFlinkMaterializedTableComputePoolArgs]] = None,
                                 credentials: pulumi.Input[Optional[GetFlinkMaterializedTableCredentialsArgs]] = None,
                                 display_name: pulumi.Input[Optional[str]] = None,
                                 environment: pulumi.Input[Optional[GetFlinkMaterializedTableEnvironmentArgs]] = None,
                                 organization: pulumi.Input[Optional[GetFlinkMaterializedTableOrganizationArgs]] = None,
                                 principal: pulumi.Input[Optional[GetFlinkMaterializedTablePrincipalArgs]] = None,
                                 rest_endpoint: pulumi.Input[Optional[str]] = None,
                                 opts: Optional[InvokeOptions] = None) -> Output[GetFlinkMaterializedTableResult]

func LookupFlinkMaterializedTable(ctx *Context, args *LookupFlinkMaterializedTableArgs, opts ...InvokeOption) (*LookupFlinkMaterializedTableResult, error)
func LookupFlinkMaterializedTableOutput(ctx *Context, args *LookupFlinkMaterializedTableOutputArgs, opts ...InvokeOption) LookupFlinkMaterializedTableResultOutput

> Note: This function is named LookupFlinkMaterializedTable in the Go SDK.

public static class GetFlinkMaterializedTable 
{
    public static Task<GetFlinkMaterializedTableResult> InvokeAsync(GetFlinkMaterializedTableArgs args, InvokeOptions? opts = null)
    public static Output<GetFlinkMaterializedTableResult> Invoke(GetFlinkMaterializedTableInvokeArgs args, InvokeOptions? opts = null)
}

public static CompletableFuture<GetFlinkMaterializedTableResult> getFlinkMaterializedTable(GetFlinkMaterializedTableArgs args, InvokeOptions options)
public static Output<GetFlinkMaterializedTableResult> getFlinkMaterializedTable(GetFlinkMaterializedTableArgs args, InvokeOptions options)

fn::invoke:
  function: confluentcloud:index/getFlinkMaterializedTable:getFlinkMaterializedTable
  arguments:
    # arguments dictionary

data "confluentcloud_getflinkmaterializedtable" "name" {
    # arguments
}

The following arguments are supported:

DisplayName string: The unique name of the Materialized Table.
ComputePool Pulumi.ConfluentCloud.Inputs.GetFlinkMaterializedTableComputePool
Credentials Pulumi.ConfluentCloud.Inputs.GetFlinkMaterializedTableCredentials
Environment Pulumi.ConfluentCloud.Inputs.GetFlinkMaterializedTableEnvironment
Organization Pulumi.ConfluentCloud.Inputs.GetFlinkMaterializedTableOrganization
Principal Pulumi.ConfluentCloud.Inputs.GetFlinkMaterializedTablePrincipal
RestEndpoint string: The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud.

DisplayName string: The unique name of the Materialized Table.
ComputePool GetFlinkMaterializedTableComputePool
Credentials GetFlinkMaterializedTableCredentials
Environment GetFlinkMaterializedTableEnvironment
Organization GetFlinkMaterializedTableOrganization
Principal GetFlinkMaterializedTablePrincipal
RestEndpoint string: The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud.

display_name string: The unique name of the Materialized Table.
compute_pool object
credentials object
environment object
organization object
principal object
rest_endpoint string: The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud.

displayName String: The unique name of the Materialized Table.
computePool GetFlinkMaterializedTableComputePool
credentials GetFlinkMaterializedTableCredentials
environment GetFlinkMaterializedTableEnvironment
organization GetFlinkMaterializedTableOrganization
principal GetFlinkMaterializedTablePrincipal
restEndpoint String: The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud.

displayName string: The unique name of the Materialized Table.
computePool GetFlinkMaterializedTableComputePool
credentials GetFlinkMaterializedTableCredentials
environment GetFlinkMaterializedTableEnvironment
organization GetFlinkMaterializedTableOrganization
principal GetFlinkMaterializedTablePrincipal
restEndpoint string: The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud.

display_name str: The unique name of the Materialized Table.
compute_pool GetFlinkMaterializedTableComputePool
credentials GetFlinkMaterializedTableCredentials
environment GetFlinkMaterializedTableEnvironment
organization GetFlinkMaterializedTableOrganization
principal GetFlinkMaterializedTablePrincipal
rest_endpoint str: The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud.

displayName String: The unique name of the Materialized Table.
computePool Property Map
credentials Property Map
environment Property Map
organization Property Map
principal Property Map
restEndpoint String: The REST endpoint of the Flink region, for example, https://flink.us-east-1.aws.confluent.cloud.

getFlinkMaterializedTable Result

The following output properties are available:

Columns List<Pulumi.ConfluentCloud.Outputs.GetFlinkMaterializedTableColumn>: (Set of Strings) The column names of the constraint.
ComputePool Pulumi.ConfluentCloud.Outputs.GetFlinkMaterializedTableComputePool
Constraints List<Pulumi.ConfluentCloud.Outputs.GetFlinkMaterializedTableConstraint>: (List of Blocks) The table constraints of the Materialized Table. Each constraints block supports the following:
DisplayName string
Distributions List<Pulumi.ConfluentCloud.Outputs.GetFlinkMaterializedTableDistribution>: (Configuration Block) The distribution definition for the Materialized Table. Supports the following:
Environment Pulumi.ConfluentCloud.Outputs.GetFlinkMaterializedTableEnvironment
Id string: The provider-assigned unique ID for this managed resource.
KafkaClusters List<Pulumi.ConfluentCloud.Outputs.GetFlinkMaterializedTableKafkaCluster>: (Configuration Block) supports the following:
Organization Pulumi.ConfluentCloud.Outputs.GetFlinkMaterializedTableOrganization
Principal Pulumi.ConfluentCloud.Outputs.GetFlinkMaterializedTablePrincipal
Query string: (String) The SQL query that defines the Materialized Table.
Stopped bool: (Boolean) Whether the Materialized Table is stopped.
Watermarks List<Pulumi.ConfluentCloud.Outputs.GetFlinkMaterializedTableWatermark>: (Configuration Block) The watermark definition for the Materialized Table. Supports the following:
Credentials Pulumi.ConfluentCloud.Outputs.GetFlinkMaterializedTableCredentials
RestEndpoint string

Columns []GetFlinkMaterializedTableColumn: (Set of Strings) The column names of the constraint.
ComputePool GetFlinkMaterializedTableComputePool
Constraints []GetFlinkMaterializedTableConstraint: (List of Blocks) The table constraints of the Materialized Table. Each constraints block supports the following:
DisplayName string
Distributions []GetFlinkMaterializedTableDistribution: (Configuration Block) The distribution definition for the Materialized Table. Supports the following:
Environment GetFlinkMaterializedTableEnvironment
Id string: The provider-assigned unique ID for this managed resource.
KafkaClusters []GetFlinkMaterializedTableKafkaCluster: (Configuration Block) supports the following:
Organization GetFlinkMaterializedTableOrganization
Principal GetFlinkMaterializedTablePrincipal
Query string: (String) The SQL query that defines the Materialized Table.
Stopped bool: (Boolean) Whether the Materialized Table is stopped.
Watermarks []GetFlinkMaterializedTableWatermark: (Configuration Block) The watermark definition for the Materialized Table. Supports the following:
Credentials GetFlinkMaterializedTableCredentials
RestEndpoint string

columns list(object): (Set of Strings) The column names of the constraint.
compute_pool object
constraints list(object): (List of Blocks) The table constraints of the Materialized Table. Each constraints block supports the following:
display_name string
distributions list(object): (Configuration Block) The distribution definition for the Materialized Table. Supports the following:
environment object
id string: The provider-assigned unique ID for this managed resource.
kafka_clusters list(object): (Configuration Block) supports the following:
organization object
principal object
query string: (String) The SQL query that defines the Materialized Table.
stopped bool: (Boolean) Whether the Materialized Table is stopped.
watermarks list(object): (Configuration Block) The watermark definition for the Materialized Table. Supports the following:
credentials object
rest_endpoint string

columns List<GetFlinkMaterializedTableColumn>: (Set of Strings) The column names of the constraint.
computePool GetFlinkMaterializedTableComputePool
constraints List<GetFlinkMaterializedTableConstraint>: (List of Blocks) The table constraints of the Materialized Table. Each constraints block supports the following:
displayName String
distributions List<GetFlinkMaterializedTableDistribution>: (Configuration Block) The distribution definition for the Materialized Table. Supports the following:
environment GetFlinkMaterializedTableEnvironment
id String: The provider-assigned unique ID for this managed resource.
kafkaClusters List<GetFlinkMaterializedTableKafkaCluster>: (Configuration Block) supports the following:
organization GetFlinkMaterializedTableOrganization
principal GetFlinkMaterializedTablePrincipal
query String: (String) The SQL query that defines the Materialized Table.
stopped Boolean: (Boolean) Whether the Materialized Table is stopped.
watermarks List<GetFlinkMaterializedTableWatermark>: (Configuration Block) The watermark definition for the Materialized Table. Supports the following:
credentials GetFlinkMaterializedTableCredentials
restEndpoint String

columns GetFlinkMaterializedTableColumn[]: (Set of Strings) The column names of the constraint.
computePool GetFlinkMaterializedTableComputePool
constraints GetFlinkMaterializedTableConstraint[]: (List of Blocks) The table constraints of the Materialized Table. Each constraints block supports the following:
displayName string
distributions GetFlinkMaterializedTableDistribution[]: (Configuration Block) The distribution definition for the Materialized Table. Supports the following:
environment GetFlinkMaterializedTableEnvironment
id string: The provider-assigned unique ID for this managed resource.
kafkaClusters GetFlinkMaterializedTableKafkaCluster[]: (Configuration Block) supports the following:
organization GetFlinkMaterializedTableOrganization
principal GetFlinkMaterializedTablePrincipal
query string: (String) The SQL query that defines the Materialized Table.
stopped boolean: (Boolean) Whether the Materialized Table is stopped.
watermarks GetFlinkMaterializedTableWatermark[]: (Configuration Block) The watermark definition for the Materialized Table. Supports the following:
credentials GetFlinkMaterializedTableCredentials
restEndpoint string

columns Sequence[GetFlinkMaterializedTableColumn]: (Set of Strings) The column names of the constraint.
compute_pool GetFlinkMaterializedTableComputePool
constraints Sequence[GetFlinkMaterializedTableConstraint]: (List of Blocks) The table constraints of the Materialized Table. Each constraints block supports the following:
display_name str
distributions Sequence[GetFlinkMaterializedTableDistribution]: (Configuration Block) The distribution definition for the Materialized Table. Supports the following:
environment GetFlinkMaterializedTableEnvironment
id str: The provider-assigned unique ID for this managed resource.
kafka_clusters Sequence[GetFlinkMaterializedTableKafkaCluster]: (Configuration Block) supports the following:
organization GetFlinkMaterializedTableOrganization
principal GetFlinkMaterializedTablePrincipal
query str: (String) The SQL query that defines the Materialized Table.
stopped bool: (Boolean) Whether the Materialized Table is stopped.
watermarks Sequence[GetFlinkMaterializedTableWatermark]: (Configuration Block) The watermark definition for the Materialized Table. Supports the following:
credentials GetFlinkMaterializedTableCredentials
rest_endpoint str

columns List<Property Map>: (Set of Strings) The column names of the constraint.
computePool Property Map
constraints List<Property Map>: (List of Blocks) The table constraints of the Materialized Table. Each constraints block supports the following:
displayName String
distributions List<Property Map>: (Configuration Block) The distribution definition for the Materialized Table. Supports the following:
environment Property Map
id String: The provider-assigned unique ID for this managed resource.
kafkaClusters List<Property Map>: (Configuration Block) supports the following:
organization Property Map
principal Property Map
query String: (String) The SQL query that defines the Materialized Table.
stopped Boolean: (Boolean) Whether the Materialized Table is stopped.
watermarks List<Property Map>: (Configuration Block) The watermark definition for the Materialized Table. Supports the following:
credentials Property Map
restEndpoint String

Supporting Types

GetFlinkMaterializedTableColumn

ColumnsComputeds List<Pulumi.ConfluentCloud.Inputs.GetFlinkMaterializedTableColumnColumnsComputed>
ColumnsMetadatas List<Pulumi.ConfluentCloud.Inputs.GetFlinkMaterializedTableColumnColumnsMetadata>
ColumnsPhysicals List<Pulumi.ConfluentCloud.Inputs.GetFlinkMaterializedTableColumnColumnsPhysical>

ColumnsComputeds []GetFlinkMaterializedTableColumnColumnsComputed
ColumnsMetadatas []GetFlinkMaterializedTableColumnColumnsMetadata
ColumnsPhysicals []GetFlinkMaterializedTableColumnColumnsPhysical

columns_computeds list(object)
columns_metadatas list(object)
columns_physicals list(object)

columnsComputeds List<GetFlinkMaterializedTableColumnColumnsComputed>
columnsMetadatas List<GetFlinkMaterializedTableColumnColumnsMetadata>
columnsPhysicals List<GetFlinkMaterializedTableColumnColumnsPhysical>

columnsComputeds GetFlinkMaterializedTableColumnColumnsComputed[]
columnsMetadatas GetFlinkMaterializedTableColumnColumnsMetadata[]
columnsPhysicals GetFlinkMaterializedTableColumnColumnsPhysical[]

columns_computeds Sequence[GetFlinkMaterializedTableColumnColumnsComputed]
columns_metadatas Sequence[GetFlinkMaterializedTableColumnColumnsMetadata]
columns_physicals Sequence[GetFlinkMaterializedTableColumnColumnsPhysical]

columnsComputeds List<Property Map>
columnsMetadatas List<Property Map>
columnsPhysicals List<Property Map>

GetFlinkMaterializedTableColumnColumnsComputed

ColumnComputedComment string: Comment for the computed column.
ColumnComputedExpression string: Expression of the computed column.
ColumnComputedKind string: Kind of the computed column.
ColumnComputedName string: Name of the computed column.
ColumnComputedType string: Type of the computed column.
ColumnComputedVirtual bool: Whether computed column is virtual.

ColumnComputedComment string: Comment for the computed column.
ColumnComputedExpression string: Expression of the computed column.
ColumnComputedKind string: Kind of the computed column.
ColumnComputedName string: Name of the computed column.
ColumnComputedType string: Type of the computed column.
ColumnComputedVirtual bool: Whether computed column is virtual.

column_computed_comment string: Comment for the computed column.
column_computed_expression string: Expression of the computed column.
column_computed_kind string: Kind of the computed column.
column_computed_name string: Name of the computed column.
column_computed_type string: Type of the computed column.
column_computed_virtual bool: Whether computed column is virtual.

columnComputedComment String: Comment for the computed column.
columnComputedExpression String: Expression of the computed column.
columnComputedKind String: Kind of the computed column.
columnComputedName String: Name of the computed column.
columnComputedType String: Type of the computed column.
columnComputedVirtual Boolean: Whether computed column is virtual.

columnComputedComment string: Comment for the computed column.
columnComputedExpression string: Expression of the computed column.
columnComputedKind string: Kind of the computed column.
columnComputedName string: Name of the computed column.
columnComputedType string: Type of the computed column.
columnComputedVirtual boolean: Whether computed column is virtual.

column_computed_comment str: Comment for the computed column.
column_computed_expression str: Expression of the computed column.
column_computed_kind str: Kind of the computed column.
column_computed_name str: Name of the computed column.
column_computed_type str: Type of the computed column.
column_computed_virtual bool: Whether computed column is virtual.

columnComputedComment String: Comment for the computed column.
columnComputedExpression String: Expression of the computed column.
columnComputedKind String: Kind of the computed column.
columnComputedName String: Name of the computed column.
columnComputedType String: Type of the computed column.
columnComputedVirtual Boolean: Whether computed column is virtual.

GetFlinkMaterializedTableColumnColumnsMetadata

ColumnMetadataComment string: Comment for the metadata column.
ColumnMetadataKey string: Metadata key of the metadata column.
ColumnMetadataKind string: Kind of the metadata column.
ColumnMetadataName string: Name of the metadata column.
ColumnMetadataType string: Type of the metadata column.
ColumnMetadataVirtual bool: Whether metadata column is virtual.

ColumnMetadataComment string: Comment for the metadata column.
ColumnMetadataKey string: Metadata key of the metadata column.
ColumnMetadataKind string: Kind of the metadata column.
ColumnMetadataName string: Name of the metadata column.
ColumnMetadataType string: Type of the metadata column.
ColumnMetadataVirtual bool: Whether metadata column is virtual.

column_metadata_comment string: Comment for the metadata column.
column_metadata_key string: Metadata key of the metadata column.
column_metadata_kind string: Kind of the metadata column.
column_metadata_name string: Name of the metadata column.
column_metadata_type string: Type of the metadata column.
column_metadata_virtual bool: Whether metadata column is virtual.

columnMetadataComment String: Comment for the metadata column.
columnMetadataKey String: Metadata key of the metadata column.
columnMetadataKind String: Kind of the metadata column.
columnMetadataName String: Name of the metadata column.
columnMetadataType String: Type of the metadata column.
columnMetadataVirtual Boolean: Whether metadata column is virtual.

columnMetadataComment string: Comment for the metadata column.
columnMetadataKey string: Metadata key of the metadata column.
columnMetadataKind string: Kind of the metadata column.
columnMetadataName string: Name of the metadata column.
columnMetadataType string: Type of the metadata column.
columnMetadataVirtual boolean: Whether metadata column is virtual.

column_metadata_comment str: Comment for the metadata column.
column_metadata_key str: Metadata key of the metadata column.
column_metadata_kind str: Kind of the metadata column.
column_metadata_name str: Name of the metadata column.
column_metadata_type str: Type of the metadata column.
column_metadata_virtual bool: Whether metadata column is virtual.

columnMetadataComment String: Comment for the metadata column.
columnMetadataKey String: Metadata key of the metadata column.
columnMetadataKind String: Kind of the metadata column.
columnMetadataName String: Name of the metadata column.
columnMetadataType String: Type of the metadata column.
columnMetadataVirtual Boolean: Whether metadata column is virtual.

GetFlinkMaterializedTableColumnColumnsPhysical

ColumnPhysicalComment string: Comment for the physical column.
ColumnPhysicalKind string: Kind of the physical column.
ColumnPhysicalName string: Name of the physical column.
ColumnPhysicalType string: Type of the physical column.

ColumnPhysicalComment string: Comment for the physical column.
ColumnPhysicalKind string: Kind of the physical column.
ColumnPhysicalName string: Name of the physical column.
ColumnPhysicalType string: Type of the physical column.

column_physical_comment string: Comment for the physical column.
column_physical_kind string: Kind of the physical column.
column_physical_name string: Name of the physical column.
column_physical_type string: Type of the physical column.

columnPhysicalComment String: Comment for the physical column.
columnPhysicalKind String: Kind of the physical column.
columnPhysicalName String: Name of the physical column.
columnPhysicalType String: Type of the physical column.

columnPhysicalComment string: Comment for the physical column.
columnPhysicalKind string: Kind of the physical column.
columnPhysicalName string: Name of the physical column.
columnPhysicalType string: Type of the physical column.

column_physical_comment str: Comment for the physical column.
column_physical_kind str: Kind of the physical column.
column_physical_name str: Name of the physical column.
column_physical_type str: Type of the physical column.

columnPhysicalComment String: Comment for the physical column.
columnPhysicalKind String: Kind of the physical column.
columnPhysicalName String: Name of the physical column.
columnPhysicalType String: Type of the physical column.

GetFlinkMaterializedTableComputePool

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 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.

GetFlinkMaterializedTableConstraint

Columns List<string>: (Set of Strings) The column names of the constraint.
Enforced bool: (Boolean) Whether the constraint is enforced.
Name string: (String) The name of the constraint, for example, pkOrders.
Type string: (String) The type of the constraint, for example, PRIMARY_KEY.

Columns []string: (Set of Strings) The column names of the constraint.
Enforced bool: (Boolean) Whether the constraint is enforced.
Name string: (String) The name of the constraint, for example, pkOrders.
Type string: (String) The type of the constraint, for example, PRIMARY_KEY.

columns list(string): (Set of Strings) The column names of the constraint.
enforced bool: (Boolean) Whether the constraint is enforced.
name string: (String) The name of the constraint, for example, pkOrders.
type string: (String) The type of the constraint, for example, PRIMARY_KEY.

columns List<String>: (Set of Strings) The column names of the constraint.
enforced Boolean: (Boolean) Whether the constraint is enforced.
name String: (String) The name of the constraint, for example, pkOrders.
type String: (String) The type of the constraint, for example, PRIMARY_KEY.

columns string[]: (Set of Strings) The column names of the constraint.
enforced boolean: (Boolean) Whether the constraint is enforced.
name string: (String) The name of the constraint, for example, pkOrders.
type string: (String) The type of the constraint, for example, PRIMARY_KEY.

columns Sequence[str]: (Set of Strings) The column names of the constraint.
enforced bool: (Boolean) Whether the constraint is enforced.
name str: (String) The name of the constraint, for example, pkOrders.
type str: (String) The type of the constraint, for example, PRIMARY_KEY.

columns List<String>: (Set of Strings) The column names of the constraint.
enforced Boolean: (Boolean) Whether the constraint is enforced.
name String: (String) The name of the constraint, for example, pkOrders.
type String: (String) The type of the constraint, for example, PRIMARY_KEY.

GetFlinkMaterializedTableCredentials

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 Materialized Tables 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_materialized_table.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_materialized_table.example" -out=rotate-flink-api-key and pulumi up rotate-flink-api-key instead.

Note: When using OAuth to authenticate a Flink Materialized Table, if the intended principal.id is a service account instead of an Identity Pool, make sure the Identity Pool has an Assigner role binding on the service account. Otherwise, you may encounter a 403 Forbidden error. For example:

import * as pulumi from "@pulumi/pulumi";
import * as confluentcloud from "@pulumi/confluentcloud";
const identity_pool_assigner = new confluentcloud.RoleBinding("identity-pool-assigner", {
principal: "User:pool-abc123",
roleName: "Assigner",
crnPattern: ${main.resourceName}/service-account=sa-def456,
});

import pulumi
import pulumi_confluentcloud as confluentcloud

identity_pool_assigner = confluentcloud.RoleBinding("identity-pool-assigner",
    principal="User:pool-abc123",
    role_name="Assigner",
    crn_pattern=f"{main['resourceName']}/service-account=sa-def456")

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using ConfluentCloud = Pulumi.ConfluentCloud;

return await Deployment.RunAsync(() => 
{
    var identity_pool_assigner = new ConfluentCloud.RoleBinding("identity-pool-assigner", new()
    {
        Principal = "User:pool-abc123",
        RoleName = "Assigner",
        CrnPattern = $"{main.ResourceName}/service-account=sa-def456",
    });

});

package main

import (
	"github.com/pulumi/pulumi-confluentcloud/sdk/v2/go/confluentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := confluentcloud.NewRoleBinding(ctx, "identity-pool-assigner", &confluentcloud.RoleBindingArgs{
			Principal:  pulumi.String("User:pool-abc123"),
			RoleName:   pulumi.String("Assigner"),
			CrnPattern: pulumi.Sprintf("%v/service-account=sa-def456", main.ResourceName),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.confluentcloud.RoleBinding;
import com.pulumi.confluentcloud.RoleBindingArgs;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var identity_pool_assigner = new RoleBinding("identity-pool-assigner", RoleBindingArgs.builder()
            .principal("User:pool-abc123")
            .roleName("Assigner")
            .crnPattern(String.format("%s/service-account=sa-def456", main.resourceName()))
            .build());

    }
}

resources:
  identity-pool-assigner:
    type: confluentcloud:RoleBinding
    properties:
      principal: User:pool-abc123
      roleName: Assigner
      crnPattern: ${main.resourceName}/service-account=sa-def456

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 Materialized Tables 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_materialized_table.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_materialized_table.example" -out=rotate-flink-api-key and pulumi up rotate-flink-api-key instead.

Note: When using OAuth to authenticate a Flink Materialized Table, if the intended principal.id is a service account instead of an Identity Pool, make sure the Identity Pool has an Assigner role binding on the service account. Otherwise, you may encounter a 403 Forbidden error. For example:

import * as pulumi from "@pulumi/pulumi";
import * as confluentcloud from "@pulumi/confluentcloud";
const identity_pool_assigner = new confluentcloud.RoleBinding("identity-pool-assigner", {
principal: "User:pool-abc123",
roleName: "Assigner",
crnPattern: ${main.resourceName}/service-account=sa-def456,
});

import pulumi
import pulumi_confluentcloud as confluentcloud

identity_pool_assigner = confluentcloud.RoleBinding("identity-pool-assigner",
    principal="User:pool-abc123",
    role_name="Assigner",
    crn_pattern=f"{main['resourceName']}/service-account=sa-def456")

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using ConfluentCloud = Pulumi.ConfluentCloud;

return await Deployment.RunAsync(() => 
{
    var identity_pool_assigner = new ConfluentCloud.RoleBinding("identity-pool-assigner", new()
    {
        Principal = "User:pool-abc123",
        RoleName = "Assigner",
        CrnPattern = $"{main.ResourceName}/service-account=sa-def456",
    });

});

package main

import (
	"github.com/pulumi/pulumi-confluentcloud/sdk/v2/go/confluentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := confluentcloud.NewRoleBinding(ctx, "identity-pool-assigner", &confluentcloud.RoleBindingArgs{
			Principal:  pulumi.String("User:pool-abc123"),
			RoleName:   pulumi.String("Assigner"),
			CrnPattern: pulumi.Sprintf("%v/service-account=sa-def456", main.ResourceName),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.confluentcloud.RoleBinding;
import com.pulumi.confluentcloud.RoleBindingArgs;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var identity_pool_assigner = new RoleBinding("identity-pool-assigner", RoleBindingArgs.builder()
            .principal("User:pool-abc123")
            .roleName("Assigner")
            .crnPattern(String.format("%s/service-account=sa-def456", main.resourceName()))
            .build());

    }
}

resources:
  identity-pool-assigner:
    type: confluentcloud:RoleBinding
    properties:
      principal: User:pool-abc123
      roleName: Assigner
      crnPattern: ${main.resourceName}/service-account=sa-def456

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 Materialized Tables 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_materialized_table.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_materialized_table.example" -out=rotate-flink-api-key and pulumi up rotate-flink-api-key instead.

Note: When using OAuth to authenticate a Flink Materialized Table, if the intended principal.id is a service account instead of an Identity Pool, make sure the Identity Pool has an Assigner role binding on the service account. Otherwise, you may encounter a 403 Forbidden error. For example:

import * as pulumi from "@pulumi/pulumi";
import * as confluentcloud from "@pulumi/confluentcloud";
const identity_pool_assigner = new confluentcloud.RoleBinding("identity-pool-assigner", {
principal: "User:pool-abc123",
roleName: "Assigner",
crnPattern: ${main.resourceName}/service-account=sa-def456,
});

import pulumi
import pulumi_confluentcloud as confluentcloud

identity_pool_assigner = confluentcloud.RoleBinding("identity-pool-assigner",
    principal="User:pool-abc123",
    role_name="Assigner",
    crn_pattern=f"{main['resourceName']}/service-account=sa-def456")

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using ConfluentCloud = Pulumi.ConfluentCloud;

return await Deployment.RunAsync(() => 
{
    var identity_pool_assigner = new ConfluentCloud.RoleBinding("identity-pool-assigner", new()
    {
        Principal = "User:pool-abc123",
        RoleName = "Assigner",
        CrnPattern = $"{main.ResourceName}/service-account=sa-def456",
    });

});

package main

import (
	"github.com/pulumi/pulumi-confluentcloud/sdk/v2/go/confluentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := confluentcloud.NewRoleBinding(ctx, "identity-pool-assigner", &confluentcloud.RoleBindingArgs{
			Principal:  pulumi.String("User:pool-abc123"),
			RoleName:   pulumi.String("Assigner"),
			CrnPattern: pulumi.Sprintf("%v/service-account=sa-def456", main.ResourceName),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.confluentcloud.RoleBinding;
import com.pulumi.confluentcloud.RoleBindingArgs;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var identity_pool_assigner = new RoleBinding("identity-pool-assigner", RoleBindingArgs.builder()
            .principal("User:pool-abc123")
            .roleName("Assigner")
            .crnPattern(String.format("%s/service-account=sa-def456", main.resourceName()))
            .build());

    }
}

resources:
  identity-pool-assigner:
    type: confluentcloud:RoleBinding
    properties:
      principal: User:pool-abc123
      roleName: Assigner
      crnPattern: ${main.resourceName}/service-account=sa-def456

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 Materialized Tables 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_materialized_table.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_materialized_table.example" -out=rotate-flink-api-key and pulumi up rotate-flink-api-key instead.

Note: When using OAuth to authenticate a Flink Materialized Table, if the intended principal.id is a service account instead of an Identity Pool, make sure the Identity Pool has an Assigner role binding on the service account. Otherwise, you may encounter a 403 Forbidden error. For example:

import * as pulumi from "@pulumi/pulumi";
import * as confluentcloud from "@pulumi/confluentcloud";
const identity_pool_assigner = new confluentcloud.RoleBinding("identity-pool-assigner", {
principal: "User:pool-abc123",
roleName: "Assigner",
crnPattern: ${main.resourceName}/service-account=sa-def456,
});

import pulumi
import pulumi_confluentcloud as confluentcloud

identity_pool_assigner = confluentcloud.RoleBinding("identity-pool-assigner",
    principal="User:pool-abc123",
    role_name="Assigner",
    crn_pattern=f"{main['resourceName']}/service-account=sa-def456")

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using ConfluentCloud = Pulumi.ConfluentCloud;

return await Deployment.RunAsync(() => 
{
    var identity_pool_assigner = new ConfluentCloud.RoleBinding("identity-pool-assigner", new()
    {
        Principal = "User:pool-abc123",
        RoleName = "Assigner",
        CrnPattern = $"{main.ResourceName}/service-account=sa-def456",
    });

});

package main

import (
	"github.com/pulumi/pulumi-confluentcloud/sdk/v2/go/confluentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := confluentcloud.NewRoleBinding(ctx, "identity-pool-assigner", &confluentcloud.RoleBindingArgs{
			Principal:  pulumi.String("User:pool-abc123"),
			RoleName:   pulumi.String("Assigner"),
			CrnPattern: pulumi.Sprintf("%v/service-account=sa-def456", main.ResourceName),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.confluentcloud.RoleBinding;
import com.pulumi.confluentcloud.RoleBindingArgs;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var identity_pool_assigner = new RoleBinding("identity-pool-assigner", RoleBindingArgs.builder()
            .principal("User:pool-abc123")
            .roleName("Assigner")
            .crnPattern(String.format("%s/service-account=sa-def456", main.resourceName()))
            .build());

    }
}

resources:
  identity-pool-assigner:
    type: confluentcloud:RoleBinding
    properties:
      principal: User:pool-abc123
      roleName: Assigner
      crnPattern: ${main.resourceName}/service-account=sa-def456

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 Materialized Tables 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_materialized_table.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_materialized_table.example" -out=rotate-flink-api-key and pulumi up rotate-flink-api-key instead.

Note: When using OAuth to authenticate a Flink Materialized Table, if the intended principal.id is a service account instead of an Identity Pool, make sure the Identity Pool has an Assigner role binding on the service account. Otherwise, you may encounter a 403 Forbidden error. For example:

import * as pulumi from "@pulumi/pulumi";
import * as confluentcloud from "@pulumi/confluentcloud";
const identity_pool_assigner = new confluentcloud.RoleBinding("identity-pool-assigner", {
principal: "User:pool-abc123",
roleName: "Assigner",
crnPattern: ${main.resourceName}/service-account=sa-def456,
});

import pulumi
import pulumi_confluentcloud as confluentcloud

identity_pool_assigner = confluentcloud.RoleBinding("identity-pool-assigner",
    principal="User:pool-abc123",
    role_name="Assigner",
    crn_pattern=f"{main['resourceName']}/service-account=sa-def456")

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using ConfluentCloud = Pulumi.ConfluentCloud;

return await Deployment.RunAsync(() => 
{
    var identity_pool_assigner = new ConfluentCloud.RoleBinding("identity-pool-assigner", new()
    {
        Principal = "User:pool-abc123",
        RoleName = "Assigner",
        CrnPattern = $"{main.ResourceName}/service-account=sa-def456",
    });

});

package main

import (
	"github.com/pulumi/pulumi-confluentcloud/sdk/v2/go/confluentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := confluentcloud.NewRoleBinding(ctx, "identity-pool-assigner", &confluentcloud.RoleBindingArgs{
			Principal:  pulumi.String("User:pool-abc123"),
			RoleName:   pulumi.String("Assigner"),
			CrnPattern: pulumi.Sprintf("%v/service-account=sa-def456", main.ResourceName),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.confluentcloud.RoleBinding;
import com.pulumi.confluentcloud.RoleBindingArgs;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var identity_pool_assigner = new RoleBinding("identity-pool-assigner", RoleBindingArgs.builder()
            .principal("User:pool-abc123")
            .roleName("Assigner")
            .crnPattern(String.format("%s/service-account=sa-def456", main.resourceName()))
            .build());

    }
}

resources:
  identity-pool-assigner:
    type: confluentcloud:RoleBinding
    properties:
      principal: User:pool-abc123
      roleName: Assigner
      crnPattern: ${main.resourceName}/service-account=sa-def456

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 Materialized Tables 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_materialized_table.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_materialized_table.example" -out=rotate-flink-api-key and pulumi up rotate-flink-api-key instead.

Note: When using OAuth to authenticate a Flink Materialized Table, if the intended principal.id is a service account instead of an Identity Pool, make sure the Identity Pool has an Assigner role binding on the service account. Otherwise, you may encounter a 403 Forbidden error. For example:

import * as pulumi from "@pulumi/pulumi";
import * as confluentcloud from "@pulumi/confluentcloud";
const identity_pool_assigner = new confluentcloud.RoleBinding("identity-pool-assigner", {
principal: "User:pool-abc123",
roleName: "Assigner",
crnPattern: ${main.resourceName}/service-account=sa-def456,
});

import pulumi
import pulumi_confluentcloud as confluentcloud

identity_pool_assigner = confluentcloud.RoleBinding("identity-pool-assigner",
    principal="User:pool-abc123",
    role_name="Assigner",
    crn_pattern=f"{main['resourceName']}/service-account=sa-def456")

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using ConfluentCloud = Pulumi.ConfluentCloud;

return await Deployment.RunAsync(() => 
{
    var identity_pool_assigner = new ConfluentCloud.RoleBinding("identity-pool-assigner", new()
    {
        Principal = "User:pool-abc123",
        RoleName = "Assigner",
        CrnPattern = $"{main.ResourceName}/service-account=sa-def456",
    });

});

package main

import (
	"github.com/pulumi/pulumi-confluentcloud/sdk/v2/go/confluentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := confluentcloud.NewRoleBinding(ctx, "identity-pool-assigner", &confluentcloud.RoleBindingArgs{
			Principal:  pulumi.String("User:pool-abc123"),
			RoleName:   pulumi.String("Assigner"),
			CrnPattern: pulumi.Sprintf("%v/service-account=sa-def456", main.ResourceName),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.confluentcloud.RoleBinding;
import com.pulumi.confluentcloud.RoleBindingArgs;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var identity_pool_assigner = new RoleBinding("identity-pool-assigner", RoleBindingArgs.builder()
            .principal("User:pool-abc123")
            .roleName("Assigner")
            .crnPattern(String.format("%s/service-account=sa-def456", main.resourceName()))
            .build());

    }
}

resources:
  identity-pool-assigner:
    type: confluentcloud:RoleBinding
    properties:
      principal: User:pool-abc123
      roleName: Assigner
      crnPattern: ${main.resourceName}/service-account=sa-def456

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 Materialized Tables 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_materialized_table.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_materialized_table.example" -out=rotate-flink-api-key and pulumi up rotate-flink-api-key instead.

Note: When using OAuth to authenticate a Flink Materialized Table, if the intended principal.id is a service account instead of an Identity Pool, make sure the Identity Pool has an Assigner role binding on the service account. Otherwise, you may encounter a 403 Forbidden error. For example:

import * as pulumi from "@pulumi/pulumi";
import * as confluentcloud from "@pulumi/confluentcloud";
const identity_pool_assigner = new confluentcloud.RoleBinding("identity-pool-assigner", {
principal: "User:pool-abc123",
roleName: "Assigner",
crnPattern: ${main.resourceName}/service-account=sa-def456,
});

import pulumi
import pulumi_confluentcloud as confluentcloud

identity_pool_assigner = confluentcloud.RoleBinding("identity-pool-assigner",
    principal="User:pool-abc123",
    role_name="Assigner",
    crn_pattern=f"{main['resourceName']}/service-account=sa-def456")

using System.Collections.Generic;
using System.Linq;
using Pulumi;
using ConfluentCloud = Pulumi.ConfluentCloud;

return await Deployment.RunAsync(() => 
{
    var identity_pool_assigner = new ConfluentCloud.RoleBinding("identity-pool-assigner", new()
    {
        Principal = "User:pool-abc123",
        RoleName = "Assigner",
        CrnPattern = $"{main.ResourceName}/service-account=sa-def456",
    });

});

package main

import (
	"github.com/pulumi/pulumi-confluentcloud/sdk/v2/go/confluentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := confluentcloud.NewRoleBinding(ctx, "identity-pool-assigner", &confluentcloud.RoleBindingArgs{
			Principal:  pulumi.String("User:pool-abc123"),
			RoleName:   pulumi.String("Assigner"),
			CrnPattern: pulumi.Sprintf("%v/service-account=sa-def456", main.ResourceName),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.confluentcloud.RoleBinding;
import com.pulumi.confluentcloud.RoleBindingArgs;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var identity_pool_assigner = new RoleBinding("identity-pool-assigner", RoleBindingArgs.builder()
            .principal("User:pool-abc123")
            .roleName("Assigner")
            .crnPattern(String.format("%s/service-account=sa-def456", main.resourceName()))
            .build());

    }
}

resources:
  identity-pool-assigner:
    type: confluentcloud:RoleBinding
    properties:
      principal: User:pool-abc123
      roleName: Assigner
      crnPattern: ${main.resourceName}/service-account=sa-def456

GetFlinkMaterializedTableDistribution

BucketCount int: (Integer) The number of buckets the table is distributed by.
Keys List<string>: (Set of Strings) The names of the columns the table is distributed by.

BucketCount int: (Integer) The number of buckets the table is distributed by.
Keys []string: (Set of Strings) The names of the columns the table is distributed by.

bucket_count number: (Integer) The number of buckets the table is distributed by.
keys list(string): (Set of Strings) The names of the columns the table is distributed by.

bucketCount Integer: (Integer) The number of buckets the table is distributed by.
keys List<String>: (Set of Strings) The names of the columns the table is distributed by.

bucketCount number: (Integer) The number of buckets the table is distributed by.
keys string[]: (Set of Strings) The names of the columns the table is distributed by.

bucket_count int: (Integer) The number of buckets the table is distributed by.
keys Sequence[str]: (Set of Strings) The names of the columns the table is distributed by.

bucketCount Number: (Integer) The number of buckets the table is distributed by.
keys List<String>: (Set of Strings) The names of the columns the table is distributed by.

GetFlinkMaterializedTableEnvironment

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 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.

GetFlinkMaterializedTableKafkaCluster

Id string: (String) The ID of the Kafka Cluster hosting the Materialized Table's topic, for example, lkc-abc123.

Id string: (String) The ID of the Kafka Cluster hosting the Materialized Table's topic, for example, lkc-abc123.

id string: (String) The ID of the Kafka Cluster hosting the Materialized Table's topic, for example, lkc-abc123.

id String: (String) The ID of the Kafka Cluster hosting the Materialized Table's topic, for example, lkc-abc123.

id string: (String) The ID of the Kafka Cluster hosting the Materialized Table's topic, for example, lkc-abc123.

id str: (String) The ID of the Kafka Cluster hosting the Materialized Table's topic, for example, lkc-abc123.

id String: (String) The ID of the Kafka Cluster hosting the Materialized Table's topic, for example, lkc-abc123.

GetFlinkMaterializedTableOrganization

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 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.

GetFlinkMaterializedTablePrincipal

Id string: The ID of the Principal the Flink Materialized Table runs as, for example, sa-abc123.

Id string: The ID of the Principal the Flink Materialized Table runs as, for example, sa-abc123.

id string: The ID of the Principal the Flink Materialized Table runs as, for example, sa-abc123.

id String: The ID of the Principal the Flink Materialized Table runs as, for example, sa-abc123.

id string: The ID of the Principal the Flink Materialized Table runs as, for example, sa-abc123.

id str: The ID of the Principal the Flink Materialized Table runs as, for example, sa-abc123.

id String: The ID of the Principal the Flink Materialized Table runs as, for example, sa-abc123.

GetFlinkMaterializedTableWatermark

Column string: (String) The name of the watermark column.
Expression string: (String) The watermark expression.

Column string: (String) The name of the watermark column.
Expression string: (String) The watermark expression.

column string: (String) The name of the watermark column.
expression string: (String) The watermark expression.

column String: (String) The name of the watermark column.
expression String: (String) The watermark expression.

column string: (String) The name of the watermark column.
expression string: (String) The watermark expression.

column str: (String) The name of the watermark column.
expression str: (String) The watermark expression.

column String: (String) The name of the watermark column.
expression String: (String) The watermark expression.

Package Details

Repository: Confluent Cloud pulumi/pulumi-confluentcloud
License: Apache-2.0
Notes: This Pulumi package is based on the confluent Terraform Provider.

Viewing docs for Confluent v2.69.0
published on Friday, May 15, 2026 by Pulumi

Schema (JSON)

pulumi/pulumi-confluentcloud

confluentcloud.getFlinkMaterializedTable

On this page

On this page

Example Usage

Option #1: Manage multiple Flink Materialized Tables in the same Pulumi Stack

Option #2: Manage a single Flink Materialized Table in the same Pulumi Stack

Using getFlinkMaterializedTable

getFlinkMaterializedTable Result

Supporting Types

GetFlinkMaterializedTableColumn

GetFlinkMaterializedTableColumnColumnsComputed

GetFlinkMaterializedTableColumnColumnsMetadata

GetFlinkMaterializedTableColumnColumnsPhysical

GetFlinkMaterializedTableComputePool

GetFlinkMaterializedTableConstraint

GetFlinkMaterializedTableCredentials

GetFlinkMaterializedTableDistribution

GetFlinkMaterializedTableEnvironment

GetFlinkMaterializedTableKafkaCluster

GetFlinkMaterializedTableOrganization

GetFlinkMaterializedTablePrincipal

GetFlinkMaterializedTableWatermark

Package Details

On this page

On this page