4:com/hazelcast/map/impl/operation/MapReplicationStateHolderjava/lang/Object:com/hazelcast/nio/serialization/IdentifiedDataSerializable.com/hazelcast/nio/serialization/impl/VersionedMapReplicationStateHolder.javajava/util/Map$Entry  java/util/Map Entry.com/hazelcast/query/impl/Index$OperationSourcecom/hazelcast/query/impl/IndexOperationSourcestoresByMapNameLjava/util/Map;{Ljava/util/Map;>;datapLjava/util/Map;>;loaded6Ljava/util/Map; mapIndexInfosLjava/util/List;9Ljava/util/List; operation:Lcom/hazelcast/map/impl/operation/MapReplicationOperation;()V ! "this;I)Vjava/util/Collection,size()I ./ -0com/hazelcast/util/MapUtil2 createHashMap(I)Ljava/util/Map; 45 36  8  :  <java/util/ArrayList>(I)V @ ?A  Citerator()Ljava/util/Iterator; EF -Gjava/util/IteratorIhasNext()Z KL JMnext()Ljava/lang/Object; OP JQ"com/hazelcast/spi/ServiceNamespaceS!com/hazelcast/spi/ObjectNamespaceU getObjectName()Ljava/lang/String; WX VY)com/hazelcast/map/impl/PartitionContainer[getExistingRecordStoreD(Ljava/lang/String;)Lcom/hazelcast/map/impl/recordstore/RecordStore; ]^ \_java/lang/Stringa.com/hazelcast/map/impl/recordstore/RecordStorecgetMapContainer'()Lcom/hazelcast/map/impl/MapContainer; ef dg#com/hazelcast/map/impl/MapContaineri getMapConfig"()Lcom/hazelcast/config/MapConfig; kl jmcom/hazelcast/config/MapConfigogetTotalBackupCount q/ prisLoaded tL dujava/lang/BooleanwvalueOf(Z)Ljava/lang/Boolean; yz x{put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; }~ java/util/HashSet "isGlobalIndexEnabled L j getIndexes$()Lcom/hazelcast/query/impl/Indexes; j com/hazelcast/query/impl/Indexes+()[Lcom/hazelcast/query/impl/InternalIndex;  java/util/Set)[Lcom/hazelcast/query/impl/InternalIndex;"com/hazelcast/query/impl/IndexInfogetName X  isOrdered L (Ljava/lang/String;Z)V add(Ljava/lang/Object;)Z getIndexDefinitions()Ljava/util/Collection; addAll(Ljava/util/Collection;)Z getPartitionId / \%(I)Lcom/hazelcast/query/impl/Indexes; jhaveAtLeastOneIndexOrDefinition L %com/hazelcast/query/impl/MapIndexInfo(Ljava/lang/String;)V  addIndexInfos(Ljava/util/Collection;)V java/util/List index Lcom/hazelcast/query/impl/Index;indexes"Lcom/hazelcast/query/impl/Indexes; mapNamespace#Lcom/hazelcast/spi/ObjectNamespace;mapNameLjava/lang/String; recordStore0Lcom/hazelcast/map/impl/recordstore/RecordStore; mapContainer%Lcom/hazelcast/map/impl/MapContainer; mapConfig Lcom/hazelcast/config/MapConfig; indexInfos5Ljava/util/Set;Ljava/util/Set; mapIndexInfo'Lcom/hazelcast/query/impl/MapIndexInfo; namespace$Lcom/hazelcast/spi/ServiceNamespace; container+Lcom/hazelcast/map/impl/PartitionContainer; namespaces;Ljava/util/Collection; replicaIndexI applyStatecom/hazelcast/util/ThreadUtilassertRunningOnPartitionThread ! applyIndexesState ! entrySet()Ljava/util/Set; GgetValue P getKey P 8com/hazelcast/map/impl/operation/MapReplicationOperationgetRecordStore ^ reset ! dget&(Ljava/lang/Object;)Ljava/lang/Object;  booleanValue L xsetPreMigrationLoadedStatus(Z)V  dgetMapServiceContext,()Lcom/hazelcast/map/impl/MapServiceContext;  j (com/hazelcast/map/impl/MapServiceContextgetPartitionContainer.(I)Lcom/hazelcast/map/impl/PartitionContainer;     ()Ljava/util/Map;  j addOrGetIndex=(Ljava/lang/String;Z)Lcom/hazelcast/query/impl/InternalIndex;   getNodeEngine ()Lcom/hazelcast/spi/NodeEngine;   com/hazelcast/spi/NodeEnginegetSerializationService8()Lcom/hazelcast/spi/serialization/SerializationService;  indexesMustBePopulated_(Lcom/hazelcast/query/impl/Indexes;Lcom/hazelcast/map/impl/operation/MapReplicationOperation;)Z  !clearAll #! $4com/hazelcast/spi/serialization/SerializationService&3com/hazelcast/map/impl/record/RecordReplicationInfo((()Lcom/hazelcast/nio/serialization/Data; * )+ * )-com/hazelcast/util/Clock1currentTimeMillis()J 34 25 createRecordc(Lcom/hazelcast/nio/serialization/Data;Ljava/lang/Object;JJJ)Lcom/hazelcast/map/impl/record/Record; 78 d9%com/hazelcast/map/impl/record/Records;applyRecordInfoS(Lcom/hazelcast/map/impl/record/Record;Lcom/hazelcast/map/impl/record/RecordInfo;)V => <? putRecordO(Lcom/hazelcast/nio/serialization/Data;Lcom/hazelcast/map/impl/record/Record;)V AB dCgetValueOrCachedValuep(Lcom/hazelcast/map/impl/record/Record;Lcom/hazelcast/spi/serialization/SerializationService;)Ljava/lang/Object; EF <G$com/hazelcast/map/impl/record/RecordI J+ newQueryEntryc(Lcom/hazelcast/nio/serialization/Data;Ljava/lang/Object;)Lcom/hazelcast/query/impl/QueryableEntry; LM jNSYSTEM0Lcom/hazelcast/query/impl/Index$OperationSource; PQ RputEntryn(Lcom/hazelcast/query/impl/QueryableEntry;Ljava/lang/Object;Lcom/hazelcast/query/impl/Index$OperationSource;)V TU V$com/hazelcast/nio/serialization/DataX shouldEvict ZL d[ evictEntries)(Lcom/hazelcast/nio/serialization/Data;)V ]^ d_disposeDeferredBlocks a! dbmarkPartitionAsIndexed-(I[Lcom/hazelcast/query/impl/InternalIndex;)V de findexDefinition;Ljava/util/Map$Entry;queryableEntry)Lcom/hazelcast/query/impl/QueryableEntry; valueToIndexLjava/lang/Object;key&Lcom/hazelcast/nio/serialization/Data;value newRecord&Lcom/hazelcast/map/impl/record/Record;recordReplicationInfo5Lcom/hazelcast/map/impl/record/RecordReplicationInfo;recordReplicationInfosMLjava/util/Collection;partitionContainerserializationService6Lcom/hazelcast/spi/serialization/SerializationService;ZindexesSnapshot dataEntryvLjava/util/Map$Entry;>; G getMapName X  getIndexInfos()Ljava/util/List;   addIndexes+(Ljava/lang/String;Ljava/util/Collection;)V  Q(Ljava/lang/String;Ljava/util/Collection;)V getIndex<(Ljava/lang/String;)Lcom/hazelcast/query/impl/InternalIndex;   $createIndexesFromRecordedDefinitions !  indexInfo$Lcom/hazelcast/query/impl/IndexInfo;; writeData'(Lcom/hazelcast/nio/ObjectDataOutput;)Vjava/io/IOException 0"com/hazelcast/nio/ObjectDataOutputwriteInt @ h(Lcom/hazelcast/map/impl/recordstore/RecordStore;)Lcom/hazelcast/spi/serialization/SerializationService;  writeUTF   d0 dGtoReplicationInfo(Lcom/hazelcast/map/impl/record/Record;Lcom/hazelcast/spi/serialization/SerializationService;)Lcom/hazelcast/map/impl/record/RecordReplicationInfo;   writeObject(Ljava/lang/Object;)V   writeBoolean   0recordreplicationInfoss;Ljava/util/Iterator;entryLjava/util/Map$Entry;>; loadedEntryout$Lcom/hazelcast/nio/ObjectDataOutput;readData&(Lcom/hazelcast/nio/ObjectDataInput;)V!com/hazelcast/nio/ObjectDataInputreadInt / readUTF X  readObject P  - readBoolean L jnamerecordStoreSizeiin#Lcom/hazelcast/nio/ObjectDataInput; loadedSizemapIndexInfosSize getFactoryId,com/hazelcast/map/impl/MapDataSerializerHookF_ID  getIdhaveAtLeastOneIndex L isGlobal L getReplicaIndex /  SignatureCodeLineNumberTableLocalVariableTable StackMapTableLocalVariableTypeTable Exceptions InnerClasses SourceFile!  !3*# WX $% &F *#*+(Z[ \ $% )**,179*,17;*,17=*?Y,1BD,H:N]RT:V:Z:+`:h:  n:  s*=v|W*9WY:  Z :  :  66- 2: YW  Wh +:  X P :  66- 2: YW  WY:   *D W @J5 \-JTVbdjpJ\-JTVbdjp0&\-JTVbdjp0 \-#_ ab'c8dVe]ffgnhsivlmnorsuvxyzy|})6SpvM S)Z ]Df;n3"   VK$% +!= Ѹ**;*;L+N+R M,-N,b:*(:*=xh:h*( ::N;R : :   b xW:: *("6  %: -H:  N R):  ,: .://6: : @D , H:KO:SW\` ci  gP J J -bdj\JA1'JyJ -bdj\'J)YYJ J -bdj\'J-0:EPWox :AHTW^epu~ )hj  kl~ mnAzopHsqp^]rs:tu :vEP}xU=xyz  { | 0}j$% )hi :vw0}~!4*D/*DL+N+RM*,, J!$03$ 4$%,*(+N-h:K,H:N6R::WƧG*(:,H:N"R:Wڱ  djJ9J(B<CP`fty\ C<$t6$%  )+*9*9M,Ny,R N-b:-d::++:N'RJ:*(: + է+*=*=M,N1,R N+-b+-x+*D*DM,N,RN+-LJMJ bd'J-JJ6Jb1<GNVclv  % ( p su <^GSNLzl.E1ij!j)$%) l.E1i!i >*h = +=*7;>W+:+6?YB:6+):W*;W+>*7=6"*=++|W+6*?YBD6 +:*DW߱?"b-!$#b&1;FPV dj#q$y%&%)*+,-+/F tu4"F&>13vY|% $$%.qm5 13vw/.ެ3 $%/-q8 $%  t**+ <> ACFHK  @