|
Change Parameter Type contQryFilter : IgnitePredicate<CacheContinuousQueryEntry<K,V>> to contQryFilter : CacheEntryEventFilter<K,V> in method public CacheQueryReadEvent(node ClusterNode, msg String, type int, qryType CacheQueryType, cacheName String, clsName String, clause String, scanQryFilter IgniteBiPredicate<K,V>, contQryFilter CacheEntryEventFilter<K,V>, args Object[], subjId UUID, taskName String, key K, val V, oldVal V, row Object) in class org.apache.ignite.events.CacheQueryReadEvent |
From |
To |
|
Change Parameter Type filter : IgnitePredicate<CacheContinuousQueryEntry<K,V>> to rmtFilter : CacheEntryEventFilter<K,V> in method public CacheContinuousQueryHandler(cacheName String, topic Object, locLsnr CacheEntryUpdatedListener<K,V>, rmtFilter CacheEntryEventFilter<K,V>, internal boolean, oldValRequired boolean, sync boolean, ignoreExpired boolean, taskHash int, skipPrimaryCheck boolean) in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Change Parameter Type src : IgniteCache to source : Cache in method package CacheContinuousQueryEvent(source Cache, eventType EventType, e CacheContinuousQueryEntry<K,V>) in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryEvent |
From |
To |
|
Change Parameter Type contQryMgr : GridCacheContinuousQueryManager<K,V> to contQryMgr : CacheContinuousQueryManager<K,V> in method public GridCacheContext(ctx GridKernalContext, sharedCtx GridCacheSharedContext, cacheCfg CacheConfiguration, evtMgr GridCacheEventManager<K,V>, swapMgr GridCacheSwapManager<K,V>, serMgr IgniteCacheSerializationManager<K,V>, storeMgr GridCacheStoreManager<K,V>, evictMgr GridCacheEvictionManager<K,V>, qryMgr GridCacheQueryManager<K,V>, contQryMgr CacheContinuousQueryManager<K,V>, affMgr GridCacheAffinityManager<K,V>, dataStructuresMgr CacheDataStructuresManager<K,V>, ttlMgr GridCacheTtlManager<K,V>, drMgr GridCacheDrManager<K,V>, jtaMgr CacheJtaManagerAdapter<K,V>) in class org.apache.ignite.internal.processors.cache.GridCacheContext |
From |
To |
|
Change Parameter Type contQryFilter : IgnitePredicate<CacheContinuousQueryEntry<K,V>> to contQryFilter : CacheEntryEventFilter<K,V> in method public CacheQueryExecutedEvent(node ClusterNode, msg String, type int, qryType CacheQueryType, cacheName String, clsName String, clause String, scanQryFilter IgniteBiPredicate<K,V>, contQryFilter CacheEntryEventFilter<K,V>, args Object[], subjId UUID, taskName String) in class org.apache.ignite.events.CacheQueryExecutedEvent |
From |
To |
|
Change Parameter Type e : CacheContinuousQueryEntry to e : CacheEntryEvent<? extends K,? extends V> in method public evaluate(e CacheEntryEvent<? extends K,? extends V>) : boolean in class org.apache.ignite.internal.processors.cache.datastructures.CacheDataStructuresManager.QueueHeaderPredicate |
From |
To |
|
Change Parameter Type lsnrCfg : CacheEntryListenerConfiguration to lsnrCfg : CacheEntryListenerConfiguration<K,V> in method public deregisterCacheEntryListener(lsnrCfg CacheEntryListenerConfiguration<K,V>) : void in class org.apache.ignite.internal.processors.cache.IgniteCacheProxy |
From |
To |
|
Change Parameter Type lsnr : GridCacheContinuousQueryListener<K,V> to lsnr : CacheContinuousQueryListener<K,V> in method package registerListener(lsnrId UUID, lsnr CacheContinuousQueryListener<K,V>, internal boolean) : boolean in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryManager |
From |
To |
|
Change Parameter Type updated : Iterable<CacheContinuousQueryEntry<GridHadoopJobId,GridHadoopJobMetadata>> to updated : Iterable<CacheEntryEvent<? extends GridHadoopJobId,? extends GridHadoopJobMetadata>> in method private processJobMetadataUpdates(updated Iterable<CacheEntryEvent<? extends GridHadoopJobId,? extends GridHadoopJobMetadata>>) : void in class org.apache.ignite.internal.processors.hadoop.jobtracker.GridHadoopJobTracker |
From |
To |
|
Rename Variable recordEvt : boolean to recordIgniteEvt : boolean in method public onEntryUpdated(e GridCacheEntryEx<K,V>, key K, newVal V, newBytes GridCacheValueBytes, oldVal V, oldBytes GridCacheValueBytes) : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryManager |
From |
To |
|
Rename Variable info : ListenerInfo to lsnr : CacheContinuousQueryListener<K,V> in method package unregisterListener(internal boolean, id UUID) : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryManager |
From |
To |
|
Rename Variable e : Map.Entry<K,V> to evt : CacheEntryEvent<? extends K,? extends V> in method public notifyCallback(nodeId UUID, routineId UUID, objs Collection<?>, ctx GridKernalContext) : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Rename Variable entries : Collection<CacheContinuousQueryEntry<K,V>> to evts : Collection<CacheEntryEvent<? extends K,? extends V>> in method public notifyCallback(nodeId UUID, routineId UUID, objs Collection<?>, ctx GridKernalContext) : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Rename Variable qe : GridCacheContinuousQueryEntry<K,V> to e : CacheContinuousQueryEntry<? extends K,? extends V> in method public notifyCallback(nodeId UUID, routineId UUID, objs Collection<?>, ctx GridKernalContext) : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Rename Variable lsnrCfgs : Iterable<CacheEntryListenerConfiguration<K,V>> to cfgs : Iterable<CacheEntryListenerConfiguration<K,V>> in method protected onKernalStart0() : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryManager |
From |
To |
|
Change Variable Type cache2 : GridCache<Integer,Integer> to cache2 : IgniteCache<Integer,Integer> in method public testCrossCallback() : void in class org.apache.ignite.internal.processors.cache.query.continuous.GridCacheContinuousQueryReplicatedSelfTest |
From |
To |
|
Change Variable Type cache : GridCache<Integer,Integer> to cache : IgniteCache<Integer,Integer> in method public testBuffering() : void in class org.apache.ignite.internal.processors.cache.query.continuous.GridCacheContinuousQueryAbstractSelfTest |
From |
To |
|
Change Variable Type cache : GridCache<Integer,Integer> to cache : IgniteCache<Integer,Integer> in method public testLocalNodeOnly() : void in class org.apache.ignite.internal.processors.cache.query.continuous.GridCacheContinuousQueryAbstractSelfTest |
From |
To |
|
Change Variable Type info : ListenerInfo to lsnr : CacheContinuousQueryListener<K,V> in method package unregisterListener(internal boolean, id UUID) : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryManager |
From |
To |
|
Change Variable Type lsnr : ListenerInfo<K,V> to lsnr : CacheContinuousQueryListener<K,V> in method public onEntryUpdated(e GridCacheEntryEx<K,V>, key K, newVal V, newBytes GridCacheValueBytes, oldVal V, oldBytes GridCacheValueBytes) : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryManager |
From |
To |
|
Change Variable Type lsnrCol : ConcurrentMap<UUID,ListenerInfo<K,V>> to lsnrCol : ConcurrentMap<UUID,CacheContinuousQueryListener<K,V>> in method public onEntryUpdated(e GridCacheEntryEx<K,V>, key K, newVal V, newBytes GridCacheValueBytes, oldVal V, oldBytes GridCacheValueBytes) : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryManager |
From |
To |
|
Change Variable Type lsnrCol : ConcurrentMap<UUID,ListenerInfo<K,V>> to lsnrCol : ConcurrentMap<UUID,CacheContinuousQueryListener<K,V>> in method public onEntryExpired(e GridCacheEntryEx<K,V>, key K, oldVal V, oldBytes GridCacheValueBytes) : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryManager |
From |
To |
|
Change Variable Type lsnr : ListenerInfo<K,V> to lsnr : CacheContinuousQueryListener<K,V> in method public onEntryExpired(e GridCacheEntryEx<K,V>, key K, oldVal V, oldBytes GridCacheValueBytes) : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryManager |
From |
To |
|
Change Variable Type contQryMgr : GridCacheContinuousQueryManager to contQryMgr : CacheContinuousQueryManager in method public main(args String[]) : void in class org.apache.ignite.loadtests.continuous.GridContinuousOperationsLoadTest |
From |
To |
|
Change Variable Type cache : GridCache<Integer,Integer> to cache : IgniteCache<Integer,Integer> in method public testAllEntries() : void in class org.apache.ignite.internal.processors.cache.query.continuous.GridCacheContinuousQueryAbstractSelfTest |
From |
To |
|
Change Variable Type cache2 : GridCache<Integer,Integer> to cache2 : IgniteCache<Integer,Integer> in method public testRemoteNodeCallback() : void in class org.apache.ignite.internal.processors.cache.query.continuous.GridCacheContinuousQueryReplicatedSelfTest |
From |
To |
|
Change Variable Type lsnr : GridCacheContinuousQueryListener<K,V> to lsnr : CacheContinuousQueryListener<K,V> in method public register(nodeId UUID, routineId UUID, ctx GridKernalContext) : boolean in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Change Variable Type cache : GridCache<Integer,Integer> to cache : IgniteCache<Integer,Integer> in method public testEvents() : void in class org.apache.ignite.internal.processors.cache.query.continuous.GridCacheContinuousQueryAbstractSelfTest |
From |
To |
|
Change Variable Type cache : GridCache<Integer,Integer> to cache : IgniteCache<Integer,Integer> in method public testLoadCache() : void in class org.apache.ignite.internal.processors.cache.query.continuous.GridCacheContinuousQueryAbstractSelfTest |
From |
To |
|
Change Variable Type mgr : GridCacheContinuousQueryManager to mgr : CacheContinuousQueryManager in method protected afterTest() : void in class org.apache.ignite.internal.processors.cache.query.continuous.GridCacheContinuousQueryAbstractSelfTest |
From |
To |
|
Change Variable Type cache : GridCache<Integer,String> to cache : IgniteCache<Integer,String> in method public main(args String[]) : void in class org.apache.ignite.examples.datagrid.CacheContinuousQueryExample |
From |
To |
|
Change Variable Type cache : GridCache<Integer,Integer> to cache : IgniteCache<Integer,Integer> in method public testTimeInterval() : void in class org.apache.ignite.internal.processors.cache.query.continuous.GridCacheContinuousQueryAbstractSelfTest |
From |
To |
|
Change Variable Type entries : Collection<CacheContinuousQueryEntry<K,V>> to evts : Collection<CacheEntryEvent<? extends K,? extends V>> in method public notifyCallback(nodeId UUID, routineId UUID, objs Collection<?>, ctx GridKernalContext) : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Change Variable Type cache1 : GridCache<Integer,Integer> to cache1 : IgniteCache<Integer,Integer> in method public testRemoteNodeCallback() : void in class org.apache.ignite.internal.processors.cache.query.continuous.GridCacheContinuousQueryReplicatedSelfTest |
From |
To |
|
Change Variable Type cache : GridCache<Object,Object> to cache : IgniteCache<Object,Object> in method public testInternalKey() : void in class org.apache.ignite.internal.processors.cache.query.continuous.GridCacheContinuousQueryAbstractSelfTest |
From |
To |
|
Change Variable Type cache : GridCache<Integer,Integer> to cache : IgniteCache<Integer,Integer> in method public testEntriesByFilter() : void in class org.apache.ignite.internal.processors.cache.query.continuous.GridCacheContinuousQueryAbstractSelfTest |
From |
To |
|
Change Variable Type cache : GridCache<Object,Object> to cache : IgniteCache<Object,Object> in method public main(args String[]) : void in class org.apache.ignite.loadtests.continuous.GridContinuousOperationsLoadTest |
From |
To |
|
Change Variable Type contQryMgr : GridCacheContinuousQueryManager to contQryMgr : CacheContinuousQueryManager in method public start() : void in class org.apache.ignite.internal.processors.cache.GridCacheProcessor |
From |
To |
|
Change Variable Type cache1 : GridCache<Integer,Integer> to cache1 : IgniteCache<Integer,Integer> in method public testCrossCallback() : void in class org.apache.ignite.internal.processors.cache.query.continuous.GridCacheContinuousQueryReplicatedSelfTest |
From |
To |
|
Change Variable Type e : Map.Entry<K,V> to evt : CacheEntryEvent<? extends K,? extends V> in method public notifyCallback(nodeId UUID, routineId UUID, objs Collection<?>, ctx GridKernalContext) : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |
|
Change Variable Type all : Collection<Map.Entry<Integer,Integer>> to all : Collection<CacheEntryEvent<? extends Integer,? extends Integer>> in method public testNodeJoin() : void in class org.apache.ignite.internal.processors.cache.query.continuous.GridCacheContinuousQueryAbstractSelfTest |
From |
To |
|
Change Variable Type cache : GridCache<Integer,Integer> to cache : IgniteCache<Integer,Integer> in method public testNodeJoin() : void in class org.apache.ignite.internal.processors.cache.query.continuous.GridCacheContinuousQueryAbstractSelfTest |
From |
To |
|
Change Variable Type entry : Map.Entry<GridHadoopJobId,GridHadoopJobMetadata> to entry : CacheEntryEvent<? extends GridHadoopJobId,? extends GridHadoopJobMetadata> in method private processJobMetadataUpdates(updated Iterable<CacheEntryEvent<? extends GridHadoopJobId,? extends GridHadoopJobMetadata>>) : void in class org.apache.ignite.internal.processors.hadoop.jobtracker.GridHadoopJobTracker |
From |
To |
|
Change Variable Type qe : GridCacheContinuousQueryEntry<K,V> to e : CacheContinuousQueryEntry<? extends K,? extends V> in method public notifyCallback(nodeId UUID, routineId UUID, objs Collection<?>, ctx GridKernalContext) : void in class org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryHandler |
From |
To |