mirror of
https://github.com/honeymoose/OpenSearch.git
synced 2025-02-17 10:25:15 +00:00
parent
3a2d40acd9
commit
5ad540a1aa
@ -78,7 +78,7 @@ public class TrackingConcurrentMergeScheduler extends ConcurrentMergeScheduler {
|
|||||||
@Override
|
@Override
|
||||||
protected void doMerge(MergePolicy.OneMerge merge) throws IOException {
|
protected void doMerge(MergePolicy.OneMerge merge) throws IOException {
|
||||||
int totalNumDocs = merge.totalNumDocs();
|
int totalNumDocs = merge.totalNumDocs();
|
||||||
long totalSizeInBytes = merge.totalBytesSize();
|
long totalSizeInBytes = merge.estimatedMergeBytes;
|
||||||
long time = System.currentTimeMillis();
|
long time = System.currentTimeMillis();
|
||||||
currentMerges.inc();
|
currentMerges.inc();
|
||||||
currentMergesNumDocs.inc(totalNumDocs);
|
currentMergesNumDocs.inc(totalNumDocs);
|
||||||
|
@ -88,7 +88,7 @@ public class TrackingSerialMergeScheduler extends MergeScheduler {
|
|||||||
writer.mergeInit(merge);
|
writer.mergeInit(merge);
|
||||||
|
|
||||||
int totalNumDocs = merge.totalNumDocs();
|
int totalNumDocs = merge.totalNumDocs();
|
||||||
long totalSizeInBytes = merge.totalBytesSize();
|
long totalSizeInBytes = merge.estimatedMergeBytes;
|
||||||
long time = System.currentTimeMillis();
|
long time = System.currentTimeMillis();
|
||||||
currentMerges.inc();
|
currentMerges.inc();
|
||||||
currentMergesNumDocs.inc(totalNumDocs);
|
currentMergesNumDocs.inc(totalNumDocs);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user