| 228 | } |
| 229 | |
| 230 | void recordInterOpStats( |
| 231 | bytedance::bolt::exec::Operator& op, |
| 232 | const InterOpStats& interOpStats) { |
| 233 | auto lockedStats = op.stats().wlock(); |
| 234 | lockedStats->addRuntimeStat( |
| 235 | "exportToArrowArrayNanos", |
| 236 | bytedance::bolt::RuntimeCounter{ |
| 237 | static_cast<int64_t>(interOpStats.exportToArrowArrayTimeNs), |
| 238 | bytedance::bolt::RuntimeCounter::Unit::kNanos}); |
| 239 | lockedStats->addRuntimeStat( |
| 240 | "exportToArrowSchemaNanos", |
| 241 | bytedance::bolt::RuntimeCounter{ |
| 242 | static_cast<int64_t>(interOpStats.exportToArrowSchemaTimeNs), |
| 243 | bytedance::bolt::RuntimeCounter::Unit::kNanos}); |
| 244 | } |
| 245 | |
| 246 | } // namespace bolt::cudf::exec |
no test coverage detected