| 104 | } |
| 105 | |
| 106 | TEST(WorkloadManagementFieldsTest, CheckFieldDefinitions) { |
| 107 | // Asserts FIELD_DEFINITIONS includes one entry for each member of the Thrift |
| 108 | // TQueryTableColumn enum and has correctly defined each column. |
| 109 | ASSERT_EQ(_TQueryTableColumn_VALUES_TO_NAMES.size(), FIELD_DEFINITIONS.size()); |
| 110 | |
| 111 | vector<FieldDefEntry> expected_field_defs = { |
| 112 | _createV100String(TQueryTableColumn::CLUSTER_ID), |
| 113 | _createV100String(TQueryTableColumn::QUERY_ID), |
| 114 | _createV100String(TQueryTableColumn::SESSION_ID), |
| 115 | _createV100String(TQueryTableColumn::SESSION_TYPE), |
| 116 | _createV100String(TQueryTableColumn::HIVESERVER2_PROTOCOL_VERSION), |
| 117 | _createV100String(TQueryTableColumn::DB_USER), |
| 118 | _createV100String(TQueryTableColumn::DB_USER_CONNECTION), |
| 119 | _createV100String(TQueryTableColumn::DB_NAME), |
| 120 | _createV100String(TQueryTableColumn::IMPALA_COORDINATOR), |
| 121 | _createV100String(TQueryTableColumn::QUERY_STATUS), |
| 122 | _createV100String(TQueryTableColumn::QUERY_STATE), |
| 123 | _createV100String(TQueryTableColumn::IMPALA_QUERY_END_STATE), |
| 124 | _createV100String(TQueryTableColumn::QUERY_TYPE), |
| 125 | _createV100String(TQueryTableColumn::NETWORK_ADDRESS), |
| 126 | _createV100Timestamp(TQueryTableColumn::START_TIME_UTC), |
| 127 | _createV100Decimal(TQueryTableColumn::TOTAL_TIME_MS), |
| 128 | _createV100String(TQueryTableColumn::QUERY_OPTS_CONFIG), |
| 129 | _createV100String(TQueryTableColumn::RESOURCE_POOL), |
| 130 | _createV100BigInt(TQueryTableColumn::PER_HOST_MEM_ESTIMATE), |
| 131 | _createV100BigInt(TQueryTableColumn::DEDICATED_COORD_MEM_ESTIMATE), |
| 132 | _createV100String(TQueryTableColumn::PER_HOST_FRAGMENT_INSTANCES), |
| 133 | _createV100Int(TQueryTableColumn::BACKENDS_COUNT), |
| 134 | _createV100String(TQueryTableColumn::ADMISSION_RESULT), |
| 135 | _createV100BigInt(TQueryTableColumn::CLUSTER_MEMORY_ADMITTED), |
| 136 | _createV100String(TQueryTableColumn::EXECUTOR_GROUP), |
| 137 | _createV100String(TQueryTableColumn::EXECUTOR_GROUPS), |
| 138 | _createV100String(TQueryTableColumn::EXEC_SUMMARY), |
| 139 | _createV100BigInt(TQueryTableColumn::NUM_ROWS_FETCHED), |
| 140 | _createV100BigInt(TQueryTableColumn::ROW_MATERIALIZATION_ROWS_PER_SEC), |
| 141 | _createV100Decimal(TQueryTableColumn::ROW_MATERIALIZATION_TIME_MS), |
| 142 | _createV100BigInt(TQueryTableColumn::COMPRESSED_BYTES_SPILLED), |
| 143 | _createV100Decimal(TQueryTableColumn::EVENT_PLANNING_FINISHED), |
| 144 | _createV100Decimal(TQueryTableColumn::EVENT_SUBMIT_FOR_ADMISSION), |
| 145 | _createV100Decimal(TQueryTableColumn::EVENT_COMPLETED_ADMISSION), |
| 146 | _createV100Decimal(TQueryTableColumn::EVENT_ALL_BACKENDS_STARTED), |
| 147 | _createV100Decimal(TQueryTableColumn::EVENT_ROWS_AVAILABLE), |
| 148 | _createV100Decimal(TQueryTableColumn::EVENT_FIRST_ROW_FETCHED), |
| 149 | _createV100Decimal(TQueryTableColumn::EVENT_LAST_ROW_FETCHED), |
| 150 | _createV100Decimal(TQueryTableColumn::EVENT_UNREGISTER_QUERY), |
| 151 | _createV100Decimal(TQueryTableColumn::READ_IO_WAIT_TOTAL_MS), |
| 152 | _createV100Decimal(TQueryTableColumn::READ_IO_WAIT_MEAN_MS), |
| 153 | _createV100BigInt(TQueryTableColumn::BYTES_READ_CACHE_TOTAL), |
| 154 | _createV100BigInt(TQueryTableColumn::BYTES_READ_TOTAL), |
| 155 | _createV100BigInt(TQueryTableColumn::PERNODE_PEAK_MEM_MIN), |
| 156 | _createV100BigInt(TQueryTableColumn::PERNODE_PEAK_MEM_MAX), |
| 157 | _createV100BigInt(TQueryTableColumn::PERNODE_PEAK_MEM_MEAN), |
| 158 | _createV100String(TQueryTableColumn::SQL), |
| 159 | _createV100String(TQueryTableColumn::PLAN), |
| 160 | _createV100String(TQueryTableColumn::TABLES_QUERIED), |
| 161 | _createV110String(TQueryTableColumn::SELECT_COLUMNS), |
| 162 | _createV110String(TQueryTableColumn::WHERE_COLUMNS), |
| 163 | _createV110String(TQueryTableColumn::JOIN_COLUMNS), |
nothing calls this directly
no test coverage detected