Toggle navigation
Home
java.util.concurrent.Executor to com.google.common.util.concurrent.ListeningExecutorService
No. of Instances - 4
No. of Commits - 2
No. of Projects - {'presto'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> External
Mapping:
Add or Remove Method invocation
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); } } )