| 2439 | self._aggregate_results() |
| 2440 | |
| 2441 | def _aggregate_results(self): |
| 2442 | m = self.keyspace_table_rows |
| 2443 | for row in self.tables_result: |
| 2444 | m[row["keyspace_name"]].append(row) |
| 2445 | |
| 2446 | m = self.keyspace_table_col_rows |
| 2447 | for row in self.columns_result: |
| 2448 | ksname = row["keyspace_name"] |
| 2449 | cfname = row[self._table_name_col] |
| 2450 | m[ksname][cfname].append(row) |
| 2451 | |
| 2452 | m = self.keyspace_type_rows |
| 2453 | for row in self.types_result: |
| 2454 | m[row["keyspace_name"]].append(row) |
| 2455 | |
| 2456 | m = self.keyspace_func_rows |
| 2457 | for row in self.functions_result: |
| 2458 | m[row["keyspace_name"]].append(row) |
| 2459 | |
| 2460 | m = self.keyspace_agg_rows |
| 2461 | for row in self.aggregates_result: |
| 2462 | m[row["keyspace_name"]].append(row) |
| 2463 | |
| 2464 | m = self.keyspace_table_trigger_rows |
| 2465 | for row in self.triggers_result: |
| 2466 | ksname = row["keyspace_name"] |
| 2467 | cfname = row[self._table_name_col] |
| 2468 | m[ksname][cfname].append(row) |
| 2469 | |
| 2470 | @staticmethod |
| 2471 | def _schema_type_to_cql(type_string): |