pytest/sys/data/schema.py

#!/bin/env python
# -*- coding: utf-8 -*-
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements.  See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership.  The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License.  You may obtain a copy of the License at
#
#   http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied.  See the License for the
# specific language governing permissions and limitations
# under the License.

"""
the data set for test load on palo
Date: 2018-07-10 15:12:35
"""
import sys, os
sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), "../../lib")))
sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), "../..")))
from palo_client import PartitionInfo
from palo_client import DistributionInfo

baseall_column_list = [("k1", "tinyint"),
                       ("k2", "smallint"),
                       ("k3", "int"),
                       ("k4", "bigint"),
                       ("k5", "decimal(9, 3)"),
                       ("k6", "char(5)"),
                       ("k10", "date"),
                       ("k11", "datetime"),
                       ("k7", "varchar(20)"),
                       ("k8", "double", "max"),
                       ("k9", "float", "sum")]

baseall_column_no_agg_list = [("k1", "tinyint"),
                              ("k2", "smallint"),
                              ("k3", "int"),
                              ("k4", "bigint"),
                              ("k5", "decimal(9, 3)"),
                              ("k6", "char(5)"),
                              ("k10", "date"),
                              ("k11", "datetime"),
                              ("k7", "varchar(20)"),
                              ("k8", "double"),
                              ("k9", "float")]

baseall_column_name_list = ['k1', 'k2', 'k3', 'k4', 'k5', 'k6', 'k10', 'k11', 'k7', 'k8', 'k9']

baseall_tinyint_partition_info = PartitionInfo("k1",
                                       ["p1", "p2", "p3", "p4", "p5"],
                                       ["-10", "0", "10", "100", "MAXVALUE"])

baseall_smallint_partition_info = PartitionInfo(
    'k2',
    ['partition_a', 'partition_b', 'partition_c', 'partition_d'],
    ['0', '5', '10', 'MAXVALUE']
)

baseall_int_partition_info = PartitionInfo(
    'k3',
    ['partition_a', 'partition_b', 'partition_c', 'partition_d'],
    ['0', '2000', '65536', 'MAXVALUE']
)

baseall_bigint_partition_info = PartitionInfo(
    'k4',
    ['partition_a', 'partition_b', 'partition_c', 'partition_d'],
    ['-11011905', '0', '11011905', 'MAXVALUE']
)

baseall_date_partition_info = PartitionInfo(
    'k10',
    ['partition_a', 'partition_b', 'partition_c'],
    ['1910-01-01', '2012-03-14', 'MAXVALUE']
)

baseall_datetime_partition_info = PartitionInfo(
    'k11',
    ['partition_a', 'partition_b', 'partition_c'],
    ['1910-01-01 00:00:00', '2012-03-14 00:00:00', 'MAXVALUE']
)

baseall_distribution_info = DistributionInfo('HASH(k1)', 5)
baseall_duplicate_key = 'DUPLICATE KEY(k1,k2,k3,k4,k5,k6,k10,k11,k7)' 
baseall_unique_key = 'UNIQUE KEY(k1,k2,k3,k4,k5,k6,k10,k11,k7)'

all_type_column_list = [("tinyint_key", "tinyint"), ("smallint_key", "smallint"),
        ("int_key", "int"), ("bigint_key", "bigint"),
        ("char_50_key", "char(50)"), ("varchar_key", "varchar(500)"),
        ("char_key", "char"), ("varchar_most_key", "varchar(65533)"),
        ("decimal_key", "decimal(20, 6)"), ("decimal_most_key", "decimal(27, 9)"),
        ("date_key", "date"), ("datetime_key", "datetime"),
        ("tinyint_value", "tinyint", "sum"), ("smallint_value", "smallint", "sum"),
        ("int_value", "int", "sum"), ("bigint_value", "bigint", "sum"),
        ("char_50_value", "char(50)", "replace"),
        ("varchar_value", "varchar(500)", "replace"),
        ("char_value", "char", "replace"),
        ("varchar_most_value", "varchar(65533)", "replace"),
        ("decimal_value", "decimal(20, 6)", "sum"),
        ("decimal_most_value", "decimal(27, 9)", "sum"),
        ("date_value_max", "date", "max"),
        ("date_value_replace", "date", "replace"),
        ("date_value_min", "date", "min"),
        ("datetime_value_replace", "datetime", "replace"),
        ("datetime_value_max", "datetime", "replace"),
        ("datetime_value_min", "datetime", "replace"),
        ("float_value", "float", "sum"),
        ("double_value", "double", "sum")
    ]

all_type_column_name_list = ['tinyint_key', 'smallint_key', 'int_key', 'bigint_key',
                             'char_50_key', 'varchar_key', 'char_key', 'varchar_most_key',
                             'decimal_key', 'deciaml_most_key', 'date_key', 'datetime_key']

partition_column_list = [('k1', 'TINYINT'),
            ('k2', 'SMALLINT'),
            ('k3', 'INT'),
            ('k4', 'BIGINT'),
            ('k5', 'DATETIME'),
            ('v1', 'DATE', 'REPLACE'),
            ('v2', 'CHAR', 'REPLACE'),
            ('v3', 'VARCHAR(4096)', 'REPLACE'),
            ('v4', 'FLOAT', 'SUM'),
            ('v5', 'DOUBLE', 'SUM'),
            ('v6', 'DECIMAL(20,7)', 'SUM')]

partition_column_list_parse = [('k1', 'TINYINT'),
            ('k2', 'SMALLINT'),
            ('k3', 'INT'),
            ('k4', 'BIGINT'),
            ('k5_t', 'DATETIME'),
            ('v1', 'DATE', 'REPLACE'),
            ('v2', 'CHAR', 'REPLACE'),
            ('v3', 'VARCHAR(4096)', 'REPLACE'),
            ('v4', 'FLOAT', 'SUM'),
            ('v5', 'DOUBLE', 'SUM'),
            ('v6', 'DECIMAL(20,7)', 'SUM')]

partition_column_no_agg_list = [('k1', 'TINYINT'),
            ('k2', 'SMALLINT'),
            ('k3', 'INT'),
            ('k4', 'BIGINT'),
            ('k5', 'DATETIME'),
            ('v1', 'DATE'),
            ('v2', 'CHAR'),
            ('v3', 'VARCHAR(4096)'),
            ('v4', 'FLOAT'),
            ('v5', 'DOUBLE'),
            ('v6', 'DECIMAL(20,7)')]

partition_column_name_list = ['k1', 'k2', 'k3', 'k4', 'k5', 'v1', 'v2', 'v3', 'v4', 'v5', 'v6']

tinyint_column_list = [("k1", "TINYINT"),
        ("v1", "TINYINT", "SUM"),
        ("v2", "TINYINT", "MAX"),
        ("v3", "TINYINT", "MIN"),
        ("v4", "TINYINT", "REPLACE")]

tinyint_column_no_agg_list = [("k1", "TINYINT"),
                              ("v1", "TINYINT"), 
                              ("v2", "TINYINT"),
                              ("v3", "TINYINT"),
                              ("v4", "TINYINT")]

smallint_column_list = [("k1", "SMALLINT"),
        ("v1", "SMALLINT", "SUM"),
        ("v2", "SMALLINT", "MAX"),
        ("v3", "SMALLINT", "MIN"),
        ("v4", "SMALLINT", "REPLACE")]

smallint_column_no_agg_list = [("k1", "SMALLINT"),
                               ("v1", "SMALLINT"),
                               ("v2", "SMALLINT"),
                               ("v3", "SMALLINT"),
                               ("v4", "SMALLINT")]

int_column_list = [("k1", "INT"),
        ("v1", "INT", "SUM"),
        ("v2", "INT", "MAX"),
        ("v3", "INT", "MIN"),
        ("v4", "INT", "REPLACE")]

int_column_no_agg_list = [("k1", "INT"),
                              ("v1", "INT"),
                              ("v2", "INT"),
                              ("v3", "INT"),
                              ("v4", "INT")]

bigint_column_list = [("k1", "BIGINT"),
        ("v1", "BIGINT", "SUM"),
        ("v2", "BIGINT", "MAX"),
        ("v3", "BIGINT", "MIN"),
        ("v4", "BIGINT", "REPLACE")]

bigint_column_no_agg_list = [("k1", "BIGINT"),
                      ("v1", "BIGINT"),
                      ("v2", "BIGINT"),
                      ("v3", "BIGINT"),
                      ("v4", "BIGINT")]

largeint_column_list = [("k1", "LARGEINT"),
        ("v1", "LARGEINT", "SUM"),
        ("v2", "LARGEINT", "MAX"),
        ("v3", "LARGEINT", "MIN"),
        ("v4", "LARGEINT", "REPLACE")]

largeint_column_no_agg_list = [("k1", "LARGEINT"),
                        ("v1", "LARGEINT"),
                        ("v2", "LARGEINT"),
                        ("v3", "LARGEINT"),
                        ("v4", "LARGEINT")]

float_column_list = [("k1", "INT"),
        ("v1", "FLOAT", "SUM"),
        ("v2", "FLOAT", "MAX"),
        ("v3", "FLOAT", "MIN"),
        ("v4", "FLOAT", "REPLACE")]

float_column_no_agg_list = [("k1", "INT"),
        ("v1", "FLOAT"),
        ("v2", "FLOAT"),
        ("v3", "FLOAT"),
        ("v4", "FLOAT")]

double_column_list = [("k1", "INT"),
        ("v1", "DOUBLE", "SUM"),
        ("v2", "DOUBLE", "MAX"),
        ("v3", "DOUBLE", "MIN"),
        ("v4", "DOUBLE", "REPLACE")]

double_column_no_agg_list = [("k1", "INT"),
        ("v1", "DOUBLE"),
        ("v2", "DOUBLE"),
        ("v3", "DOUBLE"),
        ("v4", "DOUBLE")]

decimal_least_column_list = [("k1", "DECIMAL(1, 0)"),
        ("v1", "DECIMAL(1, 0)", "SUM"),
        ("v2", "DECIMAL(1, 0)", "MAX"),
        ("v3", "DECIMAL(1, 0)", "MIN"),
        ("v4", "DECIMAL(1, 0)", "REPLACE")]

decimal_least_column_no_agg_list = [("k1", "DECIMAL(1, 0)"),
                             ("v1", "DECIMAL(1, 0)"),
                             ("v2", "DECIMAL(1, 0)"),
                             ("v3", "DECIMAL(1, 0)"),
                             ("v4", "DECIMAL(1, 0)")]

decimal_normal_column_list = [("k1", "DECIMAL(10, 5)"),
        ("v1", "DECIMAL(10, 5)", "SUM"),
        ("v2", "DECIMAL(10, 5)", "MAX"),
        ("v3", "DECIMAL(10, 5)", "MIN"),
        ("v4", "DECIMAL(10, 5)", "REPLACE")]

decimal_normal_column_no_agg_list = [("k1", "DECIMAL(10, 5)"),
                              ("v1", "DECIMAL(10, 5)"),
                              ("v2", "DECIMAL(10, 5)"),
                              ("v3", "DECIMAL(10, 5)"),
                              ("v4", "DECIMAL(10, 5)")]

decimal_most_column_list = [("k1", "DECIMAL(27, 9)"),
        ("v1", "DECIMAL(27, 9)", "SUM"),
        ("v2", "DECIMAL(27, 9)", "MAX"),
        ("v3", "DECIMAL(27, 9)", "MIN"),
        ("v4", "DECIMAL(27, 9)", "REPLACE")]

decimal_most_column_no_agg_list = [("k1", "DECIMAL(27, 9)"),
                            ("v1", "DECIMAL(27, 9)"),
                            ("v2", "DECIMAL(27, 9)"),
                            ("v3", "DECIMAL(27, 9)"),
                            ("v4", "DECIMAL(27, 9)")]

date_column_list = [("k1", "DATE"),
        ("v1", "DATE", "REPLACE"),
        ("v2", "DATE", "MAX"),
        ("v3", "DATE", "MIN")]

date_column_no_agg_list = [("k1", "DATE"),
                    ("v1", "DATE"),
                    ("v2", "DATE"),
                    ("v3", "DATE")]

datetime_column_list = [("k1", "DATETIME"),
        ("v1", "DATETIME", "REPLACE"),
        ("v2", "DATETIME", "MAX"),
        ("v3", "DATETIME", "MIN")]

datetime_column_no_agg_list = [("k1", "DATETIME"),
                        ("v1", "DATETIME"),
                        ("v2", "DATETIME"),
                        ("v3", "DATETIME")]

char_least_column_list = [("k1", "CHAR"),
        ("v1", "CHAR", "REPLACE")]

char_least_column_no_agg_list = [("k1", "CHAR"),
        ("v1", "CHAR")]

char_normal_column_list = [("k1", "CHAR(20)"),
        ("v1", "CHAR(20)", "REPLACE")]

char_normal_column_no_agg_list = [("k1", "CHAR(20)"),
        ("v1", "CHAR(20)")]

char_most_column_list = [("k1", "CHAR(255)"),
        ("v1", "CHAR(255)", "REPLACE")]

char_most_column_no_agg_list = [("k1", "CHAR(255)"),
        ("v1", "CHAR(255)")]

varchar_least_column_list = [("k1", "VARCHAR(1)"),
        ("v1", "VARCHAR(1)", "REPLACE")]

varchar_least_column_no_agg_list = [("k1", "VARCHAR(1)"),
        ("v1", "VARCHAR(1)")]

varchar_normal_column_list = [("k1", "VARCHAR(200)"),
        ("v1", "VARCHAR(200)", "REPLACE")]

varchar_normal_column_no_agg_list = [("k1", "VARCHAR(200)"),
        ("v1", "VARCHAR(200)")]

varchar_most_column_list = [("k1", "VARCHAR(65533)"),
        ("v1", "VARCHAR(65533)", "REPLACE")]

varchar_most_column_no_agg_list = [("k1", "VARCHAR(65533)"),
        ("v1", "VARCHAR(65533)")]

string_column_list = [("k1", "VARCHAR(65535)"),
                      ("v1", "STRING", "REPLACE"),
                      ("v2", "STRING", "MAX"),
                      ("v3", "STRING", "MIN")]

string_column_no_agg_list = [("k1", "VARCHAR(65535)"),
                             ("v1", "STRING")]

json_column_no_agg_list = [("k1", "INT"),
                           ("k2", "CHAR(20)"),
                           ("k3", "double")]

hll_tinyint_column_list = [('k1', 'TINYINT'), ('v1', 'HLL', 'HLL_UNION'), ('v2', 'int', 'SUM')]
hll_smallint_column_list = [('k1', 'SMALLINT'), ('v1', 'HLL', 'HLL_UNION'), ('v2', 'int', 'SUM')]
hll_int_column_list = [('k1', 'INT'), ('v1', 'HLL', 'HLL_UNION'), ('v2', 'int', 'SUM')]
hll_bigint_column_list = [('k1', 'BIGINT'), ('v1', 'HLL', 'HLL_UNION'), ('v2', 'int', 'SUM')]
hll_largeint_column_list = [('k1', 'LARGEINT'), ('v1', 'HLL', 'HLL_UNION'), ('v2', 'int', 'SUM')]
hll_char_column_list = [('k1', 'CHAR(20)'), ('v1', 'HLL', 'HLL_UNION'), ('v2', 'int', 'SUM')]
hll_varchar_column_list = [('k1', 'VARCHAR(1)'), ('v1', 'HLL', 'HLL_UNION'), ('v2', 'int', 'SUM')]
hll_date_column_list = [('k1', 'DATE'), ('v1', 'HLL', 'HLL_UNION'), ('v2', 'int', 'SUM')]
hll_datetime_column_list = [('k1', 'DATETIME'), ('v1', 'HLL', 'HLL_UNION'), ('v2', 'int', 'SUM')]
hll_decimal_column_list = [('k1', 'DECIMAL(10, 5)'), ('v1', 'HLL', 'HLL_UNION'), 
                           ('v2', 'int', 'SUM')]

bitmap_int_column_list = [('k1', 'INT'), ('v1', 'BITMAP', 'BITMAP_UNION'), ('v2', 'int', 'SUM')]

hash_distribution_info = DistributionInfo("HASH(k1)", 15)
aggregate_key = "AGGREGATE KEY(k1)"
duplicate_key = "DUPLICATE KEY(k1)"
unique_key = "UNIQUE KEY(k1)"

types_kv_column_list = [('k1', 'TINYINT'), \
            ('k2', 'SMALLINT'), \
            ('k3', 'INT'), \
            ('k4', 'BIGINT'), \
            ('k5', 'LARGEINT'), \
            ('k6', 'DATE'), \
            ('k7', 'DATETIME'), \
            ('k8', 'CHAR(3)'), \
            ('k9', 'VARCHAR(10)'), \
            ('k10', 'DECIMAL(5,3)'), \
            ('v1', 'TINYINT', 'SUM'), \
            ('v2', 'SMALLINT', 'SUM'), \
            ('v3', 'INT', 'SUM'), \
            ('v4', 'BIGINT', 'SUM'), \
            ('v5', 'LARGEINT', 'SUM'), \
            ('v6', 'DATETIME', 'REPLACE'), \
            ('v7', 'DATE', 'REPLACE'), \
            ('v8', 'CHAR(10)', 'REPLACE'), \
            ('v9', 'VARCHAR(6)', 'REPLACE'), \
            ('v10', 'DECIMAL(27,9)', 'SUM')]

types_kv_column_no_agg_list = [('k1', 'TINYINT'), \
            ('k2', 'SMALLINT'), \
            ('k3', 'INT'), \
            ('k4', 'BIGINT'), \
            ('k5', 'LARGEINT'), \
            ('k6', 'DATE'), \
            ('k7', 'DATETIME'), \
            ('k8', 'CHAR(3)'), \
            ('k9', 'VARCHAR(10)'), \
            ('k10', 'DECIMAL(5,3)'), \
            ('v1', 'TINYINT'), \
            ('v2', 'SMALLINT'), \
            ('v3', 'INT'), \
            ('v4', 'BIGINT'), \
            ('v5', 'LARGEINT'), \
            ('v6', 'DATETIME'), \
            ('v7', 'DATE'), \
            ('v8', 'CHAR(10)'), \
            ('v9', 'VARCHAR(6)'), \
            ('v10', 'DECIMAL(27,9)')]
types_kv_aggregate_key = "AGGREGATE KEY(k1, k2, k3, k4, k5, k6, k7, k8, k9, k10)"
types_kv_duplicate_key = "DUPLICATE KEY(k1, k2, k3, k4, k5, k6, k7, k8, k9, k10)"
types_kv_unique_key = "UNIQUE KEY(k1, k2, k3, k4, k5, k6, k7, k8, k9, k10)"

storage_type = "column"

sandbox_column_list =  [('k0', 'TINYINT'),
                        ('k1', 'SMALLINT'),
                        ('k2', 'INT'),
                        ('k3', 'BIGINT'),
                        ('k4', 'LARGEINT'),
                        ('k5', 'decimal(9, 3)'),
                        ('k6', 'char(19)'),
                        ('k7', 'varchar(50)'),
                        ('k8', 'date'),
                        ('k9', 'datetime'),
                        ('v11', 'double', 'max'),
                        ('v12', 'float', 'sum'),
                        ('v13', 'int', 'min'),
                        ('v14', 'smallint', 'replace'),
                        ('v15', 'int', 'sum')]

sandbox_partition_key = 'k0'
sandbox_partition_name_list = ['pa', 'pb', 'pc', 'pd', 'pe', 'pf']
sandbox_partition_value_list = ['-50', '0', '32', '64', '96', 'MAXVALUE']
sandbox_partition_info = PartitionInfo(sandbox_partition_key,
                                       sandbox_partition_name_list,
                                       sandbox_partition_value_list)
sandbox_distribution_info = DistributionInfo('HASH(k2)', 5)

timestamp_convert_column_list = [('k1', 'BIGINT'),
                             ('k2', 'BIGINT'),
                             ('k3', 'BIGINT'),
                             ('k4', 'BIGINT')]

timestamp2timestamp_column_list = [('k1', 'DATETIME'),
                                   ('k2', 'BIGINT', 'MAX'),
                                   ('k3', 'BIGINT', 'MIN'),
                                   ('k4', 'BIGINT', 'REPLACE')]

date_format_column_list = [('k1', 'DATETIME'),
                           ('k2', 'DATETIME'),
                           ('k3', 'DATETIME'),
                           ('k4', 'DATETIME')]

md5_colmn_list = [('k1', 'BIGINT'),
                  ('k2', 'BIGINT'),
                  ('k3', 'BIGINT'),
                  ('k4', 'BIGINT'),
                  ('k5', 'CHAR(64)')]

replace_if_not_null_column_list = [('k1', 'BIGINT'),
                                   ('k2', 'BIGINT'),
                                   ('v1', 'TINYINT', 'SUM'),
                                   ('v2', 'TINYINT', 'REPLACE'),
                                   ('v3', 'TINYINT', 'REPLACE_IF_NOT_NULL'),
                                   ('v4', 'SMALLINT', 'REPLACE_IF_NOT_NULL'),
                                   ('v5', 'INT', 'REPLACE_IF_NOT_NULL'),
                                   ('v6', 'BIGINT', 'REPLACE_IF_NOT_NULL'),
                                   ('v7', 'LARGEINT', 'REPLACE_IF_NOT_NULL'),
                                   ('v8', 'DATETIME', 'REPLACE_IF_NOT_NULL'),
                                   ('v9', 'DATE', 'REPLACE_IF_NOT_NULL'),
                                   ('v10', 'CHAR(10)', 'REPLACE_IF_NOT_NULL'),
                                   ('v11', 'VARCHAR(6)', 'REPLACE_IF_NOT_NULL'),
                                   ('v12', 'DECIMAL(27,9)', 'REPLACE_IF_NOT_NULL')]

replace_if_not_null_no_agg_column_list = [('k1', 'BIGINT'),
                                   ('k2', 'BIGINT'),
                                   ('v1', 'TINYINT'),
                                   ('v2', 'TINYINT', 'REPLACE'),
                                   ('v3', 'TINYINT', 'REPLACE_IF_NOT_NULL'),
                                   ('v4', 'SMALLINT', 'REPLACE_IF_NOT_NULL'),
                                   ('v5', 'INT', 'REPLACE_IF_NOT_NULL'),
                                   ('v6', 'BIGINT', 'REPLACE_IF_NOT_NULL'),
                                   ('v7', 'LARGEINT', 'REPLACE_IF_NOT_NULL'),
                                   ('v8', 'DATETIME', 'REPLACE_IF_NOT_NULL'),
                                   ('v9', 'DATE', 'REPLACE_IF_NOT_NULL'),
                                   ('v10', 'CHAR(10)', 'REPLACE_IF_NOT_NULL'),
                                   ('v11', 'VARCHAR(6)', 'REPLACE_IF_NOT_NULL'),
                                   ('v12', 'DECIMAL(27,9)', 'REPLACE_IF_NOT_NULL')]

boolean_column_list = [('k1', 'BOOLEAN'),
                       ('k2', 'INT'),
                       ('v1', 'BOOLEAN', 'REPLACE'),
                       ('v2', 'BOOLEAN', 'REPLACE_IF_NOT_NULL')]

boolean_column_no_agg_list = [('k1', 'BOOLEAN'),
                              ('k2', 'INT'),
                              ('v1', 'BOOLEAN')]

boolean_aggregate_key = "AGGREGATE KEY(k1, k2)"
boolean_duplicate_key = "DUPLICATE KEY(k1, k2)"
boolean_unique_key = "UNIQUE KEY(k1, k2)"
boolean_distribution_info = DistributionInfo('HASH(k1, k2)', 10)

datatype_column_list = [("k0", "BOOLEAN"),
                        ("k1", "TINYINT"),
                        ("k2", "SMALLINT"),
                        ("k3", "INT"),
                        ("k4", "BIGINT"),
                        ("k5", "LARGEINT"),
                        ("k6", "DECIMALV3(9,3)"),
                        ("k7", "CHAR(5)"),
                        ("k8", "DATE"),
                        ("k9", "DATETIME"),
                        ("k10", "VARCHAR(20)"),
                        ("k11", "DOUBLE", "max"),
                        ("k12", "FLOAT", "sum"),
                        ("k13", "HLL", "hll_union"),
                        ("k14", "BITMAP", "bitmap_union")]

datatype_column_no_agg_list  = [("k0", "BOOLEAN"),
                                ("k1", "TINYINT"),
                                ("k2", "SMALLINT"),
                                ("k3", "INT"),
                                ("k4", "BIGINT"),
                                ("k5", "LARGEINT"),
                                ("k6", "DECIMALV3(9, 3)"),
                                ("k7", "CHAR(5)"),
                                ("k8", "DATE"),
                                ("k9", "DATETIME"),
                                ("k10", "VARCHAR(20)"),
                                ("k11", "DOUBLE"),
                                ("k12", "FLOAT")]

datatype_column_uniq_key = "UNIQUE KEY(k0, k1, k2, k3, k4, k5, k6)"

string_basic = [("id", "INT"), ("doc", "STRING", "REPLACE")]

baseall_string_column_list = [("k1", "tinyint"),
                       ("k2", "smallint"),
                       ("k3", "int"),
                       ("k4", "bigint"),
                       ("k5", "decimalv3(9, 3)"),
                       ("k6", "char(5)"),
                       ("k10", "date"),
                       ("k11", "datetime"),
                       ("k7", "string", "replace"),
                       ("k8", "double", "max"),
                       ("k9", "float", "sum")]

baseall_string_no_agg_column_list = [
                       ("k1", "tinyint"),
                       ("k2", "smallint"),
                       ("k3", "int"),
                       ("k4", "bigint"),
                       ("k5", "decimal(9, 3)"),
                       ("k6", "char(5)"),
                       ("k10", "date"),
                       ("k11", "datetime"),
                       ("k7", "string"),
                       ("k8", "double"),
                       ("k9", "float")]


stable_column_list = [("k0", "int"),
                      ("k1", "tinyint"),
                       ("k2", "smallint"),
                       ("k3", "int"),
                       ("k4", "bigint"),
                       ("k5", "decimal(9, 3)"),
                       ("k6", "char(5)"),
                       ("k10", "date"),
                       ("k11", "datetime"),
                       ("k7", "varchar(20)"),
                       ("k8", "double", "max"),
                       ("k9", "float", "sum")]

# key_desc = duplicate_key
array_boolean_list = [("k1", "int"), ("k2", "array<boolean>")]
array_tinyint_list = [("k1", "int"), ("k2", "array<tinyint>")]
array_smallint_list = [("k1", "int"), ("k2", "array<smallint>")]
array_int_list = [("k1", "int"), ("k2", "array<int>")]
array_bigint_list = [("k1", "int"), ("k2", "array<bigint>")]
array_largeint_list = [("k1", "int"), ("k2", "array<largeint>")]
array_decimal_list = [("k1", "int"), ("k2", "array<decimal(27, 9)>")]
array_float_list = [("k1", "int"), ("k2", "array<float>")]
array_double_list = [("k1", "int"), ("k2", "array<double>")]
array_date_list = [("k1", "int"), ("k2", "array<date>")]
array_datetime_list = [("k1", "int"), ("k2", "array<datetime>")]
array_char_list = [("k1", "int"), ("k2", "array<char(50)>")]
array_varchar_list = [("k1", "int"), ("k2", "array<varchar(300)>")]
array_string_list = [("k1", "int"), ("k2", "array<string>")]
array_table_list = [("k1", "int"),
                    ("a1", "array<boolean>"),
                    ("a2", "array<tinyint>"),
                    ("a3", "array<smallint>"),
                    ("a4", "array<int>"),
                    ("a5", "array<bigint>"),
                    ("a6", "array<largeint>"),
                    ("a7", "array<decimal(27, 9)>"),
                    ("a8", "array<float>"),
                    ("a9", "array<double>"),
                    ("a10", "array<date>"),
                    ("a11", "array<datetime>"),
                    ("a12", "array<char(20)>"),
                    ("a13", "array<varchar(50)>"),
                    ("a14", "array<string>")]