|
Rename Variable nodeId0 : ClusterNode to node : ClusterNode in method public flushBackupQueue(ctx GridKernalContext, topVer AffinityTopologyVersion) : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler.register.lsnr |
From |
To |
|
Rename Variable e : CacheContinuousQueryEntry to entryOrList : Object in method private onEntryUpdate(evt CacheContinuousQueryEvent, notify boolean, loc boolean, recordIgniteEvt boolean) : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Rename Variable localRoutineInfo : LocalRoutineInfo to locRoutineInfo : LocalRoutineInfo in method public addBackupNotification(nodeId UUID, routineId UUID, objs Collection<?>, orderedTopic Object) : void in class org.apache.ignite.internal.processors.continuous.GridContinuousProcessor |
From |
To |
|
Rename Variable oldRec : EntryBuffer to oldBuf : CacheContinuousQueryEventBuffer in method private partitionBuffer(cctx GridCacheContext, part int) : CacheContinuousQueryEventBuffer in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Change Variable Type e : CacheContinuousQueryEntry to entryOrList : Object in method private onEntryUpdate(evt CacheContinuousQueryEvent, notify boolean, loc boolean, recordIgniteEvt boolean) : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Change Variable Type oldRec : EntryBuffer to oldBuf : CacheContinuousQueryEventBuffer in method private partitionBuffer(cctx GridCacheContext, part int) : CacheContinuousQueryEventBuffer in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Change Variable Type rec : PartitionRecovery to rec : CacheContinuousQueryPartitionRecovery in method private getOrCreatePartitionRecovery(ctx GridKernalContext, partId int, topVer AffinityTopologyVersion) : CacheContinuousQueryPartitionRecovery in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Change Variable Type buf : EntryBuffer to buf : CacheContinuousQueryEventBuffer in method private partitionBuffer(cctx GridCacheContext, part int) : CacheContinuousQueryEventBuffer in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Change Variable Type oldRec : PartitionRecovery to oldRec : CacheContinuousQueryPartitionRecovery in method private getOrCreatePartitionRecovery(ctx GridKernalContext, partId int, topVer AffinityTopologyVersion) : CacheContinuousQueryPartitionRecovery in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Change Variable Type rec : PartitionRecovery to rec : CacheContinuousQueryPartitionRecovery in method private handleEvent(ctx GridKernalContext, e CacheContinuousQueryEntry) : Collection<CacheEntryEvent<? extends K,? extends V>> in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Change Variable Type rec : PartitionRecovery to rec : CacheContinuousQueryPartitionRecovery in method public onClientDisconnected() : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Inline Variable backupQueue0 : Collection<CacheContinuousQueryEntry> in method public flushBackupQueue(ctx GridKernalContext, topVer AffinityTopologyVersion) : void from class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler.register.lsnr |
From |
To |
|
Inline Variable backupQueue : Collection<Object> in method public apply() : boolean from class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryFailoverAbstractSelfTest.testBackupQueueCleanupClientQuery.waitForCondition |
From |
To |
|
Inline Variable backupQueue : Collection<Object> in method public testBackupQueueCleanupServerQuery() : void from class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryFailoverAbstractSelfTest |
From |
To |
|
Inline Variable backupQueue : Collection<Object> in method public testBackupQueueCleanupClientQuery() : void from class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryFailoverAbstractSelfTest |
From |
To |
|
Inline Variable backupQueue : Collection<Object> in method public testBackupQueueEvict() : void from class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryFailoverAbstractSelfTest |
From |
To |
|
Change Attribute Type allEvts : List<CacheEntryEvent<?,?>> to allEvts : CopyOnWriteArrayList<CacheEntryEvent<?,?>> in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryFailoverAbstractSelfTest.CacheEventListener1 |
From |
To |
|
Change Attribute Type rcvs : ConcurrentMap<Integer,PartitionRecovery> to rcvs : ConcurrentMap<Integer,CacheContinuousQueryPartitionRecovery> in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Change Attribute Type rmtFilterFactoryDep : DeployableObject to rmtFilterFactoryDep : CacheContinuousQueryDeployableObject in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandlerV2 |
From |
To |
|
Change Attribute Type entryBufs : ConcurrentMap<Integer,EntryBuffer> to entryBufs : ConcurrentMap<Integer,CacheContinuousQueryEventBuffer> in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Change Attribute Type pendingEvts : Map<Long,CacheContinuousQueryEntry> to pendingEvts : TreeMap<Long,CacheContinuousQueryEntry> in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryPartitionRecovery |
From |
To |
|
Change Attribute Type ackBuf : AcknowledgeBuffer to ackBuf : CacheContinuousQueryAcknowledgeBuffer in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Change Attribute Type rmtFilterDep : DeployableObject to rmtFilterDep : CacheContinuousQueryDeployableObject in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Change Attribute Type filteredEvts : GridLongList to filteredCnt : long in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryEntry |
From |
To |