Toggle navigation
Home
java.util.concurrent.CompletableFuture to com.google.common.util.concurrent.ListenableFuture
No. of Instances - 145
No. of Commits - 5
No. of Projects - {'presto'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Jdk -> External
Mapping:
Other
finishFuture
to
finishFuture
future
to
future
queues.offer(bucketNumber,split)
to
queues.offer(bucketNumber,split)
Cascading Type Change (Similar)
CompletableFuture<Response>
to
ListenableFuture<Response>
Add or Remove Method invocation
bufferResultFuture.thenApply(result -> { List<SerializedPage> serializedPages=result.getSerializedPages(); GenericEntity<?> entity=null; Status status; if (serializedPages.isEmpty()) { status=Status.NO_CONTENT; } else { entity=new GenericEntity<>(serializedPages,new TypeToken<List<Page>>(){ } .getType()); status=Status.OK; } return Response.status(status).entity(entity).header(PRESTO_TASK_INSTANCE_ID,result.getTaskInstanceId()).header(PRESTO_PAGE_TOKEN,result.getToken()).header(PRESTO_PAGE_NEXT_TOKEN,result.getNextToken()).header(PRESTO_BUFFER_COMPLETE,result.isBufferComplete()).build(); } )
to
Futures.transform(bufferResultFuture,result -> { List<SerializedPage> serializedPages=result.getSerializedPages(); GenericEntity<?> entity=null; Status status; if (serializedPages.isEmpty()) { status=Status.NO_CONTENT; } else { entity=new GenericEntity<>(serializedPages,new TypeToken<List<Page>>(){ } .getType()); status=Status.OK; } return Response.status(status).entity(entity).header(PRESTO_TASK_INSTANCE_ID,result.getTaskInstanceId()).header(PRESTO_PAGE_TOKEN,result.getToken()).header(PRESTO_PAGE_NEXT_TOKEN,result.getNextToken()).header(PRESTO_BUFFER_COMPLETE,result.isBufferComplete()).build(); } )
firstCompletedFuture(blockedStages)
to
whenAnyComplete(blockedStages)
futureTaskInfo.thenApply(TaskInfo::summarize)
to
Futures.transform(futureTaskInfo,TaskInfo::summarize)
CompletableFuture.runAsync(() -> { if (cancelled.get()) { return; } try { if (fileSystem.exists(target) || !fileSystem.rename(source,target)) { throw new PrestoException(HIVE_FILESYSTEM_ERROR,getRenameErrorMessage(source,target)); } } catch ( IOException e) { throw new PrestoException(HIVE_FILESYSTEM_ERROR,getRenameErrorMessage(source,target),e); } } ,executor)
to
executor.submit(() -> { if (cancelled.get()) { return; } try { if (fileSystem.exists(target) || !fileSystem.rename(source,target)) { throw new PrestoException(HIVE_FILESYSTEM_ERROR,getRenameErrorMessage(source,target)); } } catch ( IOException e) { throw new PrestoException(HIVE_FILESYSTEM_ERROR,getRenameErrorMessage(source,target),e); } } )