_aws_profile Input Column
The AWS profile defines the AWS identity used. It can be defined via credentials or by assuming a IAM role. | STRUCT( "type" VARCHAR, "name" VARCHAR, "account_id" VARCHAR, "via_profile_name" VARCHAR, "assumed_role_arn" VARCHAR, "organization" STRUCT( "account_name" VARCHAR, "id" VARCHAR, "tags" STRUCT( "key" VARCHAR, "value" VARCHAR )[], "master_account" STRUCT( "id" VARCHAR, "email" VARCHAR ), "parents" STRUCT( "type" VARCHAR, "id" VARCHAR, "name" VARCHAR, "tags" STRUCT( "key" VARCHAR, "value" VARCHAR )[] )[] ) ) |
cluster_operation_info
Cluster operation information | STRUCT( "cluster_arn" VARCHAR, "cluster_type" VARCHAR, "start_time" TIMESTAMP_S, "end_time" TIMESTAMP_S, "error_info" STRUCT( "error_code" VARCHAR, "error_string" VARCHAR ), "operation_arn" VARCHAR, "operation_state" VARCHAR, "operation_type" VARCHAR, "provisioned" STRUCT( "operation_steps" STRUCT( "step_info" STRUCT( "step_status" VARCHAR ), "step_name" VARCHAR )[], "source_cluster_info" STRUCT( "broker_ebs_volume_info" STRUCT( "kafka_broker_node_id" VARCHAR, "provisioned_throughput" STRUCT( "enabled" BOOLEAN, "volume_throughput" BIGINT ), "volume_size_gb" BIGINT )[], "configuration_info" STRUCT( "arn" VARCHAR, "revision" BIGINT ), "number_of_broker_nodes" BIGINT, "enhanced_monitoring" VARCHAR, "open_monitoring" STRUCT( "prometheus" STRUCT( "jmx_exporter" STRUCT( "enabled_in_broker" BOOLEAN ), "node_exporter" STRUCT( "enabled_in_broker" BOOLEAN ) ) ), "kafka_version" VARCHAR, "logging_info" STRUCT( "broker_logs" STRUCT( "cloud_watch_logs" STRUCT( "enabled" BOOLEAN, "log_group" VARCHAR ), "firehose" STRUCT( "delivery_stream" VARCHAR, "enabled" BOOLEAN ), "s3" STRUCT( "bucket" VARCHAR, "enabled" BOOLEAN, "prefix" VARCHAR ) ) ), "instance_type" VARCHAR, "client_authentication" STRUCT( "sasl" STRUCT( "scram" STRUCT( "enabled" BOOLEAN ), "iam" STRUCT( "enabled" BOOLEAN ) ), "tls" STRUCT( "certificate_authority_arn_list" VARCHAR[], "enabled" BOOLEAN ), "unauthenticated" STRUCT( "enabled" BOOLEAN ) ), "encryption_info" STRUCT( "encryption_at_rest" STRUCT( "data_volume_kms_key_id" VARCHAR ), "encryption_in_transit" STRUCT( "client_broker" VARCHAR, "in_cluster" BOOLEAN ) ), "connectivity_info" STRUCT( "public_access" STRUCT( "type" VARCHAR ), "vpc_connectivity" STRUCT( "client_authentication" STRUCT( "sasl" STRUCT( "scram" STRUCT( "enabled" BOOLEAN ), "iam" STRUCT( "enabled" BOOLEAN ) ), "tls" STRUCT( "enabled" BOOLEAN ) ) ) ), "storage_mode" VARCHAR, "broker_count_update_info" STRUCT( "created_broker_ids" DOUBLE[], "deleted_broker_ids" DOUBLE[] ) ), "target_cluster_info" STRUCT( "broker_ebs_volume_info" STRUCT( "kafka_broker_node_id" VARCHAR, "provisioned_throughput" STRUCT( "enabled" BOOLEAN, "volume_throughput" BIGINT ), "volume_size_gb" BIGINT )[], "configuration_info" STRUCT( "arn" VARCHAR, "revision" BIGINT ), "number_of_broker_nodes" BIGINT, "enhanced_monitoring" VARCHAR, "open_monitoring" STRUCT( "prometheus" STRUCT( "jmx_exporter" STRUCT( "enabled_in_broker" BOOLEAN ), "node_exporter" STRUCT( "enabled_in_broker" BOOLEAN ) ) ), "kafka_version" VARCHAR, "logging_info" STRUCT( "broker_logs" STRUCT( "cloud_watch_logs" STRUCT( "enabled" BOOLEAN, "log_group" VARCHAR ), "firehose" STRUCT( "delivery_stream" VARCHAR, "enabled" BOOLEAN ), "s3" STRUCT( "bucket" VARCHAR, "enabled" BOOLEAN, "prefix" VARCHAR ) ) ), "instance_type" VARCHAR, "client_authentication" STRUCT( "sasl" STRUCT( "scram" STRUCT( "enabled" BOOLEAN ), "iam" STRUCT( "enabled" BOOLEAN ) ), "tls" STRUCT( "certificate_authority_arn_list" VARCHAR[], "enabled" BOOLEAN ), "unauthenticated" STRUCT( "enabled" BOOLEAN ) ), "encryption_info" STRUCT( "encryption_at_rest" STRUCT( "data_volume_kms_key_id" VARCHAR ), "encryption_in_transit" STRUCT( "client_broker" VARCHAR, "in_cluster" BOOLEAN ) ), "connectivity_info" STRUCT( "public_access" STRUCT( "type" VARCHAR ), "vpc_connectivity" STRUCT( "client_authentication" STRUCT( "sasl" STRUCT( "scram" STRUCT( "enabled" BOOLEAN ), "iam" STRUCT( "enabled" BOOLEAN ) ), "tls" STRUCT( "enabled" BOOLEAN ) ) ) ), "storage_mode" VARCHAR, "broker_count_update_info" STRUCT( "created_broker_ids" DOUBLE[], "deleted_broker_ids" DOUBLE[] ) ), "vpc_connection_info" STRUCT( "vpc_connection_arn" VARCHAR, "owner" VARCHAR, "user_identity" STRUCT( "type" VARCHAR, "principal_id" VARCHAR ), "creation_time" TIMESTAMP_S ) ), "serverless" STRUCT( "vpc_connection_info" STRUCT( "creation_time" TIMESTAMP_S, "owner" VARCHAR, "user_identity" STRUCT( "type" VARCHAR, "principal_id" VARCHAR ), "vpc_connection_arn" VARCHAR ) ) ) |