|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public getBlocked() : ListenableFuture<?> in class com.facebook.presto.execution.scheduler.ScheduleResult |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method private fetchSplits(min int, max int, output List<Split>) : ListenableFuture<?> in class com.facebook.presto.split.BufferingSplitSource |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public toWhenHasSplitQueueSpaceFuture(blockedNodes Set<Node>, existingTasks List<RemoteTask>, spaceThreshold int) : ListenableFuture<?> in class com.facebook.presto.execution.scheduler.NodeScheduler |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement CreateSchema, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.CreateSchemaTask |
From |
To |
|
Change Return Type CompletableFuture<BufferResult> to ExtendedSettableFuture<BufferResult> in method public getFutureResult() : ExtendedSettableFuture<BufferResult> in class com.facebook.presto.execution.buffer.LazyOutputBuffer.PendingRead |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement CreateView, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.CreateViewTask |
From |
To |
|
Change Return Type CompletableFuture<BufferResult> to ListenableFuture<BufferResult> in method public getPages(sequenceId long, maxSize DataSize) : ListenableFuture<BufferResult> in class com.facebook.presto.execution.buffer.ClientBuffer |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(call Call, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.CallTask |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public isDestroyed() : ListenableFuture<?> in class com.facebook.presto.operator.PartitionedLookupSourceFactory |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement Deallocate, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.DeallocateTask |
From |
To |
|
Change Return Type CompletableFuture<TaskInfo> to ListenableFuture<TaskInfo> in method public getTaskInfo(taskId TaskId, currentState TaskState) : ListenableFuture<TaskInfo> in class com.facebook.presto.execution.TaskManager |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public whenSplitQueueHasSpace(threshold int) : ListenableFuture<?> in class com.facebook.presto.execution.RemoteTask |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public whenSplitQueueHasSpace(threshold int) : ListenableFuture<?> in class com.facebook.presto.server.remotetask.HttpRemoteTask |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement T, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.DataDefinitionTask |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public getBlocked() : ListenableFuture<?> in class com.facebook.presto.execution.scheduler.SplitPlacementResult |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method private spillToDisk() : ListenableFuture<?> in class com.facebook.presto.operator.aggregation.builder.SpillableHashAggregationBuilder |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public spill(pageIterator Iterator<Page>) : ListenableFuture<?> in class com.facebook.presto.spiller.Spiller |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public whenSplitQueueHasSpace(threshold int) : ListenableFuture<?> in class com.facebook.presto.execution.MockRemoteTaskFactory.MockRemoteTask |
From |
To |
|
Change Return Type CompletableFuture<TaskStatus> to ListenableFuture<TaskStatus> in method public getStateChange(taskStatus TaskStatus) : ListenableFuture<TaskStatus> in class com.facebook.presto.server.remotetask.ContinuousTaskStatusFetcher |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement AddColumn, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.AddColumnTask |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method private abortInternal() : ListenableFuture<?> in class com.facebook.presto.transaction.TransactionManager.TransactionMetadata |
From |
To |
|
Change Return Type CompletableFuture<BufferResult> to SettableFuture<BufferResult> in method public getResultFuture() : SettableFuture<BufferResult> in class com.facebook.presto.execution.buffer.ClientBuffer.PendingRead |
From |
To |
|
Change Return Type CompletableFuture<BufferResult> to ListenableFuture<BufferResult> in method public get(bufferId OutputBufferId, token long, maxSize DataSize) : ListenableFuture<BufferResult> in class com.facebook.presto.execution.buffer.LazyOutputBuffer |
From |
To |
|
Change Return Type CompletableFuture<BufferResult> to ListenableFuture<BufferResult> in method public get(outputBufferId OutputBufferId, startingSequenceId long, maxSize DataSize) : ListenableFuture<BufferResult> in class com.facebook.presto.execution.buffer.BroadcastOutputBuffer |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public asyncCommit() : ListenableFuture<?> in class com.facebook.presto.transaction.TransactionManager.TransactionMetadata |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement ResetSession, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.ResetSessionTask |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement CreateTable, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.CreateTableTask |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement DropSchema, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.DropSchemaTask |
From |
To |
|
Change Return Type CompletableFuture<TaskInfo> to ListenableFuture<TaskInfo> in method public getTaskInfo(callersCurrentState TaskState) : ListenableFuture<TaskInfo> in class com.facebook.presto.execution.SqlTask |
From |
To |
|
Change Return Type CompletableFuture<TaskStatus> to ListenableFuture<TaskStatus> in method public getTaskStatus(callersCurrentState TaskState) : ListenableFuture<TaskStatus> in class com.facebook.presto.execution.SqlTask |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement Revoke, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.RevokeTask |
From |
To |
|
Change Return Type CompletableFuture<BufferResult> to ListenableFuture<BufferResult> in method public getPages(sequenceId long, maxSize DataSize, pagesSupplier Optional<PagesSupplier>) : ListenableFuture<BufferResult> in class com.facebook.presto.execution.buffer.ClientBuffer |
From |
To |
|
Change Return Type CompletableFuture<BufferResult> to ListenableFuture<BufferResult> in method public getTaskResults(bufferId OutputBufferId, startingSequenceId long, maxSize DataSize) : ListenableFuture<BufferResult> in class com.facebook.presto.execution.SqlTask |
From |
To |
|
Change Return Type CompletableFuture<List<Split>> to ListenableFuture<List<Split>> in method public getNextBatch(maxSize int) : ListenableFuture<List<Split>> in class com.facebook.presto.split.SampledSplitSource |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement DropTable, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.DropTableTask |
From |
To |
|
Change Return Type CompletableFuture<BufferResult> to ListenableFuture<BufferResult> in method public get(outputBufferId OutputBufferId, startingSequenceId long, maxSize DataSize) : ListenableFuture<BufferResult> in class com.facebook.presto.execution.buffer.PartitionedOutputBuffer |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement DropView, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.DropViewTask |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(prepare Prepare, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.PrepareTask |
From |
To |
|
Change Return Type CompletableFuture<TaskStatus> to ListenableFuture<TaskStatus> in method public getTaskStatus(taskId TaskId, currentState TaskState) : ListenableFuture<TaskStatus> in class com.facebook.presto.execution.TaskManager |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public asyncCommit(transactionId TransactionId) : ListenableFuture<?> in class com.facebook.presto.transaction.TransactionManager |
From |
To |
|
Change Return Type CompletableFuture<List<Split>> to ListenableFuture<List<Split>> in method public getNextBatch(maxSize int) : ListenableFuture<List<Split>> in class com.facebook.presto.split.MockSplitSource |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public isBlocked() : ListenableFuture<?> in class com.facebook.presto.operator.aggregation.builder.SpillableHashAggregationBuilder |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement RenameSchema, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.RenameSchemaTask |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement SetSession, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.SetSessionTask |
From |
To |
|
Change Return Type CompletableFuture<BufferResult> to ListenableFuture<BufferResult> in method public getTaskResults(taskId TaskId, bufferId OutputBufferId, startingSequenceId long, maxSize DataSize) : ListenableFuture<BufferResult> in class com.facebook.presto.execution.SqlTaskManager |
From |
To |
|
Change Return Type CompletableFuture<TransactionMetadata> to ListenableFuture<TransactionMetadata> in method private removeTransactionMetadataAsFuture(transactionId TransactionId) : ListenableFuture<TransactionMetadata> in class com.facebook.presto.transaction.TransactionManager |
From |
To |
|
Change Return Type CompletableFuture<T> to ListenableFuture<T> in method public createNewListener() : ListenableFuture<T> in class com.facebook.presto.execution.FutureStateChange |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public isBlocked() : ListenableFuture<?> in class com.facebook.presto.operator.aggregation.builder.HashAggregationBuilder |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement Grant, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.GrantTask |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement Rollback, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.RollbackTask |
From |
To |
|
Change Return Type CompletableFuture<List<Split>> to ListenableFuture<List<Split>> in method public getNextBatch(maxSize int) : ListenableFuture<List<Split>> in class com.facebook.presto.split.ConnectorAwareSplitSource |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public asyncAbort() : ListenableFuture<?> in class com.facebook.presto.transaction.TransactionManager.TransactionMetadata |
From |
To |
|
Change Return Type CompletableFuture<List<Split>> to ListenableFuture<List<Split>> in method public getNextBatch(maxSize int) : ListenableFuture<List<Split>> in class com.facebook.presto.split.BufferingSplitSource |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement RenameColumn, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.RenameColumnTask |
From |
To |
|
Change Return Type CompletableFuture<T> to ListenableFuture<T> in method public getStateChange(currentState T) : ListenableFuture<T> in class com.facebook.presto.execution.StateMachine |
From |
To |
|
Change Return Type CompletableFuture<TaskStatus> to ListenableFuture<TaskStatus> in method public getTaskStatus(taskId TaskId, currentState TaskState) : ListenableFuture<TaskStatus> in class com.facebook.presto.execution.SqlTaskManager |
From |
To |
|
Change Return Type CompletableFuture<TaskState> to ListenableFuture<TaskState> in method public getStateChange(currentState TaskState) : ListenableFuture<TaskState> in class com.facebook.presto.execution.TaskStateMachine |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement Commit, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.CommitTask |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement StartTransaction, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.StartTransactionTask |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public asyncAbort(transactionId TransactionId) : ListenableFuture<?> in class com.facebook.presto.transaction.TransactionManager |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public isBlocked() : ListenableFuture<?> in class com.facebook.presto.operator.aggregation.builder.InMemoryHashAggregationBuilder |
From |
To |
|
Change Return Type CompletableFuture<BufferResult> to ListenableFuture<BufferResult> in method public get(bufferId OutputBufferId, token long, maxSize DataSize) : ListenableFuture<BufferResult> in class com.facebook.presto.execution.buffer.OutputBuffer |
From |
To |
|
Change Return Type CompletableFuture<List<Split>> to ListenableFuture<List<Split>> in method public getNextBatch(maxSize int) : ListenableFuture<List<Split>> in class com.facebook.presto.split.SplitSource |
From |
To |
|
Change Return Type CompletableFuture<BufferResult> to ListenableFuture<BufferResult> in method public getTaskResults(taskId TaskId, bufferId OutputBufferId, startingSequenceId long, maxSize DataSize) : ListenableFuture<BufferResult> in class com.facebook.presto.execution.TaskManager |
From |
To |
|
Change Return Type CompletableFuture<BufferResult> to ListenableFuture<BufferResult> in method public get(bufferId OutputBufferId, startingSequenceId long, maxSize DataSize) : ListenableFuture<BufferResult> in class com.facebook.presto.execution.buffer.ArbitraryOutputBuffer |
From |
To |
|
Change Return Type CompletableFuture<TaskInfo> to ListenableFuture<TaskInfo> in method public getTaskInfo(taskId TaskId, currentState TaskState) : ListenableFuture<TaskInfo> in class com.facebook.presto.execution.SqlTaskManager |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public execute(statement RenameTable, transactionManager TransactionManager, metadata Metadata, accessControl AccessControl, stateMachine QueryStateMachine, parameters List<Expression>) : ListenableFuture<?> in class com.facebook.presto.execution.RenameTableTask |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public toWhenHasSplitQueueSpaceFuture(existingTasks List<RemoteTask>, spaceThreshold int) : ListenableFuture<?> in class com.facebook.presto.execution.scheduler.NodeScheduler |
From |
To |
|
Change Return Type CompletableFuture<?> to ListenableFuture<?> in method public spill(pageIterator Iterator<Page>) : ListenableFuture<?> in class com.facebook.presto.spiller.BinaryFileSpiller |
From |
To |
|
Change Variable Type bufferResultFuture : CompletableFuture<BufferResult> to bufferResultFuture : ListenableFuture<BufferResult> in method public getResults(taskId TaskId, bufferId OutputBufferId, token long, maxSize DataSize, asyncResponse AsyncResponse) : void in class com.facebook.presto.server.TaskResource |
From |
To |
|
Change Variable Type futureChange : Future<State> to futureChange : ListenableFuture<State> in method private assertStateChange(stateMachine StateMachine<State>, stateChange StateChanger, expectedState State) : void in class com.facebook.presto.execution.TestStateMachine |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testDestroyFreesReader() : void in class com.facebook.presto.execution.buffer.TestBroadcastOutputBuffer |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testAbortBeforeCreate() : void in class com.facebook.presto.execution.buffer.TestArbitraryOutputBuffer |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testAbortFreesReader() : void in class com.facebook.presto.execution.buffer.TestBroadcastOutputBuffer |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testFailDoesNotFreeReader() : void in class com.facebook.presto.execution.buffer.TestPartitionedOutputBuffer |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testFailDoesNotFreeReader() : void in class com.facebook.presto.execution.buffer.TestArbitraryOutputBuffer |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testGetBeforeCreate() : void in class com.facebook.presto.execution.buffer.TestArbitraryOutputBuffer |
From |
To |
|
Change Variable Type bufferResult : CompletableFuture<BufferResult> to bufferResult : ListenableFuture<BufferResult> in method public testBufferNotCloseOnFail() : void in class com.facebook.presto.execution.TestSqlTask |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public getBufferResult(buffer PartitionedOutputBuffer, bufferId OutputBufferId, sequenceId long, maxSize DataSize, maxWait Duration) : BufferResult in class com.facebook.presto.execution.buffer.TestPartitionedOutputBuffer |
From |
To |
|
Change Variable Type blocked : CompletableFuture<?> to blocked : ListenableFuture<?> in method public selectDistributionNodes(nodeMap NodeMap, nodeTaskMap NodeTaskMap, maxSplitsPerNode int, maxPendingSplitsPerTask int, splits Set<Split>, existingTasks List<RemoteTask>, partitioning NodePartitionMap) : SplitPlacementResult in class com.facebook.presto.execution.scheduler.NodeScheduler |
From |
To |
|
Change Variable Type entry : Map.Entry<TransactionId,TransactionMetadata> to entry : Entry<TransactionId,TransactionMetadata> in method private cleanUpExpiredTransactions() : void in class com.facebook.presto.transaction.TransactionManager |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testDestroyFreesReader() : void in class com.facebook.presto.execution.buffer.TestPartitionedOutputBuffer |
From |
To |
|
Change Variable Type blockedFutures : List<CompletableFuture<?>> to blockedFutures : List<ListenableFuture<?>> in method public toWhenHasSplitQueueSpaceFuture(blockedNodes Set<Node>, existingTasks List<RemoteTask>, spaceThreshold int) : ListenableFuture<?> in class com.facebook.presto.execution.scheduler.NodeScheduler |
From |
To |
|
Change Variable Type blocked : CompletableFuture<?> to blocked : ListenableFuture<?> in method public computeAssignments(splits Set<Split>, existingTasks List<RemoteTask>) : SplitPlacementResult in class com.facebook.presto.execution.scheduler.TopologyAwareNodeSelector |
From |
To |
|
Change Variable Type iterator : Iterator<Map.Entry<TransactionId,TransactionMetadata>> to iterator : Iterator<Entry<TransactionId,TransactionMetadata>> in method private cleanUpExpiredTransactions() : void in class com.facebook.presto.transaction.TransactionManager |
From |
To |
|
Change Variable Type futureTaskState : CompletableFuture<TaskState> to futureTaskState : ListenableFuture<TaskState> in method public getTaskStatus(callersCurrentState TaskState) : ListenableFuture<TaskStatus> in class com.facebook.presto.execution.SqlTask |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method private getBufferResult(buffer ClientBuffer, sequenceId long, maxSize DataSize, maxWait Duration) : BufferResult in class com.facebook.presto.execution.buffer.TestClientBuffer |
From |
To |
|
Change Variable Type futureChange : Future<State> to futureChange : ListenableFuture<State> in method private assertNoStateChange(stateMachine StateMachine<State>, stateChange StateChanger) : void in class com.facebook.presto.execution.TestStateMachine |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testDestroyFreesReader() : void in class com.facebook.presto.execution.buffer.TestClientBuffer |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testFinishFreesReader() : void in class com.facebook.presto.execution.buffer.TestArbitraryOutputBuffer |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method private getBufferResult(buffer OutputBuffer, bufferId OutputBufferId, sequenceId long, maxSize DataSize, maxWait Duration) : BufferResult in class com.facebook.presto.execution.buffer.TestArbitraryOutputBuffer |
From |
To |
|
Change Variable Type stateChangeFutures : List<CompletableFuture<?>> to stateChangeFutures : List<ListenableFuture<?>> in method public toWhenHasSplitQueueSpaceFuture(existingTasks List<RemoteTask>, spaceThreshold int) : ListenableFuture<?> in class com.facebook.presto.execution.scheduler.NodeScheduler |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testAbortFreesReader() : void in class com.facebook.presto.execution.buffer.TestPartitionedOutputBuffer |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testNoMorePagesFreesReader() : void in class com.facebook.presto.execution.buffer.TestClientBuffer |
From |
To |
|
Change Variable Type future : CompletableFuture<?> to future : ListenableFuture<?> in method public start(resourceGroupName Optional<String>) : void in class com.facebook.presto.execution.DataDefinitionExecution |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public getBufferResult(buffer BroadcastOutputBuffer, bufferId OutputBufferId, sequenceId long, maxSize DataSize, maxWait Duration) : BufferResult in class com.facebook.presto.execution.buffer.TestBroadcastOutputBuffer |
From |
To |
|
Change Variable Type future : CompletableFuture<TaskState> to future : ListenableFuture<TaskState> in method public getStateChange(currentState TaskState) : ListenableFuture<TaskState> in class com.facebook.presto.execution.TaskStateMachine |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testAbortBeforeCreate() : void in class com.facebook.presto.execution.buffer.TestBroadcastOutputBuffer |
From |
To |
|
Change Variable Type result : CompletableFuture<BufferResult> to result : ListenableFuture<BufferResult> in method public process(delegate OutputBuffer) : void in class com.facebook.presto.execution.buffer.LazyOutputBuffer.PendingRead |
From |
To |
|
Change Variable Type futures : Set<CompletableFuture<T>> to futures : Set<SettableFuture<T>> in method private fireStateChange(newState T, executor Executor) : void in class com.facebook.presto.execution.FutureStateChange |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method private getBufferResult(buffer ClientBuffer, supplier PagesSupplier, sequenceId long, maxSize DataSize, maxWait Duration) : BufferResult in class com.facebook.presto.execution.buffer.TestClientBuffer |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testFinishFreesReader() : void in class com.facebook.presto.execution.buffer.TestPartitionedOutputBuffer |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testDestroyFreesReader() : void in class com.facebook.presto.execution.buffer.TestArbitraryOutputBuffer |
From |
To |
|
Change Variable Type futureTaskInfo : CompletableFuture<TaskInfo> to futureTaskInfo : ListenableFuture<TaskInfo> in method public getTaskInfo(taskId TaskId, currentState TaskState, maxWait Duration, uriInfo UriInfo, asyncResponse AsyncResponse) : void in class com.facebook.presto.server.TaskResource |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testFailDoesNotFreeReader() : void in class com.facebook.presto.execution.buffer.TestBroadcastOutputBuffer |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testGetBeforeCreate() : void in class com.facebook.presto.execution.buffer.TestBroadcastOutputBuffer |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testAbortFreesReader() : void in class com.facebook.presto.execution.buffer.TestArbitraryOutputBuffer |
From |
To |
|
Change Variable Type blockedStage : CompletableFuture<?> to blockedStage : ListenableFuture<?> in method private schedule() : void in class com.facebook.presto.execution.scheduler.SqlQueryScheduler |
From |
To |
|
Change Variable Type bufferResult : CompletableFuture<BufferResult> to bufferResult : ListenableFuture<BufferResult> in method public testBufferCloseOnFinish() : void in class com.facebook.presto.execution.TestSqlTask |
From |
To |
|
Change Variable Type pendingRead : CompletableFuture<BufferResult> to pendingRead : ListenableFuture<BufferResult> in method public testSimplePullBuffer() : void in class com.facebook.presto.execution.buffer.TestClientBuffer |
From |
To |
|
Change Variable Type future : CompletableFuture<?> to future : ListenableFuture<?> in method public getNextBatch(maxSize int) : ListenableFuture<List<Split>> in class com.facebook.presto.split.BufferingSplitSource |
From |
To |
|
Change Variable Type futureTaskState : CompletableFuture<TaskState> to futureTaskState : ListenableFuture<TaskState> in method public getTaskInfo(callersCurrentState TaskState) : ListenableFuture<TaskInfo> in class com.facebook.presto.execution.SqlTask |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testSetFinalBuffersWihtoutDeclaringUsedBuffer() : void in class com.facebook.presto.execution.buffer.TestBroadcastOutputBuffer |
From |
To |
|
Change Variable Type future : CompletableFuture<BufferResult> to future : ListenableFuture<BufferResult> in method public testFinishFreesReader() : void in class com.facebook.presto.execution.buffer.TestBroadcastOutputBuffer |
From |
To |
|
Change Variable Type blocked : CompletableFuture<?> to blocked : ListenableFuture<?> in method public computeAssignments(splits Set<Split>, existingTasks List<RemoteTask>) : SplitPlacementResult in class com.facebook.presto.execution.scheduler.SimpleNodeSelector |
From |
To |
|
Change Variable Type futureTaskStatus : CompletableFuture<TaskStatus> to futureTaskStatus : ListenableFuture<TaskStatus> in method public getTaskStatus(taskId TaskId, currentState TaskState, maxWait Duration, uriInfo UriInfo, asyncResponse AsyncResponse) : void in class com.facebook.presto.server.TaskResource |
From |
To |
|
Change Variable Type bufferResult : CompletableFuture<BufferResult> to bufferResult : ListenableFuture<BufferResult> in method public testBufferCloseOnCancel() : void in class com.facebook.presto.execution.TestSqlTask |
From |
To |
|
Change Variable Type blockedStages : List<CompletableFuture<?>> to blockedStages : List<ListenableFuture<?>> in method private schedule() : void in class com.facebook.presto.execution.scheduler.SqlQueryScheduler |
From |
To |