hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

print sampled block count under ENABLE_DEBUG_LOG compile mode

Browse Source
This commit is contained in:
saltonz
2023-11-30 11:42:26 +00:00
committed by ob-robot
parent acde64f198
commit ee3e45fb17
2 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/storage/access/ob_block_sample_iterator.cpp
View File

@ -616,6 +616,7 @@ ObBlockSampleIterator::ObBlockSampleIterator(const SampleInfo &sample_info)
read_info_(nullptr),
scan_merge_(nullptr),
block_num_(0),
sample_block_cnt_(0),
range_allocator_(),
range_iterator_(),
micro_range_(),
@ -630,6 +631,7 @@ ObBlockSampleIterator::~ObBlockSampleIterator()
void ObBlockSampleIterator::reuse()
{
block_num_ = 0;
sample_block_cnt_ = 0;
range_allocator_.reuse();
range_iterator_.reset();
micro_range_.reset();
@ -642,6 +644,7 @@ void ObBlockSampleIterator::reset()
read_info_ = nullptr;
scan_merge_ = nullptr;
block_num_ = 0;
sample_block_cnt_ = 0;
range_allocator_.reset();
range_iterator_.reset();
micro_range_.reset();
@ -697,6 +700,7 @@ int ObBlockSampleIterator::get_next_row(blocksstable::ObDatumRow *&row)
STORAGE_LOG(WARN, "range is null", K(ret), K(block_num_));
} else if (return_this_sample(block_num_++)) {
STORAGE_LOG(DEBUG, "open a range", K(*range), K_(block_num));
++sample_block_cnt_;
micro_range_.reset();
micro_range_ = *range;
if (OB_FAIL(open_range(micro_range_))) {
@ -708,6 +712,11 @@ int ObBlockSampleIterator::get_next_row(blocksstable::ObDatumRow *&row)
if (OB_FAIL(ret) && OB_ITER_END != ret) {
STORAGE_LOG(WARN, "failed to get next row from ObBlockSampleIterator", K(ret), K(block_num_));
}
#ifdef ENABLE_DEBUG_LOG
if (OB_ITER_END == ret) {
STORAGE_LOG(INFO, "block sample scan finish", K(ret), K_(sample_block_cnt), K_(block_num), KPC_(sample_info));
}
#endif
}
return ret;

1
src/storage/access/ob_block_sample_iterator.h
View File

@ -166,6 +166,7 @@ private:
const ObITableReadInfo *read_info_;
ObMultipleScanMerge *scan_merge_;
int64_t block_num_;
int64_t sample_block_cnt_;
common::ObArenaAllocator range_allocator_;
ObBlockSampleRangeIterator range_iterator_;
blocksstable::ObDatumRange micro_range_;