Edit C:\dspace\webapps\rest\WEB-INF\lib\org\apache\lucene\index\TrackingConcurrentMergeScheduler.class
???? 3 ? 8org/apache/lucene/index/TrackingConcurrentMergeScheduler 0org/apache/lucene/index/ConcurrentMergeScheduler %TrackingConcurrentMergeScheduler.java ,org/apache/lucene/index/MergePolicy$OneMerge #org/apache/lucene/index/MergePolicy OneMerge logger +Lorg/elasticsearch/common/logging/ESLogger; totalMerges -Lorg/elasticsearch/common/metrics/MeanMetric; totalMergesNumDocs 0Lorg/elasticsearch/common/metrics/CounterMetric; totalMergesSizeInBytes currentMerges currentMergesNumDocs currentMergesSizeInBytes onGoingMerges Ljava/util/Set; =Ljava/util/Set<Lorg/elasticsearch/index/merge/OnGoingMerge;>; readOnlyOnGoingMerges <init> .(Lorg/elasticsearch/common/logging/ESLogger;)V ()V +org/elasticsearch/common/metrics/MeanMetric ! .org/elasticsearch/common/metrics/CounterMetric # $ & ( * , . >org/elasticsearch/common/util/concurrent/ConcurrentCollections 0 newConcurrentSet ()Ljava/util/Set; 2 3 1 4 6 java/util/Collections 8 unmodifiableSet (Ljava/util/Set;)Ljava/util/Set; : ; 9 < > @ this :Lorg/apache/lucene/index/TrackingConcurrentMergeScheduler; ()J count E D F totalMergeTime sum I D J totalMergeNumDocs $ F totalMergeSizeInBytes doMerge 1(Lorg/apache/lucene/index/MergePolicy$OneMerge;)V java/io/IOException Q totalNumDocs ()I S T U totalBytesSize W D X java/lang/System Z currentTimeMillis \ D [ ] inc _ $ ` (J)V _ b $ c *org/elasticsearch/index/merge/OnGoingMerge e P f g java/util/Set i add (Ljava/lang/Object;)Z k l j m )org/elasticsearch/common/logging/ESLogger o isTraceEnabled ()Z q r p s ]merge [{}] starting..., merging [{}] segments, [{}] docs, [{}] size, into [{}] estimated_size u java/lang/Object w info +Lorg/apache/lucene/index/SegmentCommitInfo; y z { _na_ } java/lang/String [Ljava/lang/Object; ? )org/apache/lucene/index/SegmentCommitInfo ? %Lorg/apache/lucene/index/SegmentInfo; y ? ? ? #org/apache/lucene/index/SegmentInfo ? name Ljava/lang/String; ? ? ? ? segments Ljava/util/List; ? ? ? java/util/List ? size ? T ? ? java/lang/Integer ? valueOf (I)Ljava/lang/Integer; ? ? ? ? +org/elasticsearch/common/unit/ByteSizeValue ? b ? ? estimatedMergeBytes J ? ? ? trace ((Ljava/lang/String;[Ljava/lang/Object;)V ? ? p ? beforeMerge /(Lorg/elasticsearch/index/merge/OnGoingMerge;)V ? ? ? O P ? remove ? l j ? afterMerge ? ? ? dec ? $ ? ? b $ ? c N merge [{}] done, took [{}] ? 'org/elasticsearch/common/unit/TimeValue ? timeValueMillis ,(J)Lorg/elasticsearch/common/unit/TimeValue; ? ? ? ? debug ? ? p ? java/lang/Throwable ? took merge .Lorg/apache/lucene/index/MergePolicy$OneMerge; I totalSizeInBytes time onGoingMerge ,Lorg/elasticsearch/index/merge/OnGoingMerge; clone *()Lorg/apache/lucene/index/MergeScheduler; ()Ljava/lang/Object; $java/lang/CloneNotSupportedException ? ? ? ? Signature Code LocalVariableTable LineNumberTable ?()Ljava/util/Set<Lorg/elasticsearch/index/merge/OnGoingMerge;>; StackMapTable Exceptions SourceFile InnerClasses ! ? ? ? ? ^*? *? Y? ? "*? $Y? %? '*? $Y? %? )*? $Y? %? +*? $Y? %? -*? $Y? %? /*? 5? 7**? 7? =? ?*+? A? ? ^ B C ^ ? . 5 * + , % - 0 . ; / F 1 M 2 X 6 ] 7 D ? 2 *? "? G? ? B C ? : H D ? 2 *? "? K? ? B C ? >