46(com/hazelcast/map/impl/query/QueryRunnerjava/lang/ObjectQueryRunner.javamapServiceContext*Lcom/hazelcast/map/impl/MapServiceContext; nodeEngineLcom/hazelcast/spi/NodeEngine;loggerLcom/hazelcast/logging/ILogger;queryResultSizeLimiter5Lcom/hazelcast/map/impl/query/QueryResultSizeLimiter;serializationServiceCLcom/hazelcast/internal/serialization/InternalSerializationService;queryOptimizer4Lcom/hazelcast/query/impl/predicates/QueryOptimizer;operationService$Lcom/hazelcast/spi/OperationService;clusterService/Lcom/hazelcast/internal/cluster/ClusterService;localMapStatsProvider.Lcom/hazelcast/map/impl/LocalMapStatsProvider;partitionScanExecutor4Lcom/hazelcast/map/impl/query/PartitionScanExecutor;resultProcessorRegistry6Lcom/hazelcast/map/impl/query/ResultProcessorRegistry;(Lcom/hazelcast/map/impl/MapServiceContext;Lcom/hazelcast/query/impl/predicates/QueryOptimizer;Lcom/hazelcast/map/impl/query/PartitionScanExecutor;Lcom/hazelcast/map/impl/query/ResultProcessorRegistry;)V()V    !(com/hazelcast/map/impl/MapServiceContext# getNodeEngine ()Lcom/hazelcast/spi/NodeEngine; %& $'  )com/hazelcast/spi/NodeEngine+getSerializationService8()Lcom/hazelcast/spi/serialization/SerializationService; -. ,/Acom/hazelcast/internal/serialization/InternalSerializationService1  3getClass()Ljava/lang/Class; 56 7 getLogger2(Ljava/lang/Class;)Lcom/hazelcast/logging/ILogger; 9: ,; =3com/hazelcast/map/impl/query/QueryResultSizeLimiter?L(Lcom/hazelcast/map/impl/MapServiceContext;Lcom/hazelcast/logging/ILogger;)V A @B D  FgetOperationService&()Lcom/hazelcast/spi/OperationService; HI ,J  LgetClusterService1()Lcom/hazelcast/internal/cluster/ClusterService; NO ,P  RgetLocalMapStatsProvider0()Lcom/hazelcast/map/impl/LocalMapStatsProvider; TU $V  X  Z  \this*Lcom/hazelcast/map/impl/query/QueryRunner; optimizer%runPartitionScanQueryOnPartitionChunkU(Lcom/hazelcast/map/impl/query/Query;III)Lcom/hazelcast/map/impl/query/ResultSegment;"com/hazelcast/map/impl/query/Queryc getMapName()Ljava/lang/String; ef dggetMapContainer9(Ljava/lang/String;)Lcom/hazelcast/map/impl/MapContainer; ij $k getPredicate!()Lcom/hazelcast/query/Predicate; mn do#com/hazelcast/map/impl/MapContainerq getIndexes%(I)Lcom/hazelcast/query/impl/Indexes; st ru2com/hazelcast/query/impl/predicates/QueryOptimizerwoptimizeb(Lcom/hazelcast/query/Predicate;Lcom/hazelcast/query/impl/Indexes;)Lcom/hazelcast/query/Predicate; yz x{2com/hazelcast/map/impl/query/PartitionScanExecutor}executeh(Ljava/lang/String;Lcom/hazelcast/query/Predicate;III)Lcom/hazelcast/query/impl/QueryableEntriesSegment;  ~ getResultType 6 d4com/hazelcast/map/impl/query/ResultProcessorRegistrygetA(Ljava/lang/Class;)Lcom/hazelcast/map/impl/query/ResultProcessor; 0com/hazelcast/query/impl/QueryableEntriesSegment getEntries()Ljava/util/Collection; java/lang/IntegervalueOf(I)Ljava/lang/Integer; java/util/Collections singletonList$(Ljava/lang/Object;)Ljava/util/List; ,com/hazelcast/map/impl/query/ResultProcessorpopulateResultx(Lcom/hazelcast/map/impl/query/Query;JLjava/util/Collection;Ljava/util/Collection;)Lcom/hazelcast/map/impl/query/Result; *com/hazelcast/map/impl/query/ResultSegmentgetNextTableIndexToReadFrom()I )(Lcom/hazelcast/map/impl/query/Result;I)V  query$Lcom/hazelcast/map/impl/query/Query; partitionIdI tableIndex fetchSize mapContainer%Lcom/hazelcast/map/impl/MapContainer; predicateLcom/hazelcast/query/Predicate;entries2Lcom/hazelcast/query/impl/QueryableEntriesSegment; processor.Lcom/hazelcast/map/impl/query/ResultProcessor;result%Lcom/hazelcast/map/impl/query/Result;-runIndexOrPartitionScanQueryOnOwnedPartitionsK(Lcom/hazelcast/map/impl/query/Query;)Lcom/hazelcast/map/impl/query/Result;getMigrationStamp getOwnedPartitions $$()Lcom/hazelcast/query/impl/Indexes; s rjava/util/Collectioniterator()Ljava/util/Iterator; java/util/Iteratornext()Ljava/lang/Object; intValue  com/hazelcast/query/impl/Indexessize runUsingGlobalIndexSafely^(Lcom/hazelcast/query/Predicate;Lcom/hazelcast/map/impl/MapContainer;II)Ljava/util/Collection; runUsingPartitionScanSafely(Lcom/hazelcast/map/impl/query/Query;Lcom/hazelcast/query/Predicate;Ljava/util/Collection;I)Lcom/hazelcast/map/impl/query/Result; populateEmptyResulta(Lcom/hazelcast/map/impl/query/Query;Ljava/util/Collection;)Lcom/hazelcast/map/impl/query/Result; com/hazelcast/query/PredicatepopulateNonEmptyResultw(Lcom/hazelcast/map/impl/query/Query;Ljava/util/Collection;Ljava/util/Collection;)Lcom/hazelcast/map/impl/query/Result; #com/hazelcast/map/impl/query/ResultmigrationStampinitialPartitions+Ljava/util/Collection;Ljava/util/Collection;indexes"Lcom/hazelcast/query/impl/Indexes;ALjava/util/Collection;runIndexQueryOnOwnedPartitions:runPartitionIndexOrPartitionScanQueryOnGivenOwnedPartitionL(Lcom/hazelcast/map/impl/query/Query;I)Lcom/hazelcast/map/impl/query/Result;isGlobal()Z java/util/List 1(Lcom/hazelcast/query/Predicate;I)Ljava/util/Set;   createResult  o(Ljava/lang/String;Lcom/hazelcast/query/Predicate;Ljava/util/Collection;Lcom/hazelcast/map/impl/query/Result;)V  ~ completeConstruction(Ljava/util/Collection;)V    partitions%Ljava/util/List;Ljava/util/List;*runPartitionScanQueryOnGivenOwnedPartitionv(Lcom/hazelcast/map/impl/query/Query;Ljava/util/Collection;)Lcom/hazelcast/map/impl/query/Result;getNodeResultLimit(I)J  @^(Lcom/hazelcast/spi/serialization/SerializationService;J)Lcom/hazelcast/map/impl/query/Result;  dL(Lcom/hazelcast/map/impl/query/Query;J)Lcom/hazelcast/map/impl/query/Result;  (Lcom/hazelcast/map/impl/query/Query;Ljava/util/Collection;Ljava/util/Collection;)Lcom/hazelcast/map/impl/query/Result;(Lcom/hazelcast/query/Predicate;Lcom/hazelcast/map/impl/MapContainer;II)Ljava/util/Collection;validateMigrationStamp(I)Z !" #ownedPartitionCount(Lcom/hazelcast/map/impl/query/Query;Lcom/hazelcast/query/Predicate;Ljava/util/Collection;I)Lcom/hazelcast/map/impl/query/Result; getService%()Lcom/hazelcast/map/impl/MapService; '( $)!com/hazelcast/map/impl/MapService+ , ,#CodeLineNumberTableLocalVariableTable StackMapTableLocalVariableTypeTable Signature SourceFile!     /y* *+"*+(****024****8<>*@Y+*>CE*,G***KM***QS*+WY*-[*]06 => ?@#A4BDCIDVEcFmGrHxI14y^_yy`yyab/  n*"+hl:*G+pv|:*[+h:*]+:+: Y 0VW$X)Y9[F\_^1f n^_nnnn_$J95F(_ / *=*"N*"+hl::-ضv:*G+p|:*-:*+-:*+-: *+-:2(BdrA 0Bdefi%j*kBnSqZr_qduivtwyy|1f t^_s%lS>d-3d-/ *=*"N*"+hl::-ضv:*G+p|:*-:*+-: *+-:2(Bdr1 0:%*BSZ_dit~1f q^_|rc%\S.d~3rd/ *"+hlN:*G+p-v|::-v::+*+:*[+h *+:2&Rdr, 06 +.5BRW`s1f `^_v+b._5X3v._/S*"+hlN*G+p-v|::*+:*[+h 0"+4GP1HS^_SSE"1+(43 +(/f+*4*E,01 ^_3 4/w*]++*E,01 ^_3 4/%*]+:+*E-,-0  14%^_%%% 3%%4/?*$,:+:*$2   06  !+02:=1H?^_????%/+3 +4 /:*$*+-:*[+h,- *$-2  ,0"  $-581>:^_::::'3 :4&/7 *"*-0 1  ^_!"/B*"*.0$1^_5