Add counter for nimble and dwrf writer

skyelves · facebook-github-bot · commit 3c590e428061 · 2025-09-10T19:58:25.000-07:00
Summary: [feat] Add counter for nimble and dwrf writer

Differential Revision: D82173341
diff --git a/velox/dwio/dwrf/writer/Writer.cpp b/velox/dwio/dwrf/writer/Writer.cpp
@@ -903,6 +903,7 @@ std::unique_ptr<dwio::common::Writer> DwrfWriterFactory::createWriter(
   auto dwrfOptions = std::dynamic_pointer_cast<dwrf::WriterOptions>(options);
   VELOX_CHECK_NOT_NULL(
       dwrfOptions, "DWRF writer factory expected a DWRF WriterOptions object.");
+  addThreadLocalRuntimeStat("dwrfWriterCount", RuntimeCounter(1));
   return std::make_unique<Writer>(std::move(sink), *dwrfOptions);
 }
 

Original file line number	Diff line number	Diff line change
`@@ -903,6 +903,7 @@ std::unique_ptr<dwio::common::Writer> DwrfWriterFactory::createWriter(`
`903`	`903`	`auto dwrfOptions = std::dynamic_pointer_cast<dwrf::WriterOptions>(options);`
`904`	`904`	`VELOX_CHECK_NOT_NULL(`
`905`	`905`	`dwrfOptions, "DWRF writer factory expected a DWRF WriterOptions object.");`
	`906`	`+ addThreadLocalRuntimeStat("dwrfWriterCount", RuntimeCounter(1));`
`906`	`907`	`return std::make_unique<Writer>(std::move(sink), *dwrfOptions);`
`907`	`908`	`}`
`908`	`909`