| 136 | switch (FLAGS_bolt_trace_replay_shuffle_serialization_format) { |
| 137 | case 0: |
| 138 | return VectorSerde::Kind::kPresto; |
| 139 | case 1: |
| 140 | return VectorSerde::Kind::kCompactRow; |
| 141 | case 2: |
| 142 | return VectorSerde::Kind::kUnsafeRow; |
| 143 | default: |
| 144 | BOLT_UNSUPPORTED( |
| 145 | "Unsupported shuffle serialization format: {}", |
| 146 | static_cast<int>( |
| 147 | FLAGS_bolt_trace_replay_shuffle_serialization_format)); |
| 148 | } |
| 149 | } |
| 150 | |
| 151 | void printTaskMetadata( |
| 152 | const std::string& taskTraceDir, |
| 153 | memory::MemoryPool* pool, |
| 154 | std::ostringstream& oss) { |
| 155 | auto taskMetaReader = std::make_unique<exec::trace::TaskTraceMetadataReader>( |
| 156 | taskTraceDir, pool); |
| 157 | const auto queryConfigs = taskMetaReader->queryConfigs(); |
| 158 | const auto connectorProperties = taskMetaReader->connectorProperties(); |
| 159 | const auto queryPlan = taskMetaReader->queryPlan(); |
| 160 | |
| 161 | oss << "\n++++++Query configs++++++\n"; |
| 162 | for (const auto& queryConfigEntry : queryConfigs) { |
| 163 | oss << "\t" << queryConfigEntry.first << ": " << queryConfigEntry.second |
| 164 | << "\n"; |
| 165 | } |
| 166 | oss << "\n++++++Connector configs++++++\n"; |
no test coverage detected