code: def _construct_create_table_statement(
      schema, table_name, bucket, file_format="parquet"
  ):
      """Convert a dictionary based Athena schema to a Hive DDL statement
  
      Args:
          schema (dict): The sanitized Athena schema
          table_name (str): The name of the Athena table to create
          bucket (str): The S3 bucket containing the data
  
      Returns:
          str: The Hive DDL CREATE TABLE expression
      """
      # Construct the main Athena Schema
      schema_statement = []
      for key_name in sorted(schema.keys()):
          key_type = schema[key_name]
          if isinstance(key_type, str):
              schema_statement.append(
                  "{0} {1}".format(key_name, key_type)
              )
          # Account for nested structs
          elif isinstance(key_type, dict):
              struct_schema = ", ".join(
                  "{0}:{1}".format(sub_key, key_type[sub_key])
                  for sub_key in sorted(key_type.keys())
              )
              schema_statement.append(
                  "{0} struct<{1}>".format(key_name, struct_schema)
              )
  
      return CREATE_TABLE_STATEMENT.format(
          table_name=table_name,
          schema=", ".join(schema_statement),
          file_format=STORE_FORMAT_PARQUET
          if file_format == "parquet"
          else STORE_FORMAT_JSON,
          bucket=bucket,
      )
  
imports: from streamalert.shared.firehose import FirehoseClient
  from streamalert.shared.utils import get_database_name, get_data_file_format
  from streamalert.shared.alert import Alert
  from streamalert.shared.athena import AthenaClient
  from streamalert.shared.config import firehose_alerts_bucket, firehose_data_bucket
  from streamalert.shared.logger import get_logger
  from streamalert_cli.athena import helpers
  from streamalert_cli.helpers import continue_prompt, record_to_schema
  from streamalert_cli.utils import CLICommand, generate_subparser, set_parser_epilog, UniqueSortedListAction
label_desc: Use image node_id 5 for calling a global function with example usage: _construct_create_table_statement(schema, table_name, bucket, file_format) and returns: CREATE_TABLE_STATEMENT