Êþº¾4¨;com/hazelcast/mapreduce/impl/task/JobProcessInformationImpljava/lang/Object-com/hazelcast/mapreduce/JobProcessInformationJobProcessInformationImpl.java/com/hazelcast/mapreduce/JobPartitionState$State)com/hazelcast/mapreduce/JobPartitionState StatePARTITION_STATE9Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;¤Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater;PROCESSED_RECORDS7Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;vLjava/util/concurrent/atomic/AtomicIntegerFieldUpdater; supervisor1Lcom/hazelcast/mapreduce/impl/task/JobSupervisor;processedRecordsIpartitionStates,[Lcom/hazelcast/mapreduce/JobPartitionState;5(ILcom/hazelcast/mapreduce/impl/task/JobSupervisor;)V()V       this=Lcom/hazelcast/mapreduce/impl/task/JobProcessInformationImpl;partitionCountgetPartitionStates.()[Lcom/hazelcast/mapreduce/JobPartitionState;4Ledu/umd/cs/findbugs/annotations/SuppressFBWarnings;value EI_EXPOSE_REP justification×Exposed array is used a lot on internals and is explicitly exposed for speed / object creation reasons. It is never exposed to the end user (either through serialization cycle or by hiding in through a wrapper classgetProcessedRecords()I  .addProcessedRecords(I)V  25java/util/concurrent/atomic/AtomicIntegerFieldUpdater4 addAndGet(Ljava/lang/Object;I)I 67 58recordscancelPartitionStategetOwner()Lcom/hazelcast/nio/Address; => ?com/hazelcast/nio/AddressA7com/hazelcast/mapreduce/impl/task/JobPartitionStateImplC CANCELLED1Lcom/hazelcast/mapreduce/JobPartitionState$State; EF GO(Lcom/hazelcast/nio/Address;Lcom/hazelcast/mapreduce/JobPartitionState$State;)V I DJownerLcom/hazelcast/nio/Address;ioldPartitionStatesnewPartitionStatesupdatePartitionStateZ(ILcom/hazelcast/mapreduce/JobPartitionState;Lcom/hazelcast/mapreduce/JobPartitionState;)Z %& Sjava/util/ArraysUcopyOf)([Ljava/lang/Object;I)[Ljava/lang/Object; WX VY[([Lcom/hazelcast/mapreduce/JobPartitionState;[Lcom/hazelcast/mapreduce/JobPartitionState;)Z Q[ \ partitionIdoldPartitionState+Lcom/hazelcast/mapreduce/JobPartitionState;newPartitionStateP com/hazelcast/util/Preconditionsc isNotNull8(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object; ef dg"java/lang/IllegalArgumentExceptioni(partitionStates need to have same lengthk(Ljava/lang/String;)V m jn  p7java/util/concurrent/atomic/AtomicReferenceFieldUpdaterr compareAndSet9(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z tu sv/com/hazelcast/mapreduce/impl/task/JobSupervisorxcheckFullyProcessed2(Lcom/hazelcast/mapreduce/JobProcessInformation;)V z{ y|toString()Ljava/lang/String;java/lang/StringBuilder€ +JobProcessInformationImpl{processedRecords=ƒappend-(Ljava/lang/String;)Ljava/lang/StringBuilder; …† ‡(I)Ljava/lang/StringBuilder; …‰ Š, partitionStates=Œ'([Ljava/lang/Object;)Ljava/lang/String; ~Ž V(C)Ljava/lang/StringBuilder; …‘ ’ ~ ” newUpdatero(Ljava/lang/Class;Ljava/lang/Class;Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicReferenceFieldUpdater; ˜™ sš\(Ljava/lang/Class;Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater; ˜ 5ž SignatureCodeLineNumberTableLocalVariableTableRuntimeInvisibleAnnotations StackMapTable InnerClasses SourceFile!   BB ¡\*·*,µ*½ µ!±¢34 56£ "#$%&¡/*´!°¢>£ "#¤'([s)*s+,-¡/*´/¬¢C£ "#01¡B ²3*¶9W±¢ G H£ "# :;¡ÊB*´!L+¾½ M>,¾¢,+2Æ+2¹@§:,»DY²H·KS„§ÿÔ*,µ!±¥þ <<@Bú¢"KL MN'O6M<RAS£4'LM /NB"#=O 7PQR¡¼2*¶T:2,¥¬¾¸ZÀ<:-S*¶]™¬§ÿÑ¥ ü<ú¢"YZ[^_"`-a/c£>)OP2"#2^2_`2a`Q[¡0,b¸hW+¾,¾Ÿ »jYl·o¿²q*+,¶w™ *´*¶}¬¬¥¢ghik$l,m.o£ 0"#0O0P~¡]+»Y·‚„¶ˆ*´/¶‹¶ˆ*´!¸¶ˆ}¶“¶•°¢tu*t£ +"#–¡;<—¸›³qœ¸Ÿ³3±¢' )*)¦  @§