Uses of Class
org.apache.hadoop.hdfs.server.federation.router.RemoteResult
Packages that use RemoteResult
Package
Description
The router package includes the core services for a HDFS federation router.
This package contains classes that facilitate asynchronous operations within the Hadoop
Distributed File System (HDFS) Federation router.
-
Uses of RemoteResult in org.apache.hadoop.hdfs.server.federation.router
Methods in org.apache.hadoop.hdfs.server.federation.router that return RemoteResultModifier and TypeMethodDescription<R extends RemoteLocationContext,T>
RemoteResultRouterRpcClient.invokeSequential(RemoteMethod remoteMethod, List<R> locations, Class<T> expectedResultClass, Object expectedResultValue) Invokes sequential proxy calls to different locations.Methods in org.apache.hadoop.hdfs.server.federation.router that return types with arguments of type RemoteResultModifier and TypeMethodDescriptionprotected List<RemoteResult<RemoteLocation,org.apache.hadoop.hdfs.protocol.DirectoryListing>> RouterClientProtocol.getListingInt(String src, byte[] startAfter, boolean needLocation) Get a partial listing of the indicated directory.protected <T extends RemoteLocationContext,R>
List<RemoteResult<T,R>> RouterRpcClient.getRemoteResults(RemoteMethod method, long timeOutMs, RouterRpcFairnessPolicyController controller, List<T> orderedLocations, List<Callable<Object>> callables) Invokes multiple concurrent proxy calls to different clients.<T extends RemoteLocationContext,R>
List<RemoteResult<T,R>> RouterRpcClient.invokeConcurrent(Collection<T> locations, RemoteMethod method, boolean standby, long timeOutMs, Class<R> clazz) Invokes multiple concurrent proxy calls to different clients.<T extends RemoteLocationContext,R>
List<RemoteResult<T,R>> RouterRpcClient.invokeSingle(T location, RemoteMethod method) Invokes a ClientProtocol method against the specified namespace.protected <T extends RemoteLocationContext,R>
List<RemoteResult<T,R>> RouterRpcClient.processFutures(RemoteMethod method, Method m, List<T> orderedLocations, List<Future<Object>> futures) Handle all futures during the invokeConcurrent call process.Method parameters in org.apache.hadoop.hdfs.server.federation.router with type arguments of type RemoteResultModifier and TypeMethodDescriptionprotected static <T extends RemoteLocationContext,R>
Map<T,R> RouterRpcClient.postProcessResult(boolean requireResponse, List<RemoteResult<T, R>> results) Post-process the results returned byRouterRpcClient.invokeConcurrent(Collection, RemoteMethod, boolean, long, Class). -
Uses of RemoteResult in org.apache.hadoop.hdfs.server.federation.router.async
Methods in org.apache.hadoop.hdfs.server.federation.router.async that return RemoteResultModifier and TypeMethodDescription<R extends RemoteLocationContext,T>
RemoteResultRouterAsyncRpcClient.invokeSequential(RemoteMethod remoteMethod, List<R> locations, Class<T> expectedResultClass, Object expectedResultValue) Invokes sequential proxy calls to different locations.Methods in org.apache.hadoop.hdfs.server.federation.router.async that return types with arguments of type RemoteResultModifier and TypeMethodDescriptionprotected List<RemoteResult<RemoteLocation,org.apache.hadoop.hdfs.protocol.DirectoryListing>> RouterAsyncClientProtocol.getListingInt(String src, byte[] startAfter, boolean needLocation) Get listing on remote locations.protected <T extends RemoteLocationContext,R>
List<RemoteResult<T,R>> RouterAsyncRpcClient.getRemoteResults(RemoteMethod method, long timeOutMs, RouterRpcFairnessPolicyController controller, List<T> orderedLocations, List<Callable<Object>> callables) Invokes multiple concurrent proxy calls to different clients.<T extends RemoteLocationContext,R>
List<RemoteResult<T,R>> RouterAsyncRpcClient.invokeSingle(T location, RemoteMethod method) Invokes a ClientProtocol method against the specified namespace.