Uses of Interface
org.apache.hadoop.hdfs.server.federation.resolver.FederationNamenodeContext
Packages that use FederationNamenodeContext
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.
Contains the abstract definitions of the state store data records.
The protobuf implementations of state store data records defined in the
org.apache.hadoop.hdfs.server.federation.store.records package.
-
Uses of FederationNamenodeContext in org.apache.hadoop.hdfs.server.federation.resolver
Methods in org.apache.hadoop.hdfs.server.federation.resolver that return types with arguments of type FederationNamenodeContextModifier and TypeMethodDescriptionList<? extends FederationNamenodeContext>ActiveNamenodeResolver.getNamenodesForBlockPoolId(String blockPoolId) Returns a prioritized list of the most recent cached registration entries for a single block pool ID.List<? extends FederationNamenodeContext>MembershipNamenodeResolver.getNamenodesForBlockPoolId(String bpId) List<? extends FederationNamenodeContext>ActiveNamenodeResolver.getNamenodesForNameserviceId(String nameserviceId, boolean listObserversFirst) Returns a prioritized list of the most recent cached registration entries for a single nameservice ID.List<? extends FederationNamenodeContext>MembershipNamenodeResolver.getNamenodesForNameserviceId(String nsId, boolean listObserversFirst) Methods in org.apache.hadoop.hdfs.server.federation.resolver with parameters of type FederationNamenodeContextModifier and TypeMethodDescriptionintNamenodePriorityComparator.compare(FederationNamenodeContext o1, FederationNamenodeContext o2) voidActiveNamenodeResolver.rotateCache(String nsId, FederationNamenodeContext namenode, boolean listObserversFirst) Rotate cache, make the current namenode have the lowest priority, to ensure that the current namenode will not be accessed first next time.voidMembershipNamenodeResolver.rotateCache(String nsId, FederationNamenodeContext namenode, boolean listObserversFirst) Rotate cache, make the current namenode have the lowest priority, to ensure that the current namenode will not be accessed first next time. -
Uses of FederationNamenodeContext in org.apache.hadoop.hdfs.server.federation.router
Methods in org.apache.hadoop.hdfs.server.federation.router that return types with arguments of type FederationNamenodeContextModifier and TypeMethodDescriptionList<? extends FederationNamenodeContext>RouterRpcClient.getOrderedNamenodes(String nsId, boolean isObserverRead) Get a prioritized list of NNs that share the same nameservice ID (in the same namespace).Methods in org.apache.hadoop.hdfs.server.federation.router with parameters of type FederationNamenodeContextModifier and TypeMethodDescriptionprotected voidRouterRpcClient.handleInvokeMethodIOException(FederationNamenodeContext namenode, IOException ioe, RouterRpcClient.ExecutionStatus status, boolean useObserver) The RPC request to the NameNode throws an exception, handle it according to the type of exception.protected ObjectRouterRpcClient.handlerInvokeException(FederationNamenodeContext namenode, Boolean listObserverFirst, int retryCount, Method method, Object obj, Throwable e, Object[] params) Handle the exception when an RPC request to the NameNode throws an exception.protected ObjectRouterRpcClient.invoke(FederationNamenodeContext namenode, Boolean listObserverFirst, int retryCount, Method method, Object obj, Object... params) Invokes a method on the designated object.protected voidRouterRpcClient.postProcessResult(Method method, RouterRpcClient.ExecutionStatus status, FederationNamenodeContext namenode, String nsId, org.apache.hadoop.hdfs.NameNodeProxiesClient.ProxyAndInfo<?> client) The RPC request is successfully processed by the NameNode, the NameNode status in the router cache is updated according to the ExecutionStatus.protected org.apache.hadoop.io.retry.RetryPolicy.RetryAction.RetryDecisionRouterRpcClient.shouldRetry(IOException ioe, int retryCount, String nsId, FederationNamenodeContext namenode, boolean listObserverFirst) If we should retry the RPC call.Method parameters in org.apache.hadoop.hdfs.server.federation.router with type arguments of type FederationNamenodeContextModifier and TypeMethodDescriptionprotected ObjectRouterRpcClient.handlerAllNamenodeFail(List<? extends FederationNamenodeContext> namenodes, Method method, Map<FederationNamenodeContext, IOException> ioes, Object[] params) All namenodes cannot successfully process the RPC request, throw corresponding exceptions according to the exception type of each namenode.protected ObjectRouterRpcClient.handlerAllNamenodeFail(List<? extends FederationNamenodeContext> namenodes, Method method, Map<FederationNamenodeContext, IOException> ioes, Object[] params) All namenodes cannot successfully process the RPC request, throw corresponding exceptions according to the exception type of each namenode.RouterRpcClient.invokeMethod(org.apache.hadoop.security.UserGroupInformation ugi, List<? extends FederationNamenodeContext> namenodes, boolean useObserver, Class<?> protocol, Method method, Object... params) Invokes a method against the ClientProtocol proxy server. -
Uses of FederationNamenodeContext in org.apache.hadoop.hdfs.server.federation.router.async
Methods in org.apache.hadoop.hdfs.server.federation.router.async with parameters of type FederationNamenodeContextModifier and TypeMethodDescriptionprotected ObjectRouterAsyncRpcClient.invoke(FederationNamenodeContext namenode, Boolean listObserverFirst, int retryCount, Method method, Object obj, Object... params) Asynchronously invokes a method on a specified NameNode in the context of the given namespace and NameNode information.Method parameters in org.apache.hadoop.hdfs.server.federation.router.async with type arguments of type FederationNamenodeContextModifier and TypeMethodDescriptionRouterAsyncRpcClient.invokeMethod(org.apache.hadoop.security.UserGroupInformation ugi, List<? extends FederationNamenodeContext> namenodes, boolean useObserver, Class<?> protocol, Method method, Object... params) Invokes a method against the ClientProtocol proxy server. -
Uses of FederationNamenodeContext in org.apache.hadoop.hdfs.server.federation.store.records
Classes in org.apache.hadoop.hdfs.server.federation.store.records that implement FederationNamenodeContextModifier and TypeClassDescriptionclassData schema for storing NN registration information in theStateStoreService. -
Uses of FederationNamenodeContext in org.apache.hadoop.hdfs.server.federation.store.records.impl.pb
Classes in org.apache.hadoop.hdfs.server.federation.store.records.impl.pb that implement FederationNamenodeContextModifier and TypeClassDescriptionclassProtobuf implementation of the MembershipState record.