|
Move Method private partitionedUnstableDataNodes(cacheIds List<Integer>, qryId long) : Map<ClusterNode,IntArray> from class org.apache.ignite.internal.processors.query.h2.twostep.GridReduceQueryExecutor to private partitionedUnstableDataNodes(cacheIds List<Integer>, qryId long) : Map<ClusterNode,IntArray> from class org.apache.ignite.internal.processors.query.h2.twostep.ReducePartitionMapper |
From |
To |
|
Move Method private replicatedUnstableDataNodes(cacheIds List<Integer>, qryId long) : Collection<ClusterNode> from class org.apache.ignite.internal.processors.query.h2.twostep.GridReduceQueryExecutor to private replicatedUnstableDataNodes(cacheIds List<Integer>, qryId long) : Collection<ClusterNode> from class org.apache.ignite.internal.processors.query.h2.twostep.ReducePartitionMapper |
From |
To |
|
Move Method private logRetry(msg String) : void from class org.apache.ignite.internal.processors.query.h2.twostep.GridReduceQueryExecutor to private logRetry(msg String) : void from class org.apache.ignite.internal.processors.query.h2.twostep.ReducePartitionMapper |
From |
To |
|
Move Method private nodesForPartitions(cacheIds List<Integer>, topVer AffinityTopologyVersion, parts int[], isReplicatedOnly boolean, qryId long) : NodesForPartitionsResult from class org.apache.ignite.internal.processors.query.h2.twostep.GridReduceQueryExecutor to public nodesForPartitions(cacheIds List<Integer>, topVer AffinityTopologyVersion, parts int[], isReplicatedOnly boolean, qryId long) : ReducePartitionMapResult from class org.apache.ignite.internal.processors.query.h2.twostep.ReducePartitionMapper |
From |
To |
|
Move Method private narrowForQuery(partsMap Map<ClusterNode,IntArray>, parts int[]) : Map<ClusterNode,IntArray> from class org.apache.ignite.internal.processors.query.h2.twostep.GridReduceQueryExecutor to private narrowForQuery(partsMap Map<ClusterNode,IntArray>, parts int[]) : Map<ClusterNode,IntArray> from class org.apache.ignite.internal.processors.query.h2.twostep.ReducePartitionMapper |
From |
To |
|
Move Method private isPreloadingActive(cacheIds List<Integer>) : boolean from class org.apache.ignite.internal.processors.query.h2.twostep.GridReduceQueryExecutor to private isPreloadingActive(cacheIds List<Integer>) : boolean from class org.apache.ignite.internal.processors.query.h2.twostep.ReducePartitionMapper |
From |
To |
|
Move Method private hasMovingPartitions(cctx GridCacheContext<?,?>) : boolean from class org.apache.ignite.internal.processors.query.h2.twostep.GridReduceQueryExecutor to private hasMovingPartitions(cctx GridCacheContext<?,?>) : boolean from class org.apache.ignite.internal.processors.query.h2.twostep.ReducePartitionMapper |
From |
To |
|
Move Method private stableDataNodes(isReplicatedOnly boolean, topVer AffinityTopologyVersion, cacheIds List<Integer>, parts int[], qryId long) : Map<ClusterNode,IntArray> from class org.apache.ignite.internal.processors.query.h2.twostep.GridReduceQueryExecutor to private stableDataNodes(isReplicatedOnly boolean, topVer AffinityTopologyVersion, cacheIds List<Integer>, parts int[], qryId long) : Map<ClusterNode,IntArray> from class org.apache.ignite.internal.processors.query.h2.twostep.ReducePartitionMapper |
From |
To |
|
Move Method private replicatedUnstableDataNodes(cctx GridCacheContext<?,?>, qryId long) : Set<ClusterNode> from class org.apache.ignite.internal.processors.query.h2.twostep.GridReduceQueryExecutor to private replicatedUnstableDataNodes(cctx GridCacheContext<?,?>, qryId long) : Set<ClusterNode> from class org.apache.ignite.internal.processors.query.h2.twostep.ReducePartitionMapper |
From |
To |
|
Move Method private dataNodes(grpId int, topVer AffinityTopologyVersion) : Collection<ClusterNode> from class org.apache.ignite.internal.processors.query.h2.twostep.GridReduceQueryExecutor to private dataNodes(grpId int, topVer AffinityTopologyVersion) : Collection<ClusterNode> from class org.apache.ignite.internal.processors.query.h2.twostep.ReducePartitionMapper |
From |
To |
|
Move Method private stableDataNodesMap(topVer AffinityTopologyVersion, cctx GridCacheContext<?,?>, parts int[]) : Map<ClusterNode,IntArray> from class org.apache.ignite.internal.processors.query.h2.twostep.GridReduceQueryExecutor to private stableDataNodesMap(topVer AffinityTopologyVersion, cctx GridCacheContext<?,?>, parts int[]) : Map<ClusterNode,IntArray> from class org.apache.ignite.internal.processors.query.h2.twostep.ReducePartitionMapper |
From |
To |
|
Change Variable Type partsSpec : ExplicitPartitionsSpecializer to partsSpec : ReducePartitionsSpecializer in method public update(schemaName String, cacheIds List<Integer>, selectQry String, params Object[], enforceJoinOrder boolean, pageSize int, timeoutMillis int, parts int[], isReplicatedOnly boolean, cancel GridQueryCancel) : UpdateResult in class org.apache.ignite.internal.processors.query.h2.twostep.GridReduceQueryExecutor |
From |
To |
|
Change Variable Type nodesParts : NodesForPartitionsResult to nodesParts : ReducePartitionMapResult in method public update(schemaName String, cacheIds List<Integer>, selectQry String, params Object[], enforceJoinOrder boolean, pageSize int, timeoutMillis int, parts int[], isReplicatedOnly boolean, cancel GridQueryCancel) : UpdateResult in class org.apache.ignite.internal.processors.query.h2.twostep.GridReduceQueryExecutor |
From |
To |
|
Change Variable Type nodesParts : NodesForPartitionsResult to nodesParts : ReducePartitionMapResult in method public query(schemaName String, qry GridCacheTwoStepQuery, keepBinary boolean, enforceJoinOrder boolean, timeoutMillis int, cancel GridQueryCancel, params Object[], parts int[], lazy boolean, mvccTracker MvccQueryTracker) : Iterator<List<?>> in class org.apache.ignite.internal.processors.query.h2.twostep.GridReduceQueryExecutor |
From |
To |