|
Move And Inline Method package start(ses Session, detached ObjectPoolReusable<H2ConnectionWrapper>) : void moved from class org.apache.ignite.internal.processors.query.h2.twostep.MapQueryLazyWorker to class org.apache.ignite.internal.processors.query.h2.twostep.GridMapQueryExecutor & inlined to private onQueryRequest0(node ClusterNode, reqId long, segmentId int, schemaName String, qrys Collection<GridCacheSqlQuery>, cacheIds List<Integer>, topVer AffinityTopologyVersion, partsMap Map<UUID,int[]>, parts int[], pageSize int, distributedJoinMode DistributedJoinMode, enforceJoinOrder boolean, replicated boolean, timeout int, params Object[], lazy boolean, mvccSnapshot MvccSnapshot, tx GridDhtTxLocalAdapter, txDetails GridH2SelectForUpdateTxDetails, lockFut CompoundLockFuture, runCntr AtomicInteger) : void |
From |
To |
|
Change Variable Type conn0 : ObjectPoolReusable<H2ConnectionWrapper> to conn0 : ThreadLocalObjectPool.Reusable<H2ConnectionWrapper> in method public beforeDetach() : void in class org.apache.ignite.internal.processors.query.h2.dml.UpdatePlan.AbstractIterator |
From |
To |
|
Change Variable Type r1 : ObjectPoolReusable<Obj> to o1 : Reusable<Obj> in method public testObjectShouldBeClosedOnRecycleIfPoolIsFull() : void in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPoolSelfTest |
From |
To |
|
Change Variable Type entry : Map.Entry<Thread,ConcurrentHashMap<H2ConnectionWrapper,Boolean>> to entry : Map.Entry<Thread,H2ConnectionWrapper> in method private cleanupStatementCache() : void in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Change Variable Type entry : Map.Entry<Thread,ConcurrentHashMap<H2ConnectionWrapper,Boolean>> to entry : Map.Entry<Thread,H2ConnectionWrapper> in method private cleanupConnections() : void in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Change Variable Type r2 : ObjectPoolReusable<Obj> to o2 : Reusable<Obj> in method public testObjectShouldNotBeReturnedIfPoolIsFull() : void in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPoolSelfTest |
From |
To |
|
Change Variable Type conn0 : ObjectPoolReusable<H2ConnectionWrapper> to conn0 : ThreadLocalObjectPool.Reusable<H2ConnectionWrapper> in method protected onClose() : void in class org.apache.ignite.internal.processors.query.h2.dml.UpdatePlan.AbstractIterator |
From |
To |
|
Change Variable Type r1 : ObjectPoolReusable<Obj> to o1 : Reusable<Obj> in method public testObjectIsReusedAfterRecycling() : void in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPoolSelfTest |
From |
To |
|
Change Variable Type it : Iterator<Map.Entry<Thread,ConcurrentHashMap<H2ConnectionWrapper,Boolean>>> to it : Iterator<Map.Entry<Thread,H2ConnectionWrapper>> in method private cleanupStatementCache() : void in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Change Variable Type r1 : ObjectPoolReusable<Obj> to o1 : Reusable<Obj> in method public testBorrowedObjectIsNotReturnedTwice() : void in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPoolSelfTest |
From |
To |
|
Change Variable Type r1 : ObjectPoolReusable<Obj> to o1 : Reusable<Obj> in method public testObjectShouldReturnedToRecyclingThreadBag() : void in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPoolSelfTest |
From |
To |
|
Change Variable Type r2 : ObjectPoolReusable<Obj> to o2 : Reusable<Obj> in method public testObjectShouldBeClosedOnRecycleIfPoolIsFull() : void in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPoolSelfTest |
From |
To |
|
Change Variable Type allNodesReady : IgniteCountDownLatch to nodesStartedLatch : CountDownLatch in method private waitForNodes() : void in class org.apache.ignite.yardstick.IgniteAbstractBenchmark |
From |
To |
|
Change Variable Type r1 : ObjectPoolReusable<Obj> to o1 : Reusable<Obj> in method public testObjectShouldNotBeReturnedIfPoolIsFull() : void in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPoolSelfTest |
From |
To |
|
Change Variable Type it : Iterator<Map.Entry<Thread,ConcurrentHashMap<H2ConnectionWrapper,Boolean>>> to it : Iterator<Map.Entry<Thread,H2ConnectionWrapper>> in method private cleanupConnections() : void in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Change Variable Type r2 : ObjectPoolReusable<Obj> to o2 : Reusable<Obj> in method public testBorrowedObjectIsNotReturnedTwice() : void in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPoolSelfTest |
From |
To |
|
Change Variable Type conns : ConcurrentMap<Thread,ConcurrentMap<H2ConnectionWrapper,Boolean>> to conns : ConcurrentMap<Thread,H2ConnectionWrapper> in method private getStatementCacheSize(qryProcessor GridQueryProcessor) : int in class org.apache.ignite.internal.processors.cache.IgniteCacheQueryH2IndexingLeakTest |
From |
To |
|
Change Variable Type conn : H2ConnectionWrapper to conn : Connection in method private onSqlException() : void in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Change Variable Type pooled : E to pooled : Reusable<E> in method public borrow() : Reusable<E> in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPool |
From |
To |
|
Rename Variable allNodesReady : IgniteCountDownLatch to nodesStartedLatch : CountDownLatch in method private waitForNodes() : void in class org.apache.ignite.yardstick.IgniteAbstractBenchmark |
From |
To |
|
Rename Variable r1 : ObjectPoolReusable<Obj> to o1 : Reusable<Obj> in method public testObjectShouldNotBeReturnedIfPoolIsFull() : void in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPoolSelfTest |
From |
To |
|
Rename Variable r2 : ObjectPoolReusable<Obj> to o2 : Reusable<Obj> in method public testBorrowedObjectIsNotReturnedTwice() : void in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPoolSelfTest |
From |
To |
|
Rename Variable r1 : ObjectPoolReusable<Obj> to o1 : Reusable<Obj> in method public testObjectShouldBeClosedOnRecycleIfPoolIsFull() : void in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPoolSelfTest |
From |
To |
|
Rename Variable qryResults : MapQueryResults to qr : MapQueryResults in method private onNextPageRequest(node ClusterNode, req GridQueryNextPageRequest) : void in class org.apache.ignite.internal.processors.query.h2.twostep.GridMapQueryExecutor |
From |
To |
|
Rename Variable r2 : ObjectPoolReusable<Obj> to o2 : Reusable<Obj> in method public testObjectShouldNotBeReturnedIfPoolIsFull() : void in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPoolSelfTest |
From |
To |
|
Rename Variable goldenRes : List<List<?>> to pRes : List<List<?>> in method private restarts(broadcastQry boolean) : void in class org.apache.ignite.internal.processors.cache.distributed.near.IgniteCacheQueryNodeRestartDistributedJoinSelfTest |
From |
To |
|
Rename Variable r1 : ObjectPoolReusable<Obj> to o1 : Reusable<Obj> in method public testObjectIsReusedAfterRecycling() : void in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPoolSelfTest |
From |
To |
|
Rename Variable r1 : ObjectPoolReusable<Obj> to o1 : Reusable<Obj> in method public testBorrowedObjectIsNotReturnedTwice() : void in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPoolSelfTest |
From |
To |
|
Rename Variable r1 : ObjectPoolReusable<Obj> to o1 : Reusable<Obj> in method public testObjectShouldReturnedToRecyclingThreadBag() : void in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPoolSelfTest |
From |
To |
|
Rename Variable r2 : ObjectPoolReusable<Obj> to o2 : Reusable<Obj> in method public testObjectShouldBeClosedOnRecycleIfPoolIsFull() : void in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPoolSelfTest |
From |
To |
|
Rename Variable qryResults : MapQueryResults to qr : MapQueryResults in method private onQueryRequest0(node ClusterNode, reqId long, segmentId int, schemaName String, qrys Collection<GridCacheSqlQuery>, cacheIds List<Integer>, topVer AffinityTopologyVersion, partsMap Map<UUID,int[]>, parts int[], pageSize int, distributedJoinMode DistributedJoinMode, enforceJoinOrder boolean, replicated boolean, timeout int, params Object[], lazy boolean, mvccSnapshot MvccSnapshot, tx GridDhtTxLocalAdapter, txDetails GridH2SelectForUpdateTxDetails, lockFut CompoundLockFuture, runCntr AtomicInteger) : void in class org.apache.ignite.internal.processors.query.h2.twostep.GridMapQueryExecutor |
From |
To |
|
Inline Method public checkShortLazyQuery(node Ignite) : void inlined to private checkBaseOperations(node Ignite) : void in class org.apache.ignite.internal.processors.query.LazyQuerySelfTest |
From |
To |
|
Inline Method public setupConnection(conn Connection, distributedJoins boolean, enforceJoinOrder boolean, lazy boolean) : void inlined to public setupConnection(conn Connection, distributedJoins boolean, enforceJoinOrder boolean) : void in class org.apache.ignite.internal.processors.query.h2.H2Utils |
From |
To |
|
Inline Method private assertQueryResults(rows List<List<?>>, resSize int) : void inlined to private assertBaseQueryResults(rows List<List<?>>) : void in class org.apache.ignite.internal.processors.query.LazyQuerySelfTest |
From |
To |
|
Inline Method private createLazyWorker(node ClusterNode, reqId long, segmentId int) : MapQueryLazyWorker inlined to private onQueryRequest0(node ClusterNode, reqId long, segmentId int, schemaName String, qrys Collection<GridCacheSqlQuery>, cacheIds List<Integer>, topVer AffinityTopologyVersion, partsMap Map<UUID,int[]>, parts int[], pageSize int, distributedJoinMode DistributedJoinMode, enforceJoinOrder boolean, replicated boolean, timeout int, params Object[], lazy boolean, mvccSnapshot MvccSnapshot, tx GridDhtTxLocalAdapter, txDetails GridH2SelectForUpdateTxDetails, lockFut CompoundLockFuture, runCntr AtomicInteger) : void in class org.apache.ignite.internal.processors.query.h2.twostep.GridMapQueryExecutor |
From |
To |
|
Inline Method public close() : void inlined to package cancel(forceQryCancel boolean) : void in class org.apache.ignite.internal.processors.query.h2.twostep.MapQueryResults |
From |
To |
|
Inline Method private stop0(nodeStop boolean) : void inlined to public stop(nodeStop boolean) : void in class org.apache.ignite.internal.processors.query.h2.twostep.MapQueryLazyWorker |
From |
To |
|
Change Attribute Type pool : ObjectPool<Obj> to pool : ThreadLocalObjectPool<Obj> in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPoolSelfTest |
From |
To |
|
Change Attribute Type conns : ConcurrentMap<Thread,ConcurrentHashMap<H2ConnectionWrapper,Boolean>> to conns : ConcurrentMap<Thread,H2ConnectionWrapper> in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Change Attribute Type connectionPool : ThreadLocal<ObjectPool<H2ConnectionWrapper>> to connectionPool : ThreadLocalObjectPool<H2ConnectionWrapper> in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Change Attribute Type connCache : ThreadLocal<ObjectPoolReusable<H2ConnectionWrapper>> to connCache : ThreadLocal<ThreadLocalObjectPool.Reusable<H2ConnectionWrapper>> in class org.apache.ignite.internal.processors.query.h2.IgniteH2Indexing |
From |
To |
|
Change Attribute Type pool : ObjectPool<T> to pool : ThreadLocalObjectPool<T> in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPool.Reusable |
From |
To |
|
Change Attribute Type bag : ConcurrentLinkedQueue<E> to bag : ThreadLocal<Queue<Reusable<E>>> in class org.apache.ignite.internal.processors.query.h2.ThreadLocalObjectPool |
From |
To |
|
Change Attribute Type conn : ObjectPoolReusable<H2ConnectionWrapper> to conn : ThreadLocalObjectPool.Reusable<H2ConnectionWrapper> in class org.apache.ignite.internal.processors.query.h2.dml.UpdatePlan.AbstractIterator |
From |
To |
|
Change Attribute Type log : IgniteLogger to lazyWorker : MapQueryLazyWorker in class org.apache.ignite.internal.processors.query.h2.twostep.MapQueryResult |
From |
To |
|
Extract And Move Method public lazyWorker(lazyWorker MapQueryLazyWorker) : GridH2QueryContext extracted from private onQueryRequest0(node ClusterNode, reqId long, segmentId int, schemaName String, qrys Collection<GridCacheSqlQuery>, cacheIds List<Integer>, topVer AffinityTopologyVersion, partsMap Map<UUID,int[]>, parts int[], pageSize int, distributedJoinMode DistributedJoinMode, enforceJoinOrder boolean, replicated boolean, timeout int, params Object[], lazy boolean, mvccSnapshot MvccSnapshot, tx GridDhtTxLocalAdapter, txDetails GridH2SelectForUpdateTxDetails, lockFut CompoundLockFuture, runCntr AtomicInteger) : void in class org.apache.ignite.internal.processors.query.h2.twostep.GridMapQueryExecutor & moved to class org.apache.ignite.internal.processors.query.h2.opt.GridH2QueryContext |
From |
To |