File tree Expand file tree Collapse file tree 2 files changed +3
-0
lines changed
Expand file tree Collapse file tree 2 files changed +3
-0
lines changed Original file line number Diff line number Diff line change @@ -411,8 +411,10 @@ Status PushBrokerReader::init() {
411411 _runtime_profile->set_name (" PushBrokerReader" );
412412
413413 _file_cache_statistics.reset (new io::FileCacheStatistics ());
414+ _file_reader_stats.reset (new io::FileReaderStats ());
414415 _io_ctx.reset (new io::IOContext ());
415416 _io_ctx->file_cache_stats = _file_cache_statistics.get ();
417+ _io_ctx->file_reader_stats = _file_reader_stats.get ();
416418 _io_ctx->query_id = &_runtime_state->query_id ();
417419
418420 auto slot_descs = desc_tbl->get_tuple_descriptor (0 )->slots ();
Original file line number Diff line number Diff line change @@ -136,6 +136,7 @@ class PushBrokerReader {
136136 std::vector<TFileRangeDesc> _file_ranges;
137137
138138 std::unique_ptr<io::FileCacheStatistics> _file_cache_statistics;
139+ std::unique_ptr<io::FileReaderStats> _file_reader_stats;
139140 std::unique_ptr<io::IOContext> _io_ctx;
140141
141142 // col names from _slot_descs
You can’t perform that action at this time.
0 commit comments