4/com/hazelcast/map/impl/MapMigrationAwareServicejava/lang/Object1com/hazelcast/spi/FragmentedMigrationAwareServiceMapMigrationAwareService.java=com/hazelcast/map/impl/MapMigrationAwareService$TargetIndexes TargetIndexes1com/hazelcast/map/impl/MapMigrationAwareService$2 1com/hazelcast/map/impl/MapMigrationAwareService$1 .com/hazelcast/query/impl/Index$OperationSourcecom/hazelcast/query/impl/IndexOperationSource containers,[Lcom/hazelcast/map/impl/PartitionContainer;mapServiceContext*Lcom/hazelcast/map/impl/MapServiceContext;serializationService6Lcom/hazelcast/spi/serialization/SerializationService;$assertionsDisabledZ-(Lcom/hazelcast/map/impl/MapServiceContext;)V()V    !(com/hazelcast/map/impl/MapServiceContext# getNodeEngine ()Lcom/hazelcast/spi/NodeEngine; %& $'com/hazelcast/spi/NodeEngine)getSerializationService8()Lcom/hazelcast/spi/serialization/SerializationService; +, *-  /getPartitionContainers.()[Lcom/hazelcast/map/impl/PartitionContainer; 12 $3  5this1Lcom/hazelcast/map/impl/MapMigrationAwareService;getAllServiceNamespacesE(Lcom/hazelcast/spi/PartitionReplicationEvent;)Ljava/util/Collection;k(Lcom/hazelcast/spi/PartitionReplicationEvent;)Ljava/util/Collection;+com/hazelcast/spi/PartitionReplicationEvent<getPartitionId()I >? =@getReplicaIndex B? =C)com/hazelcast/map/impl/PartitionContainerEgetAllNamespaces(I)Ljava/util/Collection; GH FIevent-Lcom/hazelcast/spi/PartitionReplicationEvent;isKnownServiceNamespace'(Lcom/hazelcast/spi/ServiceNamespace;)Z!com/hazelcast/spi/ObjectNamespaceOhz:impl:mapServiceQ"com/hazelcast/spi/ServiceNamespaceSgetServiceName()Ljava/lang/String; UV TWjava/lang/StringYequals(Ljava/lang/Object;)Z [\ Z] namespace$Lcom/hazelcast/spi/ServiceNamespace;beforeMigration.(Lcom/hazelcast/spi/PartitionMigrationEvent;)VisLocalPromotion.(Lcom/hazelcast/spi/PartitionMigrationEvent;)Z cd eclearNonGlobalIndexes gb h NON_GLOBAL?Lcom/hazelcast/map/impl/MapMigrationAwareService$TargetIndexes; jk lpopulateIndexesm(Lcom/hazelcast/spi/PartitionMigrationEvent;Lcom/hazelcast/map/impl/MapMigrationAwareService$TargetIndexes;)V no pflushAndRemoveQueryCaches rb s+Lcom/hazelcast/spi/PartitionMigrationEvent;)com/hazelcast/spi/PartitionMigrationEventv w@getQueryCacheContext7()Lcom/hazelcast/map/impl/querycache/QueryCacheContext; yz ${3com/hazelcast/map/impl/querycache/QueryCacheContext}getPublisherContext@()Lcom/hazelcast/map/impl/querycache/publisher/PublisherContext;  ~getMigrationEndpoint1()Lcom/hazelcast/spi/partition/MigrationEndpoint; w-com/hazelcast/spi/partition/MigrationEndpointSOURCE/Lcom/hazelcast/spi/partition/MigrationEndpoint; >com/hazelcast/map/impl/querycache/publisher/AccumulatorSweeperflushAccumulatorB(Lcom/hazelcast/map/impl/querycache/publisher/PublisherContext;I)V removeAccumulator Lcom/hazelcast/map/impl/querycache/publisher/PublisherContext;prepareReplicationOperationL(Lcom/hazelcast/spi/PartitionReplicationEvent;)Lcom/hazelcast/spi/Operation;8com/hazelcast/map/impl/operation/MapReplicationOperation0(Lcom/hazelcast/map/impl/PartitionContainer;II)V   getService%()Lcom/hazelcast/map/impl/MapService; $com/hazelcast/spi/Operation setService1(Ljava/lang/Object;)Lcom/hazelcast/spi/Operation;  setNodeEngine=(Lcom/hazelcast/spi/NodeEngine;)Lcom/hazelcast/spi/Operation;  operationLcom/hazelcast/spi/Operation;b(Lcom/hazelcast/spi/PartitionReplicationEvent;Ljava/util/Collection;)Lcom/hazelcast/spi/Operation;(Lcom/hazelcast/spi/PartitionReplicationEvent;Ljava/util/Collection;)Lcom/hazelcast/spi/Operation;  assertAllKnownNamespaces(Ljava/util/Collection;)Z java/lang/AssertionError F(Lcom/hazelcast/map/impl/PartitionContainer;Ljava/util/Collection;II)V   namespaces;Ljava/util/Collection;?(Ljava/util/Collection;)Zjava/util/Collectioniterator()Ljava/util/Iterator; java/util/IteratorhasNext()Z next()Ljava/lang/Object; MN java/lang/StringBuilder append-(Ljava/lang/Object;)Ljava/lang/StringBuilder;  is not a MapService namespace!-(Ljava/lang/String;)Ljava/lang/StringBuilder; toString V (Ljava/lang/Object;)V  commitMigration DESTINATION GLOBAL k depopulateIndexes b getNewReplicaIndex ? w-removeRecordStoresHavingLesserBackupCountThan(II)V getPartitionContainer.(I)Lcom/hazelcast/map/impl/PartitionContainer;  $getAllRecordStores()Ljava/util/Collection;  F.com/hazelcast/map/impl/recordstore/RecordStore startLoading    reloadOwnedPartitions   $ removeOrRegenerateNearCacheUuid b  recordStore0Lcom/hazelcast/map/impl/recordstore/RecordStore;partitionContainer+Lcom/hazelcast/map/impl/PartitionContainer;getMetaDataGeneratorH()Lcom/hazelcast/internal/nearcache/impl/invalidation/MetaDataGenerator;  Dcom/hazelcast/internal/nearcache/impl/invalidation/MetaDataGeneratorremoveUuidAndSequence(I)V  regenerateUuid   !rollbackMigrationgetCurrentReplicaIndex $? w%getMaps&()Ljava/util/concurrent/ConcurrentMap; '( F)"java/util/concurrent/ConcurrentMap+values - ,.getName 0V 1getMapContainer9(Ljava/lang/String;)Lcom/hazelcast/map/impl/MapContainer; 34 $5#com/hazelcast/map/impl/MapContainer7 getIndexes%(I)Lcom/hazelcast/query/impl/Indexes; 9: 8; com/hazelcast/query/impl/Indexes=haveAtLeastOneIndex ? >@isGlobal B >CclearAll E >F mapContainer%Lcom/hazelcast/map/impl/MapContainer;indexes"Lcom/hazelcast/query/impl/Indexes; containerallRecordStores)()Lcom/hazelcast/util/function/Predicate; MN O+removeRecordStoresFromPartitionMatchingWith-(Lcom/hazelcast/util/function/Predicate;IZZ)V QR $SlesserBackupMapsThen*(I)Lcom/hazelcast/util/function/Predicate; UV WthresholdReplicaIndex[()Lcom/hazelcast/util/function/Predicate; \(I)Lcom/hazelcast/util/function/Predicate;  ] backupCountgetMapNearCacheManager8()Lcom/hazelcast/map/impl/nearcache/MapNearCacheManager; `a $b4com/hazelcast/map/impl/nearcache/MapNearCacheManagerdgetInvalidatorB()Lcom/hazelcast/internal/nearcache/impl/invalidation/Invalidator; fg eh>com/hazelcast/internal/nearcache/impl/invalidation/Invalidatorj kgetNow()J mn o$createIndexesFromRecordedDefinitions q >r+()[Lcom/hazelcast/query/impl/InternalIndex; 9t >u(JZ)Ljava/util/Iterator; w x)[Lcom/hazelcast/query/impl/InternalIndex;z$com/hazelcast/map/impl/record/Record|getKey(()Lcom/hazelcast/nio/serialization/Data; ~ }%com/hazelcast/map/impl/record/RecordsgetValueOrCachedValuep(Lcom/hazelcast/map/impl/record/Record;Lcom/hazelcast/spi/serialization/SerializationService;)Ljava/lang/Object;   newQueryEntryc(Lcom/hazelcast/nio/serialization/Data;Ljava/lang/Object;)Lcom/hazelcast/query/impl/QueryableEntry;  8SYSTEM0Lcom/hazelcast/query/impl/Index$OperationSource;  putEntryn(Lcom/hazelcast/query/impl/QueryableEntry;Ljava/lang/Object;Lcom/hazelcast/query/impl/Index$OperationSource;)V  >markPartitionAsIndexed-(I[Lcom/hazelcast/query/impl/InternalIndex;)V  > queryEntry)Lcom/hazelcast/query/impl/QueryableEntry;record&Lcom/hazelcast/map/impl/record/Record;key&Lcom/hazelcast/nio/serialization/Data;valueLjava/lang/Object;indexesSnapshot;Ljava/util/Iterator; targetIndexesnowJInvalid migration event:  removeEntryk(Lcom/hazelcast/nio/serialization/Data;Ljava/lang/Object;Lcom/hazelcast/query/impl/Index$OperationSource;)V  >markPartitionAsUnindexed  >com/hazelcast/util/ClockcurrentTimeMillis n java/lang/ClassdesiredAssertionStatus  CodeLineNumberTableLocalVariableTable Signature StackMapTableLocalVariableTypeTable InnerClasses SourceFile g#* *+"*+(.0*+46>? @A"B#78#9:E*6+A2+DJF78KL;MNZ+PR+X^@K78_`abg+f*+i*+mq*+tPV Y\]78KurbC+x=*"|N-:++f .~2 cdeg!h'i-j.m5n;oApBr4C78CKu>4,6+A=Y*62+DN-*"W-*"(W-vxy&z4|*6786KL1Q*, Y¿+A>Y*62,+D:*"W*"(W(0?N4Q78QKLQ60! QH+M,9,TN&*-ۚYY- ;CF )_`H78H Hbu+*+q*++*+x+*"+xM,N--: *"*+F2 $0>\cfot*\u78uKu>7b4+*+x++*+x" '234784Ku#bx++*+x+&*+x*"! !*+78+Kugbj*"+xM,*/N-F-:*"26:+x<:ADG'FC8>wF& 1CN^afi>C#HINJK15j78jKu\L{'*"PT*"XT& '78''Y MN Y[Z UV3 Y^  _\:*"cil 78no%+ Y¿, Y¿+*pB*"+x:*/::*"26:+x<:  s A D ,m D , v: !y:  A }:  :  *0: : +x 6> $FB8>{D w Fv*127Fm    !!"$# / & HIJK \z Q m%78%Ku%k7FL Q b>+ Y¿&+YY++&*pA*"+x:*/::*"26:+x<:Av:  y:  2 }:  :  *0:   +x n6($F=8>{8 wFZ&'A)H+I.N0]12457:;<=>@ABCDEz    jHI_JKMz B |78KuN]L B cd[**&*@LML Kumn.Q 784 @8"  @ @