Uses of Class
org.apache.hadoop.ozone.container.common.statemachine.StateContext
Packages that use StateContext
Package
Description
This package is contains Ozone container implementation.
Datanode Reports: As part of heartbeat, datanode has to share its current
state with SCM.
State machine class is used by the container to denote various states a
container can be in and also is used for command processing.
Classes dedicated to handle container commands.
This package contains files that guide the state transitions
from Init->Running->Shutdown for the datanode.
This package contains code for RPC endpoints transitions.
This package contains classes for the server implementation using Apache Ratis.
This package contains volume/ disk related classes.
Erasure codding related classes.
Ozone main that calls into the container layer.
Classes to replicate container data between datanodes.
-
Uses of StateContext in org.apache.hadoop.ozone.container.common.impl
Methods in org.apache.hadoop.ozone.container.common.impl with parameters of type StateContextModifier and TypeMethodDescriptionvoidContainerSet.handleVolumeFailures(StateContext context) Remove all containers belonging to failed volume.Constructors in org.apache.hadoop.ozone.container.common.impl with parameters of type StateContextModifierConstructorDescriptionHddsDispatcher(org.apache.hadoop.hdds.conf.ConfigurationSource config, ContainerSet contSet, VolumeSet volumes, Map<org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.ContainerType, Handler> handlers, StateContext context, ContainerMetrics metrics, org.apache.hadoop.hdds.security.token.TokenVerifier tokenVerifier) Constructs an OzoneContainer that receives calls from XceiverServerHandler. -
Uses of StateContext in org.apache.hadoop.ozone.container.common.report
Methods in org.apache.hadoop.ozone.container.common.report that return StateContextModifier and TypeMethodDescriptionprotected StateContextReportPublisher.getContext()ReturnsStateContext.Methods in org.apache.hadoop.ozone.container.common.report with parameters of type StateContextModifier and TypeMethodDescriptionvoidReportPublisher.init(StateContext stateContext, ScheduledExecutorService executorService) Initializes ReportPublisher with stateContext and executorService.ReportManager.Builder.setStateContext(StateContext context) Sets theStateContext. -
Uses of StateContext in org.apache.hadoop.ozone.container.common.statemachine
Methods in org.apache.hadoop.ozone.container.common.statemachine that return StateContextMethods in org.apache.hadoop.ozone.container.common.statemachine with parameters of type StateContextModifier and TypeMethodDescriptionvoidDatanodeStateMachine.setContext(StateContext context) Sets the current context. -
Uses of StateContext in org.apache.hadoop.ozone.container.common.statemachine.commandhandler
Methods in org.apache.hadoop.ozone.container.common.statemachine.commandhandler that return StateContextMethods in org.apache.hadoop.ozone.container.common.statemachine.commandhandler with parameters of type StateContextModifier and TypeMethodDescriptionvoidCloseContainerCommandHandler.handle(SCMCommand<?> command, OzoneContainer ozoneContainer, StateContext context, SCMConnectionManager connectionManager) Handles a given SCM command.voidClosePipelineCommandHandler.handle(SCMCommand<?> command, OzoneContainer ozoneContainer, StateContext context, SCMConnectionManager connectionManager) Handles a given SCM command.voidCommandHandler.handle(SCMCommand<?> command, OzoneContainer container, StateContext context, SCMConnectionManager connectionManager) Handles a given SCM command.voidCreatePipelineCommandHandler.handle(SCMCommand<?> command, OzoneContainer ozoneContainer, StateContext context, SCMConnectionManager connectionManager) Handles a given SCM command.voidDeleteBlocksCommandHandler.handle(SCMCommand<?> command, OzoneContainer container, StateContext context, SCMConnectionManager connectionManager) voidDeleteContainerCommandHandler.handle(SCMCommand<?> command, OzoneContainer ozoneContainer, StateContext context, SCMConnectionManager connectionManager) voidFinalizeNewLayoutVersionCommandHandler.handle(SCMCommand<?> command, OzoneContainer ozoneContainer, StateContext context, SCMConnectionManager connectionManager) Handles a given SCM command.voidReconcileContainerCommandHandler.handle(SCMCommand command, OzoneContainer container, StateContext context, SCMConnectionManager connectionManager) voidReconstructECContainersCommandHandler.handle(SCMCommand<?> command, OzoneContainer container, StateContext context, SCMConnectionManager connectionManager) voidRefreshVolumeUsageCommandHandler.handle(SCMCommand<?> command, OzoneContainer container, StateContext context, SCMConnectionManager connectionManager) voidReplicateContainerCommandHandler.handle(SCMCommand<?> command, OzoneContainer container, StateContext context, SCMConnectionManager connectionManager) voidSetNodeOperationalStateCommandHandler.handle(SCMCommand<?> command, OzoneContainer container, StateContext context, SCMConnectionManager connectionManager) Handles a given SCM command.CommandDispatcher.Builder.setContext(StateContext stateContext) Sets the Context.default voidCommandHandler.updateCommandStatus(StateContext context, SCMCommand<?> command, Consumer<CommandStatus> cmdStatusUpdater, org.slf4j.Logger log) Default implementation for updating command status.Constructors in org.apache.hadoop.ozone.container.common.statemachine.commandhandler with parameters of type StateContextModifierConstructorDescriptionDeleteCmdInfo(DeleteBlocksCommand command, OzoneContainer container, StateContext context, SCMConnectionManager connectionManager) -
Uses of StateContext in org.apache.hadoop.ozone.container.common.states.datanode
Constructors in org.apache.hadoop.ozone.container.common.states.datanode with parameters of type StateContextModifierConstructorDescriptionInitDatanodeState(org.apache.hadoop.hdds.conf.ConfigurationSource conf, SCMConnectionManager connectionManager, StateContext context) Create InitDatanodeState Task.RunningDatanodeState(org.apache.hadoop.hdds.conf.ConfigurationSource conf, SCMConnectionManager connectionManager, StateContext context) -
Uses of StateContext in org.apache.hadoop.ozone.container.common.states.endpoint
Methods in org.apache.hadoop.ozone.container.common.states.endpoint with parameters of type StateContextModifier and TypeMethodDescriptionHeartbeatEndpointTask.Builder.setContext(StateContext stateContext) Sets the context.RegisterEndpointTask.Builder.setContext(StateContext stateContext) Constructors in org.apache.hadoop.ozone.container.common.states.endpoint with parameters of type StateContextModifierConstructorDescriptionHeartbeatEndpointTask(EndpointStateMachine rpcEndpoint, org.apache.hadoop.hdds.conf.ConfigurationSource conf, StateContext context, org.apache.hadoop.hdds.upgrade.HDDSLayoutVersionManager versionManager) Constructs a SCM heart beat.RegisterEndpointTask(EndpointStateMachine rpcEndPoint, OzoneContainer ozoneContainer, StateContext context, org.apache.hadoop.hdds.upgrade.HDDSLayoutVersionManager versionManager) Creates a register endpoint task. -
Uses of StateContext in org.apache.hadoop.ozone.container.common.transport.server.ratis
Methods in org.apache.hadoop.ozone.container.common.transport.server.ratis with parameters of type StateContextModifier and TypeMethodDescriptionstatic XceiverServerRatisXceiverServerRatis.newXceiverServerRatis(HddsDatanodeService hddsDatanodeService, org.apache.hadoop.hdds.protocol.DatanodeDetails datanodeDetails, org.apache.hadoop.hdds.conf.ConfigurationSource ozoneConf, ContainerDispatcher dispatcher, ContainerController containerController, org.apache.hadoop.hdds.security.x509.certificate.client.CertificateClient caClient, StateContext context) -
Uses of StateContext in org.apache.hadoop.ozone.container.common.volume
Constructors in org.apache.hadoop.ozone.container.common.volume with parameters of type StateContextModifierConstructorDescriptionMutableVolumeSet(String dnUuid, String clusterID, org.apache.hadoop.hdds.conf.ConfigurationSource conf, StateContext context, StorageVolume.VolumeType volumeType, StorageVolumeChecker volumeChecker) MutableVolumeSet(String dnUuid, org.apache.hadoop.hdds.conf.ConfigurationSource conf, StateContext context, StorageVolume.VolumeType volumeType, StorageVolumeChecker volumeChecker) -
Uses of StateContext in org.apache.hadoop.ozone.container.ec.reconstruction
Constructors in org.apache.hadoop.ozone.container.ec.reconstruction with parameters of type StateContextModifierConstructorDescriptionECReconstructionCoordinator(org.apache.hadoop.hdds.conf.ConfigurationSource conf, org.apache.hadoop.hdds.security.x509.certificate.client.CertificateClient certificateClient, org.apache.hadoop.hdds.security.symmetric.SecretKeySignerClient secretKeyClient, StateContext context, ECReconstructionMetrics metrics, String threadNamePrefix) -
Uses of StateContext in org.apache.hadoop.ozone.container.ozoneimpl
Constructors in org.apache.hadoop.ozone.container.ozoneimpl with parameters of type StateContextModifierConstructorDescriptionOzoneContainer(org.apache.hadoop.hdds.protocol.DatanodeDetails datanodeDetails, org.apache.hadoop.hdds.conf.ConfigurationSource conf, StateContext context, VolumeChoosingPolicy volumeChoosingPolicy) Shorthand constructor used for testing in non-secure context.OzoneContainer(HddsDatanodeService hddsDatanodeService, org.apache.hadoop.hdds.protocol.DatanodeDetails datanodeDetails, org.apache.hadoop.hdds.conf.ConfigurationSource conf, StateContext context, org.apache.hadoop.hdds.security.x509.certificate.client.CertificateClient certClient, org.apache.hadoop.hdds.security.symmetric.SecretKeyVerifierClient secretKeyClient, VolumeChoosingPolicy volumeChoosingPolicy) Construct OzoneContainer object. -
Uses of StateContext in org.apache.hadoop.ozone.container.replication
Methods in org.apache.hadoop.ozone.container.replication with parameters of type StateContextModifier and TypeMethodDescriptionReplicationSupervisor.Builder.stateContext(StateContext newContext)