Edit C:\dspace\webapps\oai\WEB-INF\lib\org\elasticsearch\cluster\metadata\MetaDataMappingService.class
???? 33 9org/elasticsearch/cluster/metadata/MetaDataMappingService 4org/elasticsearch/common/component/AbstractComponent MetaDataMappingService.java Dorg/elasticsearch/cluster/metadata/MetaDataMappingService$UpdateTask UpdateTask Eorg/elasticsearch/cluster/metadata/MetaDataMappingService$RefreshTask RefreshTask Eorg/elasticsearch/cluster/metadata/MetaDataMappingService$MappingTask MappingTask ;org/elasticsearch/cluster/metadata/MetaDataMappingService$4 ;org/elasticsearch/cluster/metadata/MetaDataMappingService$3 ;org/elasticsearch/cluster/metadata/MetaDataMappingService$2 ;org/elasticsearch/cluster/metadata/MetaDataMappingService$1 8org/elasticsearch/cluster/metadata/IndexMetaData$Builder 0org/elasticsearch/cluster/metadata/IndexMetaData Builder java/util/Map$Entry java/util/Map Entry 3org/elasticsearch/cluster/metadata/MetaData$Builder ! +org/elasticsearch/cluster/metadata/MetaData # .org/elasticsearch/cluster/ClusterState$Builder % &org/elasticsearch/cluster/ClusterState ' threadPool )Lorg/elasticsearch/threadpool/ThreadPool; clusterService *Lorg/elasticsearch/cluster/ClusterService; indicesService *Lorg/elasticsearch/indices/IndicesService; refreshOrUpdateMutex Ljava/lang/Object; refreshOrUpdateQueue Ljava/util/List; YLjava/util/List<Lorg/elasticsearch/cluster/metadata/MetaDataMappingService$MappingTask;>; refreshOrUpdateInsertOrder J #refreshOrUpdateProcessedInsertOrder <init> ?(Lorg/elasticsearch/common/settings/Settings;Lorg/elasticsearch/threadpool/ThreadPool;Lorg/elasticsearch/cluster/ClusterService;Lorg/elasticsearch/indices/IndicesService;)V (Lorg/elasticsearch/common/inject/Inject; /(Lorg/elasticsearch/common/settings/Settings;)V 7 : ; java/lang/Object = ()V 7 ? > @ / 0 B java/util/ArrayList D E @ 1 2 G ) * I + , K - . M this ;Lorg/elasticsearch/cluster/metadata/MetaDataMappingService; settings ,Lorg/elasticsearch/common/settings/Settings; executeRefreshOrUpdate S(Lorg/elasticsearch/cluster/ClusterState;J)Lorg/elasticsearch/common/collect/Tuple; java/lang/Exception U java/util/List W isEmpty ()Z Y Z X [ &org/elasticsearch/common/collect/Tuple ] tuple N(Ljava/lang/Object;Ljava/lang/Object;)Lorg/elasticsearch/common/collect/Tuple; _ ` ^ a 6 5 c addAll (Ljava/util/Collection;)Z e f X g clear i ? X j 4 5 l java/lang/Throwable n %org/elasticsearch/common/collect/Maps p newHashMap ()Ljava/util/HashMap; r s q t iterator ()Ljava/util/Iterator; v w X x java/util/Iterator z hasNext | Z { } next ()Ljava/lang/Object; ? { ? index Ljava/lang/String; ? ? ? logger +Lorg/elasticsearch/common/logging/ESLogger; ? ? ? 7ignoring a mapping task of type [{}] with a null index. ? )org/elasticsearch/common/logging/ESLogger ? debug ((Ljava/lang/String;[Ljava/lang/Object;)V ? ? ? ? get &(Ljava/lang/Object;)Ljava/lang/Object; ? ? ? put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; ? ? ? add (Ljava/lang/Object;)Z ? ? X ? metaData /()Lorg/elasticsearch/cluster/metadata/MetaData; ? ? ( ? builder d(Lorg/elasticsearch/cluster/metadata/MetaData;)Lorg/elasticsearch/cluster/metadata/MetaData$Builder; ? ? $ ? entrySet ()Ljava/util/Set; ? ? ? java/util/Set ? ? x getKey ? ? ? java/lang/String ? F(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/IndexMetaData; ? ? " ? 3[{}] ignoring tasks - index meta data doesn't exist ? getValue ? ? ? indexUUID ? ? ? isSameUUID (Ljava/lang/String;)Z ? ? ? A[{}] ignoring task [{}] - index meta data doesn't match task uuid ? order ? 5 ????????? nodeId ? ? ? size ()I ? ? X ? (I)Ljava/lang/Object; ? ? X ? type ? ? ? equals ? ? ? ? set '(ILjava/lang/Object;)Ljava/lang/Object; ? ? X ? (org/elasticsearch/indices/IndicesService ? indexService B(Ljava/lang/String;)Lorg/elasticsearch/index/service/IndexService; ? ? ? ? ()Ljava/lang/String; ? ? ? .()Lorg/elasticsearch/common/settings/Settings; Q ? ? nodes 1()Lorg/elasticsearch/cluster/node/DiscoveryNodes; ? ? ( ? -org/elasticsearch/cluster/node/DiscoveryNodes ? localNode 0()Lorg/elasticsearch/cluster/node/DiscoveryNode; ? ? ? ? ,org/elasticsearch/cluster/node/DiscoveryNode ? id ? ? ? ? createIndex ?(Ljava/lang/String;Lorg/elasticsearch/common/settings/Settings;Ljava/lang/String;)Lorg/elasticsearch/index/service/IndexService; ? ? ? ? %org/elasticsearch/common/collect/Sets ? newHashSet ()Ljava/util/HashSet; ? ? ? ,org/elasticsearch/index/service/IndexService ? ? types [Ljava/lang/String; java/util/Collections ,(Ljava/util/Collection;[Ljava/lang/Object;)Z e mappings 5()Lorg/elasticsearch/common/collect/ImmutableOpenMap; 1org/elasticsearch/common/collect/ImmutableOpenMap containsKey ? mapperService 0()Lorg/elasticsearch/index/mapper/MapperService; ? 2org/elasticsearch/cluster/metadata/MappingMetaData source 6()Lorg/elasticsearch/common/compress/CompressedString; ,org/elasticsearch/index/mapper/MapperService" merge x(Ljava/lang/String;Lorg/elasticsearch/common/compress/CompressedString;Z)Lorg/elasticsearch/index/mapper/DocumentMapper; $% #& n(Lorg/elasticsearch/cluster/metadata/IndexMetaData;)Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder; ?( ) processIndexMappingTasks {(Ljava/util/List;Lorg/elasticsearch/index/service/IndexService;Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder;)Z +, - q(Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder;)Lorg/elasticsearch/cluster/metadata/MetaData$Builder; ?/ "0 created for mapping processing2 removeIndex '(Ljava/lang/String;Ljava/lang/String;)V 45 ?6 Z(Lorg/elasticsearch/cluster/ClusterState;)Lorg/elasticsearch/cluster/ClusterState$Builder; ?8 (9 g(Lorg/elasticsearch/cluster/metadata/MetaData$Builder;)Lorg/elasticsearch/cluster/ClusterState$Builder; ?; &< build *()Lorg/elasticsearch/cluster/ClusterState; >? &@ indexTasks task GLorg/elasticsearch/cluster/metadata/MetaDataMappingService$MappingTask; i$ Ljava/util/Iterator; eTask FLorg/elasticsearch/cluster/metadata/MetaDataMappingService$UpdateTask; existing i I uTask Z typesToIntroduce #Ljava/util/Set<Ljava/lang/String;>; Ljava/util/Set; indexDirty indexMetaData 2Lorg/elasticsearch/cluster/metadata/IndexMetaData; allIndexTasks tasks .Lorg/elasticsearch/index/service/IndexService; :Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder; entry ?Ljava/util/Map$Entry<Ljava/lang/String;Ljava/util/List<Lorg/elasticsearch/cluster/metadata/MetaDataMappingService$MappingTask;>;>; Ljava/util/Map$Entry; currentState (Lorg/elasticsearch/cluster/ClusterState; insertionOrder allTasks tasksPerIndex |Ljava/util/Map<Ljava/lang/String;Ljava/util/List<Lorg/elasticsearch/cluster/metadata/MetaDataMappingService$MappingTask;>;>; Ljava/util/Map; dirty mdBuilder 5Lorg/elasticsearch/cluster/metadata/MetaData$Builder; !()Lorg/elasticsearch/index/Index; ?e f org/elasticsearch/index/Indexh name j ? ik &org/elasticsearch/common/collect/Listsm newArrayList ()Ljava/util/ArrayList; op nq contains t ? ?u documentMapper C(Ljava/lang/String;)Lorg/elasticsearch/index/mapper/DocumentMapper; wx #y -org/elasticsearch/index/mapper/DocumentMapper{ mappingSource } |~ mapping H(Ljava/lang/String;)Lorg/elasticsearch/cluster/metadata/MappingMetaData; ?? ? 2org/elasticsearch/common/compress/CompressedString? ? ? 2(Lorg/elasticsearch/index/mapper/DocumentMapper;)V 7? ? putMapping p(Lorg/elasticsearch/cluster/metadata/MappingMetaData;)Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder; ?? ? :[{}] re-syncing mappings with cluster state for types [{}]? warn ? ? ?? ;[{}] failed to refresh-mapping in cluster state, types [{}]? 4Lorg/elasticsearch/common/compress/CompressedString; }? ? T[{}] update_mapping [{}] ignoring mapping update task as its source is equal to ours? f[{}] update_mapping [{}] ignoring mapping update task as it results in the same source as what we have? isDebugEnabled ? Z ?? 3[{}] update_mapping [{}] (dynamic) with source [{}]? isInfoEnabled ? Z ?? "[{}] update_mapping [{}] (dynamic)? info ? ? ?? 9[{}] failed to update-mapping in cluster state, type [{}]? /illegal state, got wrong mapping task type [{}]? mapper /Lorg/elasticsearch/index/mapper/DocumentMapper; arr$ len$ updatedTypes $Ljava/util/List<Ljava/lang/String;>; t Ljava/lang/Throwable; refreshTask GLorg/elasticsearch/cluster/metadata/MetaDataMappingService$RefreshTask; mappingMetaData 4Lorg/elasticsearch/cluster/metadata/MappingMetaData; updatedMapper updateTask processedRefreshes refreshMapping :(Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;)V 7? ? java/lang/StringBuilder? ? @ refresh-mapping [? append -(Ljava/lang/String;)Ljava/lang/StringBuilder; ?? ?? ][? java/util/Arrays? toString '([Ljava/lang/Object;)Ljava/lang/String; ?? ?? ]? ? ? ?? !org/elasticsearch/common/Priority? HIGH #Lorg/elasticsearch/common/Priority; ?? ?? ?(Lorg/elasticsearch/cluster/metadata/MetaDataMappingService;J)V 7? ? (org/elasticsearch/cluster/ClusterService? submitStateUpdateTask j(Ljava/lang/String;Lorg/elasticsearch/common/Priority;Lorg/elasticsearch/cluster/ClusterStateUpdateTask;)V ?? ?? insertOrder updateMapping ?(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lorg/elasticsearch/common/compress/CompressedString;JLjava/lang/String;Lorg/elasticsearch/action/ActionListener;)V 7? ? 'org/elasticsearch/action/ActionListener? update-mapping [? ] / node [? ], order [? (J)Ljava/lang/StringBuilder; ?? ?? h(Lorg/elasticsearch/cluster/metadata/MetaDataMappingService;Lorg/elasticsearch/action/ActionListener;J)V 7? ? listener eLorg/elasticsearch/action/ActionListener<Lorg/elasticsearch/cluster/ack/ClusterStateUpdateResponse;>; )Lorg/elasticsearch/action/ActionListener; removeMapping ?(Lorg/elasticsearch/action/admin/indices/mapping/delete/DeleteMappingClusterStateUpdateRequest;Lorg/elasticsearch/action/ActionListener;)V remove-mapping [? \org/elasticsearch/action/admin/indices/mapping/delete/DeleteMappingClusterStateUpdateRequest? ()[Ljava/lang/String; ? ?(Lorg/elasticsearch/cluster/metadata/MetaDataMappingService;Lorg/elasticsearch/cluster/ack/AckedRequest;Lorg/elasticsearch/action/ActionListener;Lorg/elasticsearch/action/admin/indices/mapping/delete/DeleteMappingClusterStateUpdateRequest;)V 7 request ^Lorg/elasticsearch/action/admin/indices/mapping/delete/DeleteMappingClusterStateUpdateRequest; ?(Lorg/elasticsearch/action/admin/indices/mapping/put/PutMappingClusterStateUpdateRequest;Lorg/elasticsearch/action/ActionListener;)V put-mapping [ Vorg/elasticsearch/action/admin/indices/mapping/put/PutMappingClusterStateUpdateRequest ? ? ?(Lorg/elasticsearch/cluster/metadata/MetaDataMappingService;Lorg/elasticsearch/cluster/ack/AckedRequest;Lorg/elasticsearch/action/ActionListener;Lorg/elasticsearch/action/admin/indices/mapping/put/PutMappingClusterStateUpdateRequest;)V 7 XLorg/elasticsearch/action/admin/indices/mapping/put/PutMappingClusterStateUpdateRequest; access$000 h(Lorg/elasticsearch/cluster/metadata/MetaDataMappingService;)Lorg/elasticsearch/common/logging/ESLogger; x0 access$100 access$200 access$300 g(Lorg/elasticsearch/cluster/metadata/MetaDataMappingService;)Lorg/elasticsearch/indices/IndicesService; access$400 g(Lorg/elasticsearch/cluster/metadata/MetaDataMappingService;)Lorg/elasticsearch/cluster/ClusterService; access$500 access$600 access$700 access$800 access$900 access$1000 access$1100 access$1200 Signature Code LocalVariableTable LineNumberTable RuntimeVisibleAnnotations LocalVariableTypeTable StackMapTable Exceptions ?(Lorg/elasticsearch/cluster/ClusterState;J)Lorg/elasticsearch/common/collect/Tuple<Lorg/elasticsearch/cluster/ClusterState;Ljava/util/List<Lorg/elasticsearch/cluster/metadata/MetaDataMappingService$MappingTask;>;>; ?(Ljava/util/List<Lorg/elasticsearch/cluster/metadata/MetaDataMappingService$MappingTask;>;Lorg/elasticsearch/index/service/IndexService;Lorg/elasticsearch/cluster/metadata/IndexMetaData$Builder;)Z ?(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lorg/elasticsearch/common/compress/CompressedString;JLjava/lang/String;Lorg/elasticsearch/action/ActionListener<Lorg/elasticsearch/cluster/ack/ClusterStateUpdateResponse;>;)V ?(Lorg/elasticsearch/action/admin/indices/mapping/delete/DeleteMappingClusterStateUpdateRequest;Lorg/elasticsearch/action/ActionListener<Lorg/elasticsearch/cluster/ack/ClusterStateUpdateResponse;>;)V ?(Lorg/elasticsearch/action/admin/indices/mapping/put/PutMappingClusterStateUpdateRequest;Lorg/elasticsearch/action/ActionListener<Lorg/elasticsearch/cluster/ack/ClusterStateUpdateResponse;>;)V SourceFile InnerClasses ! ) * + , - . / 0 1 2 $ 3 4 5 6 5 7 8 % ? ,*+? <*? >Y? A? C*? EY? F? H*,? J*-? L*? N? & 4 , O P , Q R , ) * , + , , - . ' I B C J K % L + M( 9 S T % ? ?? EY? F:*? CY:?*? H? \ ? +? bð *? d?? +? bð*? H? h W*? H? k **? m? dç :??? \ ? +? b?? u:? y :? ~ ? f? ? ? :? ?? *? ??? >YS? ? ? ?? ? ? X:? ? EY? F:? ?? ? W? ? W???6+? ?? ?:? ? ? ? :? ~ ??? ? ? : ? ? ? ?: ? ?: ? *? ??? >Y S? ? ??? ? ? ? X: ? EY? F: ? y :? ~ ? ?? ? ? : ? ?? ?? *? ??? >Y SYS? ? ???6? ? ?? :? ? ?? ?? ?? ?6 ? ? ? z ? ? ? :? ? ^? :? ?? ? ? G? ? ?? ;? ?? 3? ?? ? ? #? ?? ?? ? ? W6? ????? ? ? W??6*? N ? ? :? ?*? N ? ? ? ?+? ? ? ?? ? :6?: ? y :? ~ ? C? ? ? :? ? ? ? ? W? ? ? ? ?? W???? ? :? ~ ? =? ? ? ?: ??? !? ??? ?!?'W??? ?*:* ?.6? ?1W6? ,*? N 3?7 ? :? *? N 3?7 ???q? +? b?+?:?=?A? b? & ] ' 9 ] : Z ] ] b ] Pl? ??? & B ? 'B 2 ? TCD ? mEF TGH ? cID ? ?JK ? ?LH ? ? ?M ? ?CD p ?EF ? 1CD ? JEF + ? ? DEF ? ?NP \ QM -m ? ? 6dRS ^<T 2 g3U 2 p*4M } ?V P J ?W !yXZ ?EF ? O P ?[\ ?] 5 ?^ 2 {@_a ??bM ??cd ) H ? 'B 3 ? ?NO ^<T 3 g3U 3 !yXY ?^ 3 {@_` ' N S y { | } ' ? 0 ? : ? F ? O ? W ? e ? o ? v ? { ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?! ?- ?6 ?; ?O ?R ?^ ?g ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ? ? ?% ?C ?O ?R ?U ?[ ?` ?j ?m ?p ?} ?? ?? ?? ?? ?? ?? ?? ?? ?? ?? ? ?( ?F ?I ?P ?\ ?a ?i ?l ?q ?? ?? ?? ?? ?? ?? ?* ? ' X >b o? ? {? 1 ? - X? ? " {? F ? ? X X {? > ? ( ? |? ? ? ? D ( X " { ? X X ? { ? 0 ? ? ? {? @? ? " U o? ( X " { ? X X o ? ( X " { ? + V$ , +, % m _6,?g ?l:?:+? y :? ~ ?:? ? ? :? ? ?? : ?r: ?: ?6 6 ? j 2:?v ? ? N,? ?z:? ? 9?-???!??? ? ? W-? Y????W? W? ??? ? \ ? ??O*? ??? >YSY S?? 6? ": *? ??? >YSY ?S?? ?K? ?.? : ? ?: ??: - ??: ? 0 ?! ??? #*? ??? >YSY ? ?S? ? ???,? ?': ? W ? 3 ?! ???? #*? ??? >YSY ? ?S? ? ??g*? ??? ? (*? ??? >YSY SY ?S? ? ? )*? ??? ? *? ??? >YSY S?? -? Y ????W6? ": *? ??? >YSY ? ?S?? ? *? ??? >YS?? ???? @ ? ? o ? ? ? o e" oh?" o? " o & ? ~ >?? b Z ? ? L v? Q q?K T nEK E ?? 2 ? ?? @ ??? ' ? ? ? . ?}? 6 ??? x ??? $ ?? !?H 1(CD AEF _ O P _U 2 _ ?V _ ?W \bM Q ? ? L?P ) E ??? _U 3 L?O ' ? 3 1 9 @ E b n q ~ ? ? ? ? ? ? ? ? ? ? ? ? ? !" $'%.'6(H)e*h-x.?1?2?3?7?8?9?:= > A"?$@ABDCYE\F* ? ? X ? ? { ? 8 X ? ? { Xs ? ?? |+? ? ? X ? ? { o? ? V X ? ? { ?? ? N|0%? X ? ? { o? ? ? $ - ??? % ! u*? CY:?*Y? m a]? m7*? H? Y+,-??? ? Wç :??*? L??Y????+????-??????? Y*??? ? , / / 4 / & 4 u O P u ? ? u ? ? u `? 5 ' N O P )Q 7R to* 0 ? / ? ?s > o? ? ?s ?? % ? ?*? CY: ?*Y? m a]? m7 *? H? Y+,-?? ? W ç : ? ?*? L??Y????+????-?????????????? Y* ???? ? 4 7 7 < 7 & \ ? O P ? ? ? ? ? ? ? ? ? ?}? ? ? 5 ? ? ? ??? }? 5 ) ??? ' s t u 1v ?w ??* D ? 7 ? ? ?? ?? > o? ? ? ?? ?? $ . ?? % ? 8*? L??Y????+???????? Y*+,+??? ? & 8 O P 8 8?? ) 8?? ' ? 7?$ / ? % ? 5*? L??Y?? ??+??????? Y*+,+??? ? & 5 O P 5 5?? ) 5?? ' ? 4T$ 0 % / *? ?? & P ' ; % / *? ?? & P ' ; % / *? ?? & P ' ; % / *? N? & P ' ; % / *? L? & P ' ; % / *? ?? & P ' ; % / *? ?? & P ' ; % / *? ?? & P ' ; % / *? ?? & P ' ; % / *? ?? & P ' ;! % / *? ?? & P ' ;" % / *? ?? & P ' ;# % / *? ?? & P ' ; 1 2 Z " $ & (
Ms-Dos/Windows
Unix
Write backup
jsp File Browser version 1.2 by
www.vonloesch.de