4,com/hazelcast/map/impl/query/QueryEngineImpljava/lang/Object(com/hazelcast/map/impl/query/QueryEngineQueryEngineImpl.java.com/hazelcast/map/impl/query/QueryEngineImpl$1.com/hazelcast/map/impl/query/Target$TargetMode #com/hazelcast/map/impl/query/Target  TargetMode/com/hazelcast/map/impl/query/Query$QueryBuilder"com/hazelcast/map/impl/query/Query QueryBuildermapServiceContext*Lcom/hazelcast/map/impl/MapServiceContext; nodeEngineLcom/hazelcast/spi/NodeEngine;loggerLcom/hazelcast/logging/ILogger;queryResultSizeLimiter5Lcom/hazelcast/map/impl/query/QueryResultSizeLimiter;partitionService/Lcom/hazelcast/spi/partition/IPartitionService;operationService$Lcom/hazelcast/spi/OperationService;clusterService/Lcom/hazelcast/internal/cluster/ClusterService;resultProcessorRegistry6Lcom/hazelcast/map/impl/query/ResultProcessorRegistry;-(Lcom/hazelcast/map/impl/MapServiceContext;)V()V $& '  )(com/hazelcast/map/impl/MapServiceContext+ getNodeEngine ()Lcom/hazelcast/spi/NodeEngine; -. ,/  1com/hazelcast/spi/NodeEngine3getPartitionService1()Lcom/hazelcast/spi/partition/IPartitionService; 56 47  9getClass()Ljava/lang/Class; ;< = getLogger2(Ljava/lang/Class;)Lcom/hazelcast/logging/ILogger; ?@ 4A  C3com/hazelcast/map/impl/query/QueryResultSizeLimiterEL(Lcom/hazelcast/map/impl/MapServiceContext;Lcom/hazelcast/logging/ILogger;)V $G FH  JgetOperationService&()Lcom/hazelcast/spi/OperationService; LM 4N  PgetClusterService1()Lcom/hazelcast/internal/cluster/ClusterService; RS 4T ! VgetResultProcessorRegistry8()Lcom/hazelcast/map/impl/query/ResultProcessorRegistry; XY ,Z "# \this.Lcom/hazelcast/map/impl/query/QueryEngineImpl;executep(Lcom/hazelcast/map/impl/query/Query;Lcom/hazelcast/map/impl/query/Target;)Lcom/hazelcast/map/impl/query/Result; adjustQueryJ(Lcom/hazelcast/map/impl/query/Query;)Lcom/hazelcast/map/impl/query/Query; bc d9$SwitchMap$com$hazelcast$map$impl$query$Target$TargetMode[I fg hmode2()Lcom/hazelcast/map/impl/query/Target$TargetMode; jk lordinal()I no prunOnAllPartitionsK(Lcom/hazelcast/map/impl/query/Query;)Lcom/hazelcast/map/impl/query/Result; rs trunOnLocalPartitions vs wrunOnGivenPartition ya z"java/lang/IllegalArgumentException|java/lang/StringBuilder~ 'Illegal target append-(Ljava/lang/String;)Ljava/lang/StringBuilder; -(Ljava/lang/Object;)Ljava/lang/StringBuilder; toString()Ljava/lang/String; (Ljava/lang/String;)V $ }query$Lcom/hazelcast/map/impl/query/Query;target%Lcom/hazelcast/map/impl/query/Target; adjustedQuery getPredicate!()Lcom/hazelcast/query/Predicate; getIterationType$()Lcom/hazelcast/util/IterationType; getRetrievalIterationTypee(Lcom/hazelcast/query/Predicate;Lcom/hazelcast/util/IterationType;)Lcom/hazelcast/util/IterationType; ofW(Lcom/hazelcast/map/impl/query/Query;)Lcom/hazelcast/map/impl/query/Query$QueryBuilder;  iterationTypeU(Lcom/hazelcast/util/IterationType;)Lcom/hazelcast/map/impl/query/Query$QueryBuilder; build&()Lcom/hazelcast/map/impl/query/Query; #com/hazelcast/query/PagingPredicatesetIterationType%(Lcom/hazelcast/util/IterationType;)V  com/hazelcast/util/IterationType!com/hazelcast/query/TruePredicateINSTANCE#Lcom/hazelcast/query/TruePredicate;  getMapName 'precheckMaxResultLimitOnLocalPartitions FretrievalIterationType"Lcom/hazelcast/util/IterationType;getLocalPartitionIds()Ljava/util/BitSet;  LOCAL_NODE doRunOnQueryThreads(Lcom/hazelcast/map/impl/query/Query;Ljava/util/BitSet;Lcom/hazelcast/map/impl/query/Target;)Lcom/hazelcast/map/impl/query/Result; isResultFromAnyPartitionMissing(Ljava/util/BitSet;)Z doRunOnPartitionThreads^(Lcom/hazelcast/map/impl/query/Query;Ljava/util/BitSet;Lcom/hazelcast/map/impl/query/Result;)V java/util/BitSet#com/hazelcast/map/impl/query/ResultassertAllPartitionsQueried(Ljava/util/BitSet;)V mutablePartitionIdsLjava/util/BitSet;result%Lcom/hazelcast/map/impl/query/Result;getAllPartitionIds  ALL_NODES java/lang/Throwable partitionId()Ljava/lang/Integer; java/lang/IntegerintValue o 8dispatchPartitionScanQueryOnOwnerMemberOnPartitionThreadD(Lcom/hazelcast/map/impl/query/Query;I)Ljava/util/concurrent/Future; java/util/concurrent/Futureget()Ljava/lang/Object;  com/hazelcast/util/ExceptionUtilrethrow3(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;  tLjava/lang/Throwable;populateResult](Lcom/hazelcast/map/impl/query/Query;Ljava/util/BitSet;)Lcom/hazelcast/map/impl/query/Result;  dispatchOnQueryThreads[(Lcom/hazelcast/map/impl/query/Query;Lcom/hazelcast/map/impl/query/Target;)Ljava/util/List;    addResultsOfPredicateK(Ljava/util/List;Lcom/hazelcast/map/impl/query/Result;Ljava/util/BitSet;Z)V   partitionIdsfuturesVLjava/util/List;>;Ljava/util/List;(Lcom/hazelcast/map/impl/query/Query;Lcom/hazelcast/map/impl/query/Target;)Ljava/util/List;>;dispatchFullQueryOnQueryThread  %com/hazelcast/core/HazelcastExceptiongetCause()Ljava/lang/Throwable;  2com/hazelcast/map/QueryResultSizeExceededException com/hazelcast/logging/ILogger" isFineEnabled()Z $% #&"Query invocation failed on member (fine*(Ljava/lang/String;Ljava/lang/Throwable;)V *+ #,java/util/Collections. emptyList()Ljava/util/List; 01 /2 getResultType 4< 54com/hazelcast/map/impl/query/ResultProcessorRegistry7A(Ljava/lang/Class;)Lcom/hazelcast/map/impl/query/ResultProcessor; 9 8: cardinality <o =getNodeResultLimit(I)J ?@ FA,com/hazelcast/map/impl/query/ResultProcessorCL(Lcom/hazelcast/map/impl/query/Query;J)Lcom/hazelcast/map/impl/query/Result; E DFH(Lcom/hazelcast/map/impl/query/Query;Ljava/util/BitSet;)Ljava/util/List; H I(Ljava/util/List;>;Lcom/hazelcast/map/impl/query/Result;Ljava/util/BitSet;Z)Vjava/util/ListLiterator()Ljava/util/Iterator; NO MPjava/util/IteratorRhasNext T% SUnext W SXCould not get query resultsZgetPartitionIds()Ljava/util/Collection; \] ^com/hazelcast/util/BitSetUtils` hasAllBitsSet)(Ljava/util/BitSet;Ljava/lang/Iterable;)Z bc adjava/util/Collectionf unsetBits)(Ljava/util/BitSet;Ljava/lang/Iterable;)V hi ajcombine((Lcom/hazelcast/map/impl/query/Result;)V lm n queryResultqueriedPartitionIds+Ljava/util/Collection;Ljava/util/Collection;futureDLjava/util/concurrent/Future;Ljava/util/concurrent/Future;finishedPartitionIds rethrowAllZ"com/hazelcast/query/QueryExceptionzBQuery aborted. Could not execute query for all partitions. Missed |(I)Ljava/lang/StringBuilder; ~  partitions { getComparator()Ljava/util/Comparator;  ENTRY  VALUE  pagingPredicate%Lcom/hazelcast/query/PagingPredicate; predicateLcom/hazelcast/query/Predicate;-com/hazelcast/spi/partition/IPartitionServicegetPartitionCount o (I)V $ getThisAddress()Lcom/hazelcast/nio/Address;  4getMemberPartitions-(Lcom/hazelcast/nio/Address;)Ljava/util/List;  setBits i apartitionCountIset(IIZ)V  isEmpty % getQueryResultSizeLimiter7()Lcom/hazelcast/map/impl/query/QueryResultSizeLimiter;*dispatchFullQueryOnAllMembersOnQueryThread6(Lcom/hazelcast/map/impl/query/Query;)Ljava/util/List;  +dispatchFullQueryOnLocalMemberOnQueryThread  |(Lcom/hazelcast/map/impl/query/Query;)Ljava/util/List;>;getMapOperationProviderK(Ljava/lang/String;)Lcom/hazelcast/map/impl/operation/MapOperationProvider;  ,5com/hazelcast/map/impl/operation/MapOperationProvidercreateQueryOperationU(Lcom/hazelcast/map/impl/query/Query;)Lcom/hazelcast/map/impl/operation/MapOperation;  hz:impl:mapService"com/hazelcast/spi/OperationServiceinvokeOnTargety(Ljava/lang/String;Lcom/hazelcast/spi/Operation;Lcom/hazelcast/nio/Address;)Lcom/hazelcast/spi/InternalCompletableFuture;   singletonList$(Ljava/lang/Object;)Ljava/util/List;  / operationLcom/hazelcast/spi/Operation;4com/hazelcast/cluster/memberselector/MemberSelectorsDATA_MEMBER_SELECTOR#Lcom/hazelcast/core/MemberSelector;  -com/hazelcast/internal/cluster/ClusterService getMembers;(Lcom/hazelcast/core/MemberSelector;)Ljava/util/Collection;  java/util/ArrayListsize o g  gPcom/hazelcast/core/MemberC(Lcom/hazelcast/map/impl/query/Query;)Lcom/hazelcast/spi/Operation;   getAddress  add(Ljava/lang/Object;)Z  MmemberLcom/hazelcast/core/Member;members3Ljava/util/Collection;(Lcom/hazelcast/map/impl/query/Query;Ljava/util/BitSet;)Ljava/util/List;>;shouldSkipPartitionsQuery   length o (I)Z  k(Lcom/hazelcast/map/impl/query/Query;I)Ljava/util/concurrent/Future;createQueryPartitionOperation  com/hazelcast/spi/OperationsetPartitionId (I)Lcom/hazelcast/spi/Operation;  invokeOnPartition_(Ljava/lang/String;Lcom/hazelcast/spi/Operation;I)Lcom/hazelcast/spi/InternalCompletableFuture;   op   CodeLineNumberTableLocalVariableTable StackMapTableLocalVariableTypeTable Signature InnerClasses SourceFile! !"#$%f*(*+**+02**28:**2*>BD*FY+*DIK**2OQ**2UW*+[]* JK LM N1OAPNQ[ReSf^_f`aZ*+eNi,mq..!'*-u*-x*-,{}YY+ ,WX,Z2\8^?`*Z^_ZZTbcK*++M+,N--+-*K-- 4e fg#h4j>kIn*K^_K >2vs%*M*+,ʷN*,ҙ *+,-*,- suvwy#{*%^_% rs%*M*+,N*,ҙ *+,-*,- #*%^_% ya*+,ڰN-U *^_*+, :*+- :*,>^_     @*+,N---!-*D'*D)--3G & #/<*4@^_@@c*]+6;+*K,>BG ^_*+,J:*-, :T> ^_   +Q:VzY:::):! *D[-_:-e-k,o!-0? S'MS g J!-02BHV[^glux~\ 2$!epgqshtv^_wxy gqrhtuKw.*+ҙ({YY}+>--.^_./,N+'+: N, ,N- @ -4/^_//-u+*:<YM,*:*2, ) +^_ !f*:<YM,,  ^_  L + @ ^_ w/*K  ^_ Ki,mq.%*+*+}YY+$ $*0 K^_KK0**++M*Q,*2N-Ͱ %+*0^_0+v +u,e*WչMY,N,:V9Y:*+:*Q:-W-#gMS?*   !9"@#K$P#W%`&c'H@ W tv9'e^_e XsJ W tu XJH**+++^_HB,3Y,N6, ,-*+W- M"01 34#5,6:4@94&B^_BB+ +#*+N-W*Q- : => @AB4#^_## H**++G^_ G* * @K   @