Uses of Class
org.apache.hadoop.hdfs.server.federation.router.RemoteMethod

Packages that use RemoteMethod

Package	Description
org.apache.hadoop.hdfs.server.federation.router	The router package includes the core services for a HDFS federation router.
org.apache.hadoop.hdfs.server.federation.router.async	This package contains classes that facilitate asynchronous operations within the Hadoop Distributed File System (HDFS) Federation router.

Uses of RemoteMethod in org.apache.hadoop.hdfs.server.federation.router

Methods in org.apache.hadoop.hdfs.server.federation.router with parameters of type RemoteMethod

Modifier and Type	Method	Description
protected List<RemoteLocation>	RouterClientProtocol.checkFaultTolerantRetry(RemoteMethod method, String src, IOException ioe, RemoteLocation excludeLoc, List<RemoteLocation> locations)	Check if a remote method can be retried in other subclusters when it failed in the original destination.
protected org.apache.hadoop.hdfs.protocol.HdfsFileStatus	RouterClientProtocol.getFileInfoAll(List<RemoteLocation> locations, RemoteMethod method)	Get the file info from all the locations.
protected org.apache.hadoop.hdfs.protocol.HdfsFileStatus	RouterClientProtocol.getFileInfoAll(List<RemoteLocation> locations, RemoteMethod method, long timeOutMs)	Get the file info from all the locations.
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> boolean	RouterRpcClient.invokeAll(Collection<T> locations, RemoteMethod method)	Invoke method in all locations and return success if any succeeds.
<T> T	RouterRpcServer.invokeAtAvailableNsAsync(RemoteMethod method, Class<T> clazz)	Invokes the method at default namespace, if default namespace is not available then at the other available namespaces.
<T extends RemoteLocationContext, R> void	RouterRpcClient.invokeConcurrent(Collection<T> locations, RemoteMethod method)	Invoke multiple concurrent proxy calls to different clients.
<T extends RemoteLocationContext, R> void	RouterRpcClient.invokeConcurrent(Collection<T> locations, RemoteMethod method, boolean requireResponse, boolean standby)	Invoke multiple concurrent proxy calls to different clients.
<T extends RemoteLocationContext, R> Map<T,R>	RouterRpcClient.invokeConcurrent(Collection<T> locations, RemoteMethod method, boolean requireResponse, boolean standby, long timeOutMs, Class<R> clazz)	Invokes multiple concurrent proxy calls to different clients.
<T extends RemoteLocationContext, R> Map<T,R>	RouterRpcClient.invokeConcurrent(Collection<T> locations, RemoteMethod method, boolean requireResponse, boolean standby, Class<R> clazz)	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> Map<T,R>	RouterRpcClient.invokeConcurrent(Collection<T> locations, RemoteMethod method, Class<R> clazz)	Invoke multiple concurrent proxy calls to different clients.
<T> T	RouterRpcClient.invokeSequential(List<? extends RemoteLocationContext> locations, RemoteMethod remoteMethod)	Invokes sequential proxy calls to different locations.
<T> T	RouterRpcClient.invokeSequential(List<? extends RemoteLocationContext> locations, RemoteMethod remoteMethod, Class<T> expectedResultClass, Object expectedResultValue)	Invokes sequential proxy calls to different locations.
<R extends RemoteLocationContext, T> RemoteResult	RouterRpcClient.invokeSequential(RemoteMethod remoteMethod, List<R> locations, Class<T> expectedResultClass, Object expectedResultValue)	Invokes sequential proxy calls to different locations.
Object	RouterRpcClient.invokeSingle(String nsId, RemoteMethod method)	Invokes a ClientProtocol method against the specified namespace.
<T> T	RouterRpcClient.invokeSingle(String nsId, RemoteMethod method, Class<T> clazz)	Invokes a remote method against the specified namespace.
<T> T	RouterRpcClient.invokeSingle(org.apache.hadoop.hdfs.protocol.ExtendedBlock extendedBlock, RemoteMethod method, Class<T> clazz)	Invokes a remote method against the specified extendedBlock.
<T> T	RouterRpcClient.invokeSingle(org.apache.hadoop.hdfs.protocol.ExtendedBlock block, RemoteMethod method, List<RemoteLocation> locations, Class<T> clazz)	Invokes a ClientProtocol method.
<T> T	RouterRpcClient.invokeSingle(RemoteLocationContext location, RemoteMethod remoteMethod, Class<T> clazz)	Invokes a single proxy call for a single location.
<T extends RemoteLocationContext, R> List<RemoteResult<T,R>>	RouterRpcClient.invokeSingle(T location, RemoteMethod method)	Invokes a ClientProtocol method against the specified namespace.
Object	RouterRpcClient.invokeSingleBlockPool(String bpId, RemoteMethod method)	Invokes a ClientProtocol method.
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.
protected void	RouterRpcClient.releasePermit(String nsId, org.apache.hadoop.security.UserGroupInformation ugi, RemoteMethod m, RouterRpcFairnessPolicyController controller)	Release permit for specific nsId after processing against downstream nsId is completed.

Uses of RemoteMethod in org.apache.hadoop.hdfs.server.federation.router.async

Methods in org.apache.hadoop.hdfs.server.federation.router.async with parameters of type RemoteMethod

Modifier and Type	Method	Description
protected org.apache.hadoop.hdfs.protocol.HdfsFileStatus	RouterAsyncClientProtocol.getFileInfoAll(List<RemoteLocation> locations, RemoteMethod method, long timeOutMs)
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> boolean	RouterAsyncRpcClient.invokeAll(Collection<T> locations, RemoteMethod method)	Invoke method in all locations and return success if any succeeds.
<T extends RemoteLocationContext, R> Map<T,R>	RouterAsyncRpcClient.invokeConcurrent(Collection<T> locations, RemoteMethod method, boolean requireResponse, boolean standby, long timeOutMs, Class<R> clazz)	Invokes multiple concurrent proxy calls to different clients.
<T> T	RouterAsyncRpcClient.invokeSequential(List<? extends RemoteLocationContext> locations, RemoteMethod remoteMethod, Class<T> expectedResultClass, Object expectedResultValue)	Invokes sequential proxy calls to different locations.
<R extends RemoteLocationContext, T> RemoteResult	RouterAsyncRpcClient.invokeSequential(RemoteMethod remoteMethod, List<R> locations, Class<T> expectedResultClass, Object expectedResultValue)	Invokes sequential proxy calls to different locations.
Object	RouterAsyncRpcClient.invokeSingle(String nsId, RemoteMethod method)	Invokes a ClientProtocol method against the specified namespace.
<T> T	RouterAsyncRpcClient.invokeSingle(RemoteLocationContext location, RemoteMethod remoteMethod, Class<T> clazz)	Invokes a single proxy call for a single location.
<T extends RemoteLocationContext, R> List<RemoteResult<T,R>>	RouterAsyncRpcClient.invokeSingle(T location, RemoteMethod method)	Invokes a ClientProtocol method against the specified namespace.