| 379 | return 15000 |
| 380 | |
| 381 | def setup(self): |
| 382 | execute_sql(self.host, self.port, f"DROP TABLE IF EXISTS {self.table_name}") |
| 383 | execute_sql(self.host, self.port, f""" |
| 384 | CREATE TABLE {self.table_name} ( |
| 385 | sym SYMBOL, |
| 386 | ts TIMESTAMP |
| 387 | ) TIMESTAMP(ts) PARTITION BY DAY BYPASS WAL |
| 388 | """) |
| 389 | execute_sql(self.host, self.port, f""" |
| 390 | INSERT INTO {self.table_name} |
| 391 | SELECT |
| 392 | CASE WHEN x % 10 = 0 THEN NULL ELSE rnd_symbol('A','B','C') END as sym, |
| 393 | timestamp_sequence('2024-01-01', 1000000) as ts |
| 394 | FROM long_sequence({self.expected_row_count}) |
| 395 | """) |
| 396 | |
| 397 | def run(self) -> bool: |
| 398 | """Override run to verify symbol column null count statistics.""" |