|
Change Parameter Type updater : IgniteDataStreamer.Updater to updater : IgniteDataStreamer.Updater<?,?> in method package DataStreamerUpdateJob(ctx GridKernalContext, log IgniteLogger, cacheName String, col Collection<DataStreamerEntry>, ignoreDepOwnership boolean, skipStore boolean, updater IgniteDataStreamer.Updater<?,?>) in class org.apache.ignite.internal.processors.datastream.DataStreamerUpdateJob |
From |
To |
|
Change Parameter Type col : Collection<IgniteDataLoaderEntry> to col : Collection<DataStreamerEntry> in method package DataStreamerUpdateJob(ctx GridKernalContext, log IgniteLogger, cacheName String, col Collection<DataStreamerEntry>, ignoreDepOwnership boolean, skipStore boolean, updater IgniteDataStreamer.Updater<?,?>) in class org.apache.ignite.internal.processors.datastream.DataStreamerUpdateJob |
From |
To |
|
Change Parameter Type entries : Collection<? extends IgniteDataLoaderEntry> to entries : Collection<? extends DataStreamerEntry> in method private load0(entries Collection<? extends DataStreamerEntry>, resFut GridFutureAdapter<Object>, activeKeys Collection<KeyCacheObject>, remaps int) : void in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl |
From |
To |
|
Change Parameter Type req : GridDataLoadRequest to req : DataStreamerRequest in method private processRequest(nodeId UUID, req DataStreamerRequest) : void in class org.apache.ignite.internal.processors.datastream.DataStreamerProcessor |
From |
To |
|
Change Parameter Type entries : Collection<IgniteDataLoaderEntry> to entries : Collection<DataStreamerEntry> in method private submit(entries Collection<DataStreamerEntry>, curFut GridFutureAdapter<Object>) : void in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl.Buffer |
From |
To |
|
Change Parameter Type ldr : IgniteDataStreamerImpl<K,V> to ldr : DataStreamerImpl<K,V> in method private LocalStoreLoadClosure(p IgniteBiPredicate<K,V>, ldr DataStreamerImpl<K,V>, plc ExpiryPolicy) in class org.apache.ignite.internal.processors.cache.GridCacheAdapter.LocalStoreLoadClosure |
From |
To |
|
Change Parameter Type entries : Collection<? extends IgniteDataLoaderEntry> to entries : Collection<? extends DataStreamerEntry> in method public addDataInternal(entries Collection<? extends DataStreamerEntry>) : IgniteFuture<?> in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl |
From |
To |
|
Change Parameter Type entries : Collection<IgniteDataLoaderEntry> to entries : Collection<DataStreamerEntry> in method public DataStreamerRequest(reqId long, resTopicBytes byte[], cacheName String, updaterBytes byte[], entries Collection<DataStreamerEntry>, ignoreDepOwnership boolean, skipStore boolean, depMode DeploymentMode, sampleClsName String, userVer String, ldrParticipants Map<UUID,IgniteUuid>, clsLdrId IgniteUuid, forceLocDep boolean) in class org.apache.ignite.internal.processors.datastream.DataStreamerRequest |
From |
To |
|
Change Parameter Type res : GridDataLoadResponse to res : DataStreamerResponse in method package onResponse(res DataStreamerResponse) : void in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl.Buffer |
From |
To |
|
Change Parameter Type dataLdr : IgniteDataStreamerImpl to dataLdr : DataStreamerImpl in method package DataStreamerFuture(dataLdr DataStreamerImpl) in class org.apache.ignite.internal.processors.datastream.DataStreamerFuture |
From |
To |
|
Change Parameter Type newEntries : Iterable<IgniteDataLoaderEntry> to newEntries : Iterable<DataStreamerEntry> in method package update(newEntries Iterable<DataStreamerEntry>, lsnr IgniteInClosure<IgniteInternalFuture<?>>) : GridFutureAdapter<?> in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl.Buffer |
From |
To |
|
Change Parameter Type flushQ : DelayQueue<IgniteDataStreamerImpl<K,V>> to flushQ : DelayQueue<DataStreamerImpl<K,V>> in method public DataStreamerImpl(ctx GridKernalContext, cacheName String, flushQ DelayQueue<DataStreamerImpl<K,V>>) in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl |
From |
To |
|
Rename Class org.apache.ignite.internal.processors.datastream.IgniteDataStreamerProcessor renamed to org.apache.ignite.internal.processors.datastream.DataStreamerProcessor |
From |
To |
|
Rename Class org.apache.ignite.internal.processors.datastream.IgniteDataStreamerCacheUpdaters renamed to org.apache.ignite.internal.processors.datastream.DataStreamerCacheUpdaters |
From |
To |
|
Rename Class org.apache.ignite.internal.processors.datastream.IgniteDataStreamerFuture renamed to org.apache.ignite.internal.processors.datastream.DataStreamerFuture |
From |
To |
|
Rename Class org.apache.ignite.internal.processors.datastream.IgniteDataStreamerProcessorSelfTest renamed to org.apache.ignite.internal.processors.datastream.DataStreamerProcessorSelfTest |
From |
To |
|
Rename Class org.apache.ignite.internal.processors.datastream.IgniteDataLoaderEntry renamed to org.apache.ignite.internal.processors.datastream.DataStreamerEntry |
From |
To |
|
Rename Class org.apache.ignite.internal.processors.datastream.IgniteDataStreamerImplSelfTest renamed to org.apache.ignite.internal.processors.datastream.DataStreamerImplSelfTest |
From |
To |
|
Rename Class org.apache.ignite.internal.processors.datastream.IgniteDataStreamerImpl renamed to org.apache.ignite.internal.processors.datastream.DataStreamerImpl |
From |
To |
|
Rename Class org.apache.ignite.internal.processors.datastream.IgniteDataStreamerUpdateJob renamed to org.apache.ignite.internal.processors.datastream.DataStreamerUpdateJob |
From |
To |
|
Rename Class org.apache.ignite.internal.processors.datastream.GridDataLoadResponse renamed to org.apache.ignite.internal.processors.datastream.DataStreamerResponse |
From |
To |
|
Rename Class org.apache.ignite.internal.processors.datastream.GridDataLoadRequest renamed to org.apache.ignite.internal.processors.datastream.DataStreamerRequest |
From |
To |
|
Change Variable Type col : Collection<IgniteDataLoaderEntry> to col : Collection<DataStreamerEntry> in method private processRequest(nodeId UUID, req DataStreamerRequest) : void in class org.apache.ignite.internal.processors.datastream.DataStreamerProcessor |
From |
To |
|
Change Variable Type res : GridDataLoadResponse to res : DataStreamerResponse in method public onMessage(nodeId UUID, msg Object) : void in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl.DataStreamerImpl.addMessageListener |
From |
To |
|
Change Variable Type entries0 : List<IgniteDataLoaderEntry> to entries0 : List<DataStreamerEntry> in method package flush() : IgniteInternalFuture<?> in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl.Buffer |
From |
To |
|
Change Variable Type dataLdr : IgniteDataStreamerImpl<KeyCacheObject,Object> to dataLdr : DataStreamerImpl<KeyCacheObject,Object> in method public call() : Object in class org.apache.ignite.internal.processors.cache.distributed.GridDistributedCacheAdapter.GlobalRemoveAllCallable |
From |
To |
|
Change Variable Type req : GridDataLoadRequest to req : DataStreamerRequest in method private submit(entries Collection<DataStreamerEntry>, curFut GridFutureAdapter<Object>) : void in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl.Buffer |
From |
To |
|
Change Variable Type ldr : IgniteDataStreamerImpl<K,V> to ldr : DataStreamerImpl<K,V> in method public dataStreamer(cacheName String) : DataStreamerImpl<K,V> in class org.apache.ignite.internal.processors.datastream.DataStreamerProcessor |
From |
To |
|
Change Variable Type ldr : IgniteDataStreamerImpl to ldr : DataStreamerImpl in method public localLoadCache(p IgniteBiPredicate<K,V>, args Object[]) : void in class org.apache.ignite.internal.processors.cache.GridCacheAdapter |
From |
To |
|
Change Variable Type col : Collection<IgniteDataLoaderEntry> to col : Collection<DataStreamerEntry> in method private localLoadAndUpdate(keys Collection<? extends K>) : void in class org.apache.ignite.internal.processors.cache.GridCacheAdapter |
From |
To |
|
Change Variable Type entry : IgniteDataLoaderEntry to entry : DataStreamerEntry in method package update(newEntries Iterable<DataStreamerEntry>, lsnr IgniteInClosure<IgniteInternalFuture<?>>) : GridFutureAdapter<?> in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl.Buffer |
From |
To |
|
Change Variable Type ldr : IgniteDataStreamerImpl<?,?> to ldr : DataStreamerImpl<?,?> in method public onKernalStop(cancel boolean) : void in class org.apache.ignite.internal.processors.datastream.DataStreamerProcessor |
From |
To |
|
Change Variable Type ldr : IgniteDataStreamerImpl<K,V> to ldr : DataStreamerImpl<K,V> in method public start() : void in class org.apache.ignite.internal.processors.datastream.DataStreamerProcessor |
From |
To |
|
Change Variable Type e : IgniteDataLoaderEntry to e : DataStreamerEntry in method public call() : Object in class org.apache.ignite.internal.processors.datastream.DataStreamerUpdateJob |
From |
To |
|
Change Variable Type ldr : IgniteDataStreamerImpl<KeyCacheObject,CacheObject> to ldr : DataStreamerImpl<KeyCacheObject,CacheObject> in method private localLoadAndUpdate(keys Collection<? extends K>) : void in class org.apache.ignite.internal.processors.cache.GridCacheAdapter |
From |
To |
|
Change Variable Type job : IgniteDataStreamerUpdateJob to job : DataStreamerUpdateJob in method private processRequest(nodeId UUID, req DataStreamerRequest) : void in class org.apache.ignite.internal.processors.datastream.DataStreamerProcessor |
From |
To |
|
Change Variable Type mappings : Map<ClusterNode,Collection<IgniteDataLoaderEntry>> to mappings : Map<ClusterNode,Collection<DataStreamerEntry>> in method private load0(entries Collection<? extends DataStreamerEntry>, resFut GridFutureAdapter<Object>, activeKeys Collection<KeyCacheObject>, remaps int) : void in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl |
From |
To |
|
Change Variable Type entriesForNode : Collection<IgniteDataLoaderEntry> to entriesForNode : Collection<DataStreamerEntry> in method private load0(entries Collection<? extends DataStreamerEntry>, resFut GridFutureAdapter<Object>, activeKeys Collection<KeyCacheObject>, remaps int) : void in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl |
From |
To |
|
Change Variable Type e : IgniteDataLoaderEntry to e : DataStreamerEntry in method private submit(entries Collection<DataStreamerEntry>, curFut GridFutureAdapter<Object>) : void in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl.Buffer |
From |
To |
|
Change Variable Type e : Map.Entry<ClusterNode,Collection<IgniteDataLoaderEntry>> to e : Map.Entry<ClusterNode,Collection<DataStreamerEntry>> in method private load0(entries Collection<? extends DataStreamerEntry>, resFut GridFutureAdapter<Object>, activeKeys Collection<KeyCacheObject>, remaps int) : void in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl |
From |
To |
|
Change Variable Type entry : IgniteDataLoaderEntry to entry : DataStreamerEntry in method public addDataInternal(entries Collection<? extends DataStreamerEntry>) : IgniteFuture<?> in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl |
From |
To |
|
Change Variable Type entries0 : Collection<? extends IgniteDataLoaderEntry> to entries0 : Collection<? extends DataStreamerEntry> in method public addData(entries Collection<? extends Map.Entry<K,V>>) : IgniteFuture<?> in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl |
From |
To |
|
Change Variable Type ldr : IgniteDataStreamerImpl to ldr : DataStreamerImpl in method public localLoad(keys Collection<? extends K>, plc ExpiryPolicy) : void in class org.apache.ignite.internal.processors.cache.GridCacheAdapter |
From |
To |
|
Change Variable Type entries0 : List<IgniteDataLoaderEntry> to entries0 : List<DataStreamerEntry> in method package update(newEntries Iterable<DataStreamerEntry>, lsnr IgniteInClosure<IgniteInternalFuture<?>>) : GridFutureAdapter<?> in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl.Buffer |
From |
To |
|
Change Variable Type res : GridDataLoadResponse to res : DataStreamerResponse in method private sendResponse(nodeId UUID, resTopic Object, reqId long, err Throwable, forceLocDep boolean) : void in class org.apache.ignite.internal.processors.datastream.DataStreamerProcessor |
From |
To |
|
Change Variable Type entry : IgniteDataLoaderEntry to entry : DataStreamerEntry in method private load0(entries Collection<? extends DataStreamerEntry>, resFut GridFutureAdapter<Object>, activeKeys Collection<KeyCacheObject>, remaps int) : void in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl |
From |
To |
|
Change Variable Type e : IgniteDataLoaderEntry to e : DataStreamerEntry in method private load0(entries Collection<? extends DataStreamerEntry>, resFut GridFutureAdapter<Object>, activeKeys Collection<KeyCacheObject>, remaps int) : void in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl |
From |
To |
|
Change Variable Type col : Collection<IgniteDataLoaderEntry> to col : Collection<DataStreamerEntry> in method private load0(entries Collection<? extends DataStreamerEntry>, resFut GridFutureAdapter<Object>, activeKeys Collection<KeyCacheObject>, remaps int) : void in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl |
From |
To |
|
Change Attribute Type entries : List<IgniteDataLoaderEntry> to entries : List<DataStreamerEntry> in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl.Buffer |
From |
To |
|
Change Attribute Type entries : Collection<IgniteDataLoaderEntry> to entries : Collection<DataStreamerEntry> in class org.apache.ignite.internal.processors.datastream.DataStreamerRequest |
From |
To |
|
Change Attribute Type ldr : IgniteDataStreamerImpl<K,V> to ldr : DataStreamerImpl<K,V> in class org.apache.ignite.internal.processors.cache.GridCacheAdapter.LocalStoreLoadClosure |
From |
To |
|
Change Attribute Type ldrs : Collection<IgniteDataStreamerImpl> to ldrs : Collection<DataStreamerImpl> in class org.apache.ignite.internal.processors.datastream.DataStreamerProcessor |
From |
To |
|
Change Attribute Type dataLdrProc : IgniteDataStreamerProcessor to dataLdrProc : DataStreamerProcessor in class org.apache.ignite.internal.GridKernalContextImpl |
From |
To |
|
Change Attribute Type col : Collection<IgniteDataLoaderEntry> to col : Collection<DataStreamerEntry> in class org.apache.ignite.internal.processors.datastream.DataStreamerUpdateJob |
From |
To |
|
Change Attribute Type dataLdr : IgniteDataStreamerImpl to dataLdr : DataStreamerImpl in class org.apache.ignite.internal.processors.datastream.DataStreamerFuture |
From |
To |
|
Change Attribute Type flushQ : DelayQueue<IgniteDataStreamerImpl<K,V>> to flushQ : DelayQueue<DataStreamerImpl<K,V>> in class org.apache.ignite.internal.processors.datastream.DataStreamerProcessor |
From |
To |
|
Change Attribute Type flushQ : DelayQueue<IgniteDataStreamerImpl<K,V>> to flushQ : DelayQueue<DataStreamerImpl<K,V>> in class org.apache.ignite.internal.processors.datastream.DataStreamerImpl |
From |
To |