original_docstring: Copies 'source_table' into a parquet table and makes sure that the row group
      statistics in the resulting parquet file match those in 'expected_values'.
      
docstring: Copies 'source_table' into a parquet table and makes sure that the row group
  statistics in the resulting parquet file match those in 'expected_values'.
docstring_tokens: Copies ' source_table ' into a parquet table and makes sure that the row group statistics in the resulting parquet file match those in ' expected_values ' .
code: def _ctas_table_and_verify_stats(self, vector, unique_database, source_table,
                                     expected_values):
      """Copies 'source_table' into a parquet table and makes sure that the row group
      statistics in the resulting parquet file match those in 'expected_values'.
      """
      table_name = "test_hdfs_parquet_table_writer"
      qualified_table_name = "{0}.{1}".format(unique_database, table_name)
      hdfs_path = get_fs_path('/test-warehouse/{0}.db/{1}/'.format(unique_database,
                                                                   table_name))
  
      # Setting num_nodes = 1 ensures that the query is executed on the coordinator,
      # resulting in a single parquet file being written.
      self.execute_query("drop table if exists {0}".format(qualified_table_name))
      query = ("create table {0} stored as parquet as select * from {1}").format(
          qualified_table_name, source_table)
      vector.get_value('exec_option')['num_nodes'] = 1
      self.execute_query(query, vector.get_value('exec_option'))
      self._validate_parquet_stats(hdfs_path, expected_values)
code_tokens: def _ctas_table_and_verify_stats ( self , vector , unique_database , source_table , expected_values ) : table_name = "test_hdfs_parquet_table_writer" qualified_table_name = "{0}.{1}" . format ( unique_database , table_name ) hdfs_path = get_fs_path ( '/test-warehouse/{0}.db/{1}/' . format ( unique_database , table_name ) ) self . execute_query ( "drop table if exists {0}" . format ( qualified_table_name ) ) query = ( "create table {0} stored as parquet as select * from {1}" ) . format ( qualified_table_name , source_table ) vector . get_value ( 'exec_option' ) [ 'num_nodes' ] = 1 self . execute_query ( query , vector . get_value ( 'exec_option' ) ) self . _validate_parquet_stats ( hdfs_path , expected_values )
short_docstring: Copies 'source_table' into a parquet table and makes sure that the row group
  statistics in the resulting parquet file match those in 'expected_values'.
short_docstring_tokens: Copies ' source_table ' into a parquet table and makes sure that the row group statistics in the resulting parquet file match those in ' expected_values ' .
comment: """Copies 'source_table' into a parquet table and makes sure that the row group
      statistics in the resulting parquet file match those in 'expected_values'.
      """$SEP$# Setting num_nodes = 1 ensures that the query is executed on the coordinator,$SEP$# resulting in a single parquet file being written.