Uses of Class
org.apache.hadoop.hdfs.server.federation.router.RemoteLocationContext
Packages that use RemoteLocationContext
Package
Description
The resolver package contains indepedent data resolvers used in HDFS
federation.
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 RemoteLocationContext in org.apache.hadoop.hdfs.server.federation.resolver
Subclasses of RemoteLocationContext in org.apache.hadoop.hdfs.server.federation.resolverModifier and TypeClassDescriptionclassRepresents information about a single nameservice/namespace in a federated HDFS cluster.classA location in a remote namespace consisting of a nameservice ID and a HDFS path (destination).Methods in org.apache.hadoop.hdfs.server.federation.resolver with parameters of type RemoteLocationContextModifier and TypeMethodDescriptionintFederationNamespaceInfo.compareTo(RemoteLocationContext info) -
Uses of RemoteLocationContext in org.apache.hadoop.hdfs.server.federation.router
Classes in org.apache.hadoop.hdfs.server.federation.router with type parameters of type RemoteLocationContextModifier and TypeClassDescriptionclassRemoteResult<T extends RemoteLocationContext,R> Result from a remote location.Methods in org.apache.hadoop.hdfs.server.federation.router with type parameters of type RemoteLocationContextModifier and TypeMethodDescriptionprotected <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>
booleanRouterRpcClient.invokeAll(Collection<T> locations, RemoteMethod method) Invoke method in all locations and return success if any succeeds.<T extends RemoteLocationContext,R>
voidRouterRpcClient.invokeConcurrent(Collection<T> locations, RemoteMethod method) Invoke multiple concurrent proxy calls to different clients.<T extends RemoteLocationContext,R>
voidRouterRpcClient.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.<R extends RemoteLocationContext,T>
RemoteResultRouterRpcClient.invokeSequential(RemoteMethod remoteMethod, List<R> locations, Class<T> expectedResultClass, Object expectedResultValue) Invokes sequential proxy calls to different locations.<T extends RemoteLocationContext,R>
List<RemoteResult<T,R>> RouterRpcClient.invokeSingle(T location, RemoteMethod method) Invokes a ClientProtocol method against the specified namespace.protected 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).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.Methods in org.apache.hadoop.hdfs.server.federation.router with parameters of type RemoteLocationContextModifier and TypeMethodDescriptionintRemoteLocationContext.compareTo(RemoteLocationContext info) RemoteParam.getParameterForContext(RemoteLocationContext context) Determine the appropriate value for this parameter based on the location.Object[]RemoteMethod.getParams(RemoteLocationContext context) Generate a list of parameters for this specific location.<T> TRouterRpcClient.invokeSingle(RemoteLocationContext location, RemoteMethod remoteMethod, Class<T> clazz) Invokes a single proxy call for a single location.protected IOExceptionRouterRpcClient.processException(IOException ioe, RemoteLocationContext loc) Exception messages might contain local subcluster paths.Method parameters in org.apache.hadoop.hdfs.server.federation.router with type arguments of type RemoteLocationContextModifier and TypeMethodDescription<T> TRouterRpcClient.invokeSequential(List<? extends RemoteLocationContext> locations, RemoteMethod remoteMethod) Invokes sequential proxy calls to different locations.<T> TRouterRpcClient.invokeSequential(List<? extends RemoteLocationContext> locations, RemoteMethod remoteMethod, Class<T> expectedResultClass, Object expectedResultValue) Invokes sequential proxy calls to different locations.Constructor parameters in org.apache.hadoop.hdfs.server.federation.router with type arguments of type RemoteLocationContextModifierConstructorDescriptionRemoteParam(Map<? extends RemoteLocationContext, ? extends Object> map) Constructs a map based remote parameter. -
Uses of RemoteLocationContext in org.apache.hadoop.hdfs.server.federation.router.async
Methods in org.apache.hadoop.hdfs.server.federation.router.async with type parameters of type RemoteLocationContextModifier and TypeMethodDescriptionprotected <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>
booleanRouterAsyncRpcClient.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.<R extends RemoteLocationContext,T>
RemoteResultRouterAsyncRpcClient.invokeSequential(RemoteMethod remoteMethod, List<R> locations, Class<T> expectedResultClass, Object expectedResultValue) Invokes sequential proxy calls to different locations.<T extends RemoteLocationContext,R>
List<RemoteResult<T,R>> RouterAsyncRpcClient.invokeSingle(T location, RemoteMethod method) Invokes a ClientProtocol method against the specified namespace.Methods in org.apache.hadoop.hdfs.server.federation.router.async with parameters of type RemoteLocationContextModifier and TypeMethodDescription<T> TRouterAsyncRpcClient.invokeSingle(RemoteLocationContext location, RemoteMethod remoteMethod, Class<T> clazz) Invokes a single proxy call for a single location.Method parameters in org.apache.hadoop.hdfs.server.federation.router.async with type arguments of type RemoteLocationContextModifier and TypeMethodDescription<T> TRouterAsyncRpcClient.invokeSequential(List<? extends RemoteLocationContext> locations, RemoteMethod remoteMethod, Class<T> expectedResultClass, Object expectedResultValue) Invokes sequential proxy calls to different locations.