|
Change Parameter Type max : int to max : long in method public waitForMaximumCurrentTasks(max long, id long, periodToTrigger int, trigger Consumer<Long>) : void in class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Change Parameter Type ap : AsyncProcess to ap : MyAsyncProcess in method private testTaskCount(ap MyAsyncProcess) : void in class org.apache.hadoop.hbase.client.TestAsyncProcess |
From |
To |
|
Change Parameter Type rows : RowAccess<? extends Row> to rows : List<? extends Row> in method public submit(tableName TableName, rows List<? extends Row>, atLeastOne boolean, callback Batch.Callback<CResult>, needResults boolean) : AsyncRequestFuture in class org.apache.hadoop.hbase.client.TestAsyncProcess.MyAsyncProcess |
From |
To |
|
Change Parameter Type tableName : String to tableName : TableName in method public waitForAllPreviousOpsAndReset(failedRows List<Row>, tableName TableName) : RetriesExhaustedWithDetailsException in class org.apache.hadoop.hbase.client.AsyncProcess |
From |
To |
|
Move Method public testSubmittedSizeChecker() : void from class org.apache.hadoop.hbase.client.TestAsyncProcess to public testSubmittedSizeChecker() : void from class org.apache.hadoop.hbase.client.TestSimpleRequestController |
From |
To |
|
Move Method public testTaskCheckerHost() : void from class org.apache.hadoop.hbase.client.TestAsyncProcess to public testTaskCheckerHost() : void from class org.apache.hadoop.hbase.client.TestSimpleRequestController |
From |
To |
|
Move Method public testWaitForMaximumCurrentTasks() : void from class org.apache.hadoop.hbase.client.TestAsyncProcess to public testWaitForMaximumCurrentTasks() : void from class org.apache.hadoop.hbase.client.TestSimpleRequestController |
From |
To |
|
Move Method package waitForMaximumCurrentTasks(max int, tasksInProgress AtomicLong, id long, tableName String) : void from class org.apache.hadoop.hbase.client.AsyncProcess to public waitForMaximumCurrentTasks(max long, id long, periodToTrigger int, trigger Consumer<Long>) : void from class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Move Method public testTaskCountChecker() : void from class org.apache.hadoop.hbase.client.TestAsyncProcess to public testTaskCountChecker() : void from class org.apache.hadoop.hbase.client.TestSimpleRequestController |
From |
To |
|
Move Method package logDetailsOfUndoneTasks(taskInProgress long) : void from class org.apache.hadoop.hbase.client.AsyncProcess to private logDetailsOfUndoneTasks(taskInProgress long) : void from class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Move Method public testRequestSizeCheckerr() : void from class org.apache.hadoop.hbase.client.TestAsyncProcess to public testRequestSizeCheckerr() : void from class org.apache.hadoop.hbase.client.TestSimpleRequestController |
From |
To |
|
Move Attribute protected pool : ExecutorService from class org.apache.hadoop.hbase.client.AsyncProcess to private pool : ExecutorService from class org.apache.hadoop.hbase.client.AsyncProcessTask.Builder |
From |
To |
|
Move Attribute protected taskCounterPerServer : ConcurrentMap<ServerName,AtomicInteger> from class org.apache.hadoop.hbase.client.AsyncProcess to package taskCounterPerServer : ConcurrentMap<ServerName,AtomicInteger> from class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Move Attribute private operationTimeout : int from class org.apache.hadoop.hbase.client.TestAsyncProcess.MyAsyncProcess to private operationTimeout : int from class org.apache.hadoop.hbase.client.BufferedMutatorParams |
From |
To |
|
Move Attribute private writeRpcTimeout : int from class org.apache.hadoop.hbase.client.BufferedMutatorImpl to private writeRpcTimeout : int from class org.apache.hadoop.hbase.client.ConnectionConfiguration |
From |
To |
|
Move Attribute public DEFAULT_HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE : long from class org.apache.hadoop.hbase.client.AsyncProcess to package DEFAULT_HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE : long from class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Move Attribute protected maxHeapSizePerRequest : long from class org.apache.hadoop.hbase.client.AsyncProcess to private maxHeapSizePerRequest : long from class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Move Attribute private rpcTimeout : int from class org.apache.hadoop.hbase.client.TestAsyncProcess.MyAsyncProcess to private rpcTimeout : int from class org.apache.hadoop.hbase.client.BufferedMutatorParams |
From |
To |
|
Move Attribute private operationTimeout : int from class org.apache.hadoop.hbase.client.TestAsyncProcess.AsyncProcessForThrowableCheck to private operationTimeout : int from class org.apache.hadoop.hbase.client.AsyncProcessTask |
From |
To |
|
Move Attribute protected operationTimeout : int from class org.apache.hadoop.hbase.client.AsyncProcess to private operationTimeout : int from class org.apache.hadoop.hbase.client.AsyncProcessTask.Builder |
From |
To |
|
Move Attribute public DEFAULT_HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE : long from class org.apache.hadoop.hbase.client.AsyncProcess to package DEFAULT_HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE : long from class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Move Attribute private operationTimeout : int from class org.apache.hadoop.hbase.client.TestAsyncProcess.MyAsyncProcess to private operationTimeout : int from class org.apache.hadoop.hbase.client.AsyncProcessTask |
From |
To |
|
Move Attribute private THRESHOLD_TO_LOG_UNDONE_TASK_DETAILS : String from class org.apache.hadoop.hbase.client.AsyncProcess to public THRESHOLD_TO_LOG_UNDONE_TASK_DETAILS : String from class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Move Attribute protected maxConcurrentTasksPerServer : int from class org.apache.hadoop.hbase.client.AsyncProcess to package maxConcurrentTasksPerServer : int from class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Move Attribute protected rpcTimeout : int from class org.apache.hadoop.hbase.client.AsyncProcess to private rpcTimeout : int from class org.apache.hadoop.hbase.client.AsyncProcessTask.Builder |
From |
To |
|
Move Attribute public HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE : String from class org.apache.hadoop.hbase.client.AsyncProcess to public HBASE_CLIENT_MAX_PERREQUEST_HEAPSIZE : String from class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Move Attribute protected maxTotalConcurrentTasks : int from class org.apache.hadoop.hbase.client.AsyncProcess to private maxTotalConcurrentTasks : int from class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Move Attribute protected thresholdToLogUndoneTaskDetails : int from class org.apache.hadoop.hbase.client.AsyncProcess to private thresholdToLogUndoneTaskDetails : int from class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Move Attribute protected taskCounterPerRegion : ConcurrentMap<byte[],AtomicInteger> from class org.apache.hadoop.hbase.client.AsyncProcess to package taskCounterPerRegion : ConcurrentMap<byte[],AtomicInteger> from class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Move Attribute private rpcTimeout : int from class org.apache.hadoop.hbase.client.TestAsyncProcess.MyAsyncProcess to private rpcTimeout : int from class org.apache.hadoop.hbase.client.AsyncProcessTask |
From |
To |
|
Move Attribute private rpcTimeout : int from class org.apache.hadoop.hbase.client.TestAsyncProcess.AsyncProcessForThrowableCheck to private rpcTimeout : int from class org.apache.hadoop.hbase.client.AsyncProcessTask |
From |
To |
|
Move Attribute public HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE : String from class org.apache.hadoop.hbase.client.AsyncProcess to public HBASE_CLIENT_MAX_SUBMIT_HEAPSIZE : String from class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Move Attribute protected maxHeapSizeSubmit : long from class org.apache.hadoop.hbase.client.AsyncProcess to private maxHeapSizeSubmit : long from class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Move Attribute private rpcTimeout : int from class org.apache.hadoop.hbase.client.TestAsyncProcess.AsyncProcessForThrowableCheck to private rpcTimeout : int from class org.apache.hadoop.hbase.client.BufferedMutatorParams |
From |
To |
|
Move Attribute private DEFAULT_THRESHOLD_TO_LOG_UNDONE_TASK_DETAILS : int from class org.apache.hadoop.hbase.client.AsyncProcess to private DEFAULT_THRESHOLD_TO_LOG_UNDONE_TASK_DETAILS : int from class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Move Attribute protected maxConcurrentTasksPerRegion : int from class org.apache.hadoop.hbase.client.AsyncProcess to package maxConcurrentTasksPerRegion : int from class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Move Attribute protected tasksInProgress : AtomicLong from class org.apache.hadoop.hbase.client.AsyncProcess to package tasksInProgress : AtomicLong from class org.apache.hadoop.hbase.client.SimpleRequestController |
From |
To |
|
Move Attribute private operationTimeout : int from class org.apache.hadoop.hbase.client.TestAsyncProcess.AsyncProcessForThrowableCheck to private operationTimeout : int from class org.apache.hadoop.hbase.client.BufferedMutatorParams |
From |
To |
|
Merge Parameter [pool : ExecutorService, callback : Batch.Callback<CResult>, tableName : TableName, needResults : boolean, results : Object[], operationTimeout : int, rpcTimeout : int, callable : CancellableRegionServerCallable] to task : AsyncProcessTask in method public AsyncRequestFutureImpl(task AsyncProcessTask, actions List<Action>, nonceGroup long, asyncProcess AsyncProcess) in class org.apache.hadoop.hbase.client.AsyncRequestFutureImpl |
From |
To |
|
Merge Parameter [tableName : TableName, pool : ExecutorService, needResults : boolean, results : Object[], callback : Batch.Callback, callable : CancellableRegionServerCallable, operationTimeout : int, rpcTimeout : int] to task : AsyncProcessTask in method public MyAsyncRequestFutureImpl(task AsyncProcessTask, actions List<Action>, nonceGroup long, asyncProcess AsyncProcess) in class org.apache.hadoop.hbase.client.TestAsyncProcess.MyAsyncRequestFutureImpl |
From |
To |
|
Push Down Method public submit(tableName TableName, rows RowAccess<? extends Row>, atLeastOne boolean, callback Batch.Callback<CResult>, needResults boolean) : AsyncRequestFuture from class org.apache.hadoop.hbase.client.AsyncProcess to public submit(tableName TableName, rows List<? extends Row>, atLeastOne boolean, callback Batch.Callback<CResult>, needResults boolean) : AsyncRequestFuture from class org.apache.hadoop.hbase.client.TestAsyncProcess.MyAsyncProcess |
From |
To |
|
Push Down Method public submit(pool ExecutorService, tableName TableName, rows List<? extends Row>, atLeastOne boolean, callback Batch.Callback<CResult>, needResults boolean) : AsyncRequestFuture from class org.apache.hadoop.hbase.client.AsyncProcess to public submit(tableName TableName, rows List<? extends Row>, atLeastOne boolean, callback Batch.Callback<CResult>, needResults boolean) : AsyncRequestFuture from class org.apache.hadoop.hbase.client.TestAsyncProcess.MyAsyncProcess |
From |
To |