Toggle navigation
Home
org.apache.ignite.binary.BinaryType to org.apache.ignite.internal.portable.BinaryMetadata
No. of Instances - 15
No. of Commits - 1
No. of Projects - {'ignite'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Add or Remove Method invocation
key.typeId()
to
oldMeta0
checkMeta(oldMeta0,oldMeta,newMeta,null)
to
checkMeta(key,oldMeta0,newMeta,null)
key.typeId()
to
oldMeta0
checkMeta(oldMeta0,oldMeta,newMeta,null)
to
checkMeta(key,oldMeta0,newMeta,null)
key.typeId()
to
key0
key0
to
key
checkMeta(typeId,oldMeta,newMeta,null)
to
checkMeta(typeId,oldMeta,newMeta0,null)
checkMeta(typeId,oldMeta,newMeta,fields)
to
checkMeta(typeId,oldMeta,newMeta0,fields)
newMeta.typeName()
to
newMeta0.typeName()
newMeta.affinityKeyFieldName()
to
newMeta0.affinityKeyFieldName()
metaBuf.put(typeId,newMeta)
to
metaBuf.put(typeId,newMeta0)
CacheObjectBinaryProcessorImpl.this.addMeta(typeId,newMeta)
to
CacheObjectBinaryProcessorImpl.this.addMeta(typeId,newMeta0.wrap(portableCtx))
Rename Variable
newMeta
to
newMeta0
newMeta
to
newMeta0
newMeta
to
newMeta0
oldMeta
to
oldMeta0
oldMeta
to
oldMeta0
Cascading Type Change (Different)
PortableMetaDataKey
to
Integer
ConcurrentHashMap8.BiFun<PortableMetaDataKey,BinaryType,BinaryType>
to
ConcurrentHashMap8.BiFun<Integer,BinaryTypeImpl,BinaryTypeImpl>
BinaryType
to
BinaryTypeImpl
Update Anonymous class
{ @Override public BinaryType apply( PortableMetaDataKey key, BinaryType oldMeta){ BinaryType res; try { res=checkMeta(key.typeId(),oldMeta,newMeta,null) ? newMeta : oldMeta; } catch ( BinaryObjectException e) { res=oldMeta; } return res; } }
to
{ @Override public BinaryTypeImpl apply( Integer key, BinaryTypeImpl oldMeta){ BinaryMetadata res; BinaryMetadata oldMeta0=oldMeta != null ? oldMeta.metadata() : null; try { res=checkMeta(key,oldMeta0,newMeta,null) ? newMeta : oldMeta0; } catch ( BinaryObjectException e) { res=oldMeta0; } return res != null ? res.wrap(portableCtx) : null; } }
{ @Override public void addMeta( int typeId, BinaryType newMeta) throws BinaryObjectException { if (metaDataCache == null) { BinaryType oldMeta=metaBuf.get(typeId); if (oldMeta == null || checkMeta(typeId,oldMeta,newMeta,null)) { synchronized (this) { Map<String,String> fields=new HashMap<>(); if (checkMeta(typeId,oldMeta,newMeta,fields)) { newMeta=new BinaryMetaDataImpl(newMeta.typeName(),fields,newMeta.affinityKeyFieldName()); metaBuf.put(typeId,newMeta); } else return; } if (metaDataCache == null) return; else metaBuf.remove(typeId); } else return; } CacheObjectBinaryProcessorImpl.this.addMeta(typeId,newMeta); } @Override public BinaryType metadata( int typeId) throws BinaryObjectException { if (metaDataCache == null) U.awaitQuiet(startLatch); return CacheObjectBinaryProcessorImpl.this.metadata(typeId); } }
to
{ @Override public void addMeta( int typeId, BinaryType newMeta) throws BinaryObjectException { assert newMeta != null; assert newMeta instanceof BinaryTypeImpl; BinaryMetadata newMeta0=((BinaryTypeImpl)newMeta).metadata(); if (metaDataCache == null) { BinaryMetadata oldMeta=metaBuf.get(typeId); if (oldMeta == null || checkMeta(typeId,oldMeta,newMeta0,null)) { synchronized (this) { Map<String,Integer> fields=new HashMap<>(); if (checkMeta(typeId,oldMeta,newMeta0,fields)) { newMeta0=new BinaryMetadata(typeId,newMeta0.typeName(),fields,newMeta0.affinityKeyFieldName()); metaBuf.put(typeId,newMeta0); } else return; } if (metaDataCache == null) return; else metaBuf.remove(typeId); } else return; } CacheObjectBinaryProcessorImpl.this.addMeta(typeId,newMeta0.wrap(portableCtx)); } @Override public BinaryType metadata( int typeId) throws BinaryObjectException { if (metaDataCache == null) U.awaitQuiet(startLatch); return CacheObjectBinaryProcessorImpl.this.metadata(typeId); } }
Cascading Type Change (Similar)
PortableMetaDataHandler
to
BinaryMetadataHandler
Map<String,String>
to
Map<String,Integer>
BinaryMetaDataImpl
to
BinaryMetadata