4.com/hazelcast/mapreduce/impl/MapKeyValueSourceLcom/hazelcast/mapreduce/KeyValueSource;Lcom/hazelcast/nio/serialization/IdentifiedDataSerializable;Lcom/hazelcast/mapreduce/PartitionIdAware;&com/hazelcast/mapreduce/KeyValueSource:com/hazelcast/nio/serialization/IdentifiedDataSerializable(com/hazelcast/mapreduce/PartitionIdAwareMapKeyValueSource.java1Lcom/hazelcast/nio/serialization/BinaryInterface;java/util/Map$Entry  java/util/MapEntry cachedEntry3Lcom/hazelcast/mapreduce/impl/MapReduceSimpleEntry;;Lcom/hazelcast/mapreduce/impl/MapReduceSimpleEntry;mapNameLjava/lang/String; partitionIdIss6Lcom/hazelcast/spi/serialization/SerializationService;iteratorLjava/util/Iterator;; currentRecord&Lcom/hazelcast/map/impl/record/Record;()V  !1com/hazelcast/mapreduce/impl/MapReduceSimpleEntry# $!  &this8Lcom/hazelcast/mapreduce/impl/MapKeyValueSource;0Lcom/hazelcast/mapreduce/impl/MapKeyValueSource;(Ljava/lang/String;)V  , getMapName()Ljava/lang/String;open!(Lcom/hazelcast/spi/NodeEngine;)Z%com/hazelcast/spi/impl/NodeEngineImpl2getPartitionService=()Lcom/hazelcast/internal/partition/InternalPartitionService; 45 36hz:impl:mapService8 getService&(Ljava/lang/String;)Ljava/lang/Object; :; 3<!com/hazelcast/map/impl/MapService>getSerializationService8()Lcom/hazelcast/spi/serialization/SerializationService; @A 3B  D  F-com/hazelcast/spi/partition/IPartitionServiceHgetPartitionOwner(I)Lcom/hazelcast/nio/Address; JK ILcom/hazelcast/spi/NodeEngineNcom/hazelcast/nio/AddressPgetMapServiceContext,()Lcom/hazelcast/map/impl/MapServiceContext; RS ?T(com/hazelcast/map/impl/MapServiceContextVgetRecordStoreE(ILjava/lang/String;)Lcom/hazelcast/map/impl/recordstore/RecordStore; XY WZ.com/hazelcast/map/impl/recordstore/RecordStore\()Ljava/util/Iterator; ^ ]_  a nodeEngineLcom/hazelcast/spi/NodeEngine;nei'Lcom/hazelcast/spi/impl/NodeEngineImpl;ps/Lcom/hazelcast/spi/partition/IPartitionService; mapService#Lcom/hazelcast/map/impl/MapService;partitionOwnerLcom/hazelcast/nio/Address; recordStore0Lcom/hazelcast/map/impl/recordstore/RecordStore;closejava/io/IOExceptionphasNext()Zjava/util/Iteratort rs uvnext()Ljava/lang/Object; xy uz$com/hazelcast/map/impl/record/Record|  ~Zkey()TK;java/lang/IllegalStateExceptionno more elements + getKey(()Lcom/hazelcast/nio/serialization/Data; }4com/hazelcast/spi/serialization/SerializationServicetoObject&(Ljava/lang/Object;)Ljava/lang/Object;  setKeyData)(Lcom/hazelcast/nio/serialization/Data;)V $setKey $keyData&Lcom/hazelcast/nio/serialization/Data;TK;Ljava/lang/Object;element()Ljava/util/Map$Entry;()Ljava/util/Map$Entry; getKeyData $java/lang/Objectequals(Ljava/lang/Object;)Z getValue y }setValue $resetsetPartitionId(I)V writeData'(Lcom/hazelcast/nio/ObjectDataOutput;)V"com/hazelcast/nio/ObjectDataOutputwriteUTF + out$Lcom/hazelcast/nio/ObjectDataOutput;readData&(Lcom/hazelcast/nio/ObjectDataInput;)V!com/hazelcast/nio/ObjectDataInputreadUTF / in#Lcom/hazelcast/nio/ObjectDataInput; getFactoryId()I8com/hazelcast/mapreduce/impl/MapReduceDataSerializerHookF_ID  getId SignatureCodeLineNumberTableLocalVariableTableLocalVariableTypeTable StackMapTable Exceptions InnerClasses SourceFileRuntimeVisibleAnnotations!  T*"*$Y%'>5? (* ()+g*"*$Y%'*+-A5BC(* ()./A*-F (* ()01Q+3M,7N,9=?:*,CE-*GM:U*G*-[:*`b0O3I?Q* KL MNO)P.Q0SDTOUHQ(*QcdLef Ggh<ij)(klD mn Q()o =[ (* ()qrs$*bw<**b{}!}_ `"a$(* r $()y9* Y*L*E+M*'+*',W,fgij&k.l7m 9(*&9()&`* Y**'*'*E*W*'*E*W*'/rsu'vAx[y `(* `()sP *b*~  (*  ()P*G (* ()U +*-   (*   ()qU *+-   (*   ()q@ˬ (* ()> (* ()