Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -757,7 +757,7 @@ public ActiveNamenodeResolver getNamenodeResolver() {
/**
* Get the state store interface for the router heartbeats.
*
* @return FederationRouterStateStore state store API handle.
* @return RouterStore state store API handle.
*/
public RouterStore getRouterStateManager() {
if (this.routerStateManager == null && this.stateStore != null) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@
* StateStoreDriver}, NameNode registrations are cached until the next query.
* The fetched registration data is aggregated using a quorum to determine the
* best/most accurate state for each NameNode. The cache is periodically updated
* by the @{link StateStoreCacheUpdateService}.
* by the {@link StateStoreCacheUpdateService}.
*/
@InterfaceAudience.Private
@InterfaceStability.Evolving
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,6 +50,7 @@
* |--- MEMBERSHIP
* |--- REBALANCER
* |--- ROUTERS
* |--- DISABLE_NAMESERVICE
*/
public class StateStoreZooKeeperImpl extends StateStoreSerializableImpl {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,19 +31,21 @@
* StateStoreDriver} to handle querying, updating and deleting data records. The
* data storage driver is initialized and maintained by the {@link
* org.apache.hadoop.hdfs.server.federation.store.StateStoreService
* FederationStateStoreService}. The state store
* StateStoreService}. The state store
* supports fetching all records of a type, filtering by column values or
* fetching a single record by its primary key.
* <p>
* The state store contains several API interfaces, one for each data records
* type.
* <ul>
* <li>FederationMembershipStateStore: state of all Namenodes in the federation.
* <li>MembershipStore: state of all Namenodes in the federation.
* Uses the MembershipState record.
* <li>FederationMountTableStore: Mount table mapping paths in the global
* <li>MountTableStore: Mount table mapping paths in the global
* namespace to individual subcluster paths. Uses the MountTable record.
* <li>RouterStateStore: State of all routers in the federation. Uses the
* <li>RouterStore: State of all routers in the federation. Uses the
* RouterState record.
* <li>DisabledNameserviceStore: state of all disabled nameservice in the federation.
* Uses the DisabledNameservice record.
* </ul>
* Each API is defined in a separate interface. The implementations of these
* interfaces are responsible for accessing the {@link
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@
/**
* Data schema for storing NN registration information in the
* {@link org.apache.hadoop.hdfs.server.federation.store.StateStoreService
* FederationStateStoreService}.
* StateStoreService}.
*/
public abstract class MembershipState extends BaseRecord
implements FederationNamenodeContext {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -42,9 +42,9 @@
/**
* Data schema for {@link
* org.apache.hadoop.hdfs.server.federation.store.MountTableStore
* FederationMountTableStore} data stored in the {@link
* MountTableStore} data stored in the {@link
* org.apache.hadoop.hdfs.server.federation.store.StateStoreService
* FederationStateStoreService}. Supports string serialization.
* StateStoreService}. Supports string serialization.
*/
public abstract class MountTable extends BaseRecord {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@
* Entry to log the state of a
* {@link org.apache.hadoop.hdfs.server.federation.router.Router Router} in the
* {@link org.apache.hadoop.hdfs.server.federation.store.StateStoreService
* FederationStateStoreService}.
* StateStoreService}.
*/
public abstract class RouterState extends BaseRecord {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -586,8 +586,6 @@ private MembershipState getExpiredNamenodeRegistration(
/**
* Register a namenode heartbeat with the state store.
*
* @param store FederationMembershipStateStore instance to retrieve the
* membership data records.
* @param namenode A fully populated namenode membership record to be
* committed to the data store.
* @return True if successful, false otherwise.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -227,7 +227,6 @@ private MountTable getMountTableEntry(String mount) throws IOException {
/**
* Fetch all mount table records beneath a root path.
*
* @param store FederationMountTableStore instance to commit the data.
* @param mount The root search path, enter "/" to return all mount table
* records.
*
Expand Down