Function create_table

benchmarks/src/main/python/insert_bench.py:29–38

(pool)

async def create_table(pool):
    async with pool.acquire() as conn:
        await conn.execute('''
            CREATE TABLE IF NOT EXISTS user_data (
                name SYMBOL,
                email VARCHAR,
                age LONG,
                created_at TIMESTAMP
            ) timestamp(created_at) partition by hour;
        ''')


def generate_test_data(num_records):