Modifier and Type | Method and Description |
---|---|
boolean |
ActionManager.isInProgressCommand(CommandReport report)
Find if the command report is for an in progress command
|
void |
ActionDBAccessor.updateHostRoleState(String hostname,
long requestId,
long stageId,
String role,
CommandReport report)
For the given host, update all the tasks based on the command report
|
void |
ActionDBAccessorImpl.updateHostRoleState(String hostname,
long requestId,
long stageId,
String role,
CommandReport report) |
Modifier and Type | Method and Description |
---|---|
void |
ActionManager.processTaskResponse(String hostname,
List<CommandReport> reports,
Map<Long,HostRoleCommand> commands)
Persists command reports into the db
|
void |
ActionDBAccessor.updateHostRoleStates(Collection<CommandReport> reports)
Update tasks according to command reports
|
void |
ActionDBAccessorImpl.updateHostRoleStates(Collection<CommandReport> reports) |
Modifier and Type | Method and Description |
---|---|
List<CommandReport> |
HeartBeat.getReports() |
Modifier and Type | Method and Description |
---|---|
void |
HeartBeatHandler.handleCommandReportStatus(List<CommandReport> reports,
String hostname) |
protected void |
CommandStatusAgentReport.process(List<CommandReport> report,
String hostName) |
protected void |
HeartbeatProcessor.processCommandReports(List<CommandReport> reports,
String hostName,
Long now) |
protected void |
HeartbeatProcessor.processHostStatus(List<ComponentStatus> componentStatuses,
List<CommandReport> reports,
String hostName) |
void |
HeartBeat.setReports(List<CommandReport> reports) |
Constructor and Description |
---|
CommandStatusAgentReport(HeartBeatHandler hh,
String hostName,
List<CommandReport> commandReports) |
Modifier and Type | Method and Description |
---|---|
TreeMap<String,List<CommandReport>> |
CommandStatusReports.getClustersComponentReports() |
Modifier and Type | Method and Description |
---|---|
void |
CommandStatusReports.setClustersComponentReports(TreeMap<String,List<CommandReport>> clustersComponentReports) |
Modifier and Type | Method and Description |
---|---|
CommandReport |
ActionFinalReportReceivedEvent.getCommandReport() |
Constructor and Description |
---|
ActionFinalReportReceivedEvent(Long clusterId,
String hostname,
CommandReport report,
Boolean emulated)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected CommandReport |
AbstractServerAction.createCommandReport(int exitCode,
HostRoleStatus status,
String structuredOut,
String stdout,
String stderr)
Creates a CommandReport used to report back to Ambari the status of this ServerAction.
|
protected CommandReport |
AbstractServerAction.createCompletedCommandReport() |
CommandReport |
ServerAction.execute(ConcurrentMap<String,Object> requestSharedDataContext)
Executes this ServerAction
This is typically called by the ServerActionExecutor in it's own thread, but there is no
guarantee that this is the case.
|
Modifier and Type | Method and Description |
---|---|
CommandReport |
CleanupServerAction.execute(ConcurrentMap<String,Object> requestSharedDataContext) |
CommandReport |
CreatePrincipalsServerAction.execute(ConcurrentMap<String,Object> requestSharedDataContext)
Called to execute this action.
|
CommandReport |
PrepareEnableKerberosServerAction.execute(ConcurrentMap<String,Object> requestSharedDataContext)
Called to execute this action.
|
CommandReport |
FinalizeKerberosServerAction.execute(ConcurrentMap<String,Object> requestSharedDataContext) |
CommandReport |
DestroyPrincipalsServerAction.execute(ConcurrentMap<String,Object> requestSharedDataContext)
Called to execute this action.
|
CommandReport |
PrepareDisableKerberosServerAction.execute(ConcurrentMap<String,Object> requestSharedDataContext)
Called to execute this action.
|
CommandReport |
ConfigureAmbariIdentitiesServerAction.execute(ConcurrentMap<String,Object> requestSharedDataContext)
Called to execute this action.
|
CommandReport |
PrepareKerberosIdentitiesServerAction.execute(ConcurrentMap<String,Object> requestSharedDataContext)
Called to execute this action.
|
CommandReport |
CreateKeytabFilesServerAction.execute(ConcurrentMap<String,Object> requestSharedDataContext)
Called to execute this action.
|
CommandReport |
UpdateKerberosConfigsServerAction.execute(ConcurrentMap<String,Object> requestSharedDataContext)
Executes this ServerAction
This is typically called by the ServerActionExecutor in it's own thread, but there is no
guarantee that this is the case.
|
protected CommandReport |
KerberosServerAction.processIdentities(Map<String,Object> requestSharedDataContext)
Iterates through the Kerberos identity metadata from the
KerberosIdentityDataFileReader and calls
the implementing class to handle each identity found. |
protected CommandReport |
CleanupServerAction.processIdentity(ResolvedKerberosPrincipal resolvedPrincipal,
KerberosOperationHandler operationHandler,
Map<String,String> kerberosConfiguration,
boolean includedInFilter,
Map<String,Object> requestSharedDataContext)
Processes an identity as necessary.
|
protected CommandReport |
CreatePrincipalsServerAction.processIdentity(ResolvedKerberosPrincipal resolvedPrincipal,
KerberosOperationHandler operationHandler,
Map<String,String> kerberosConfiguration,
boolean includedInFilter,
Map<String,Object> requestSharedDataContext)
For each identity, generate a unique password, and create a new or update an existing principal in
an assumed to be configured KDC.
|
protected CommandReport |
PrepareEnableKerberosServerAction.processIdentity(ResolvedKerberosPrincipal resolvedPrincipal,
KerberosOperationHandler operationHandler,
Map<String,String> kerberosConfiguration,
boolean includedInFilter,
Map<String,Object> requestSharedDataContext) |
protected CommandReport |
FinalizeKerberosServerAction.processIdentity(ResolvedKerberosPrincipal resolvedPrincipal,
KerberosOperationHandler operationHandler,
Map<String,String> kerberosConfiguration,
boolean includedInFilter,
Map<String,Object> requestSharedDataContext)
Processes an identity as necessary.
|
protected CommandReport |
DestroyPrincipalsServerAction.processIdentity(ResolvedKerberosPrincipal resolvedPrincipal,
KerberosOperationHandler operationHandler,
Map<String,String> kerberosConfiguration,
boolean includedInFilter,
Map<String,Object> requestSharedDataContext)
For each identity, remove the principal from the configured KDC.
|
protected CommandReport |
AbstractPrepareKerberosServerAction.processIdentity(ResolvedKerberosPrincipal resolvedPrincipal,
KerberosOperationHandler operationHandler,
Map<String,String> kerberosConfiguration,
boolean includedInFilter,
Map<String,Object> requestSharedDataContext) |
protected CommandReport |
ConfigureAmbariIdentitiesServerAction.processIdentity(ResolvedKerberosPrincipal resolvedPrincipal,
KerberosOperationHandler operationHandler,
Map<String,String> kerberosConfiguration,
boolean includedInFilter,
Map<String,Object> requestSharedDataContext)
Creates keytab file for ambari-server identity.
|
protected abstract CommandReport |
KerberosServerAction.processIdentity(ResolvedKerberosPrincipal resolvedPrincipal,
KerberosOperationHandler operationHandler,
Map<String,String> kerberosConfiguration,
boolean includedInFilter,
Map<String,Object> requestSharedDataContext)
Processes an identity as necessary.
|
protected CommandReport |
CreateKeytabFilesServerAction.processIdentity(ResolvedKerberosPrincipal resolvedPrincipal,
KerberosOperationHandler operationHandler,
Map<String,String> kerberosConfiguration,
boolean includedInFilter,
Map<String,Object> requestSharedDataContext)
For each identity, create a keytab and append to a new or existing keytab file.
|
Modifier and Type | Method and Description |
---|---|
CommandReport |
UpdateDesiredRepositoryAction.execute(ConcurrentMap<String,Object> requestSharedDataContext)
Executes this ServerAction
This is typically called by the ServerActionExecutor in it's own thread, but there is no
guarantee that this is the case.
|
CommandReport |
PreconfigureKerberosAction.execute(ConcurrentMap<String,Object> requestSharedDataContext) |
CommandReport |
DeleteUnsupportedServicesAndComponents.execute(ConcurrentMap<String,Object> requestSharedDataContext) |
CommandReport |
YarnNodeManagerCapacityCalculation.execute(ConcurrentMap<String,Object> requestSharedDataContext) |
CommandReport |
PluginUpgradeServerAction.execute(ConcurrentMap<String,Object> requestSharedDataContext)
Executes this ServerAction
This is typically called by the ServerActionExecutor in it's own thread, but there is no
guarantee that this is the case.
|
CommandReport |
ConfigureAction.execute(ConcurrentMap<String,Object> requestSharedDataContext)
Aside from the normal execution, this method performs the following logic, with
the stack values set in the table below:
|
CommandReport |
AddComponentAction.execute(ConcurrentMap<String,Object> requestSharedDataContext)
Executes this ServerAction
This is typically called by the ServerActionExecutor in it's own thread, but there is no
guarantee that this is the case.
|
CommandReport |
CreateAndConfigureAction.execute(ConcurrentMap<String,Object> requestSharedDataContext) |
CommandReport |
KerberosKeytabsAction.execute(ConcurrentMap<String,Object> requestSharedDataContext) |
CommandReport |
UpgradeUserKerberosDescriptor.execute(ConcurrentMap<String,Object> requestSharedDataContext)
Update Kerberos Descriptor Storm properties when upgrading to Storm 1.0
Finds the relevant artifact entities and iterates through them to process each independently.
|
CommandReport |
ManualStageAction.execute(ConcurrentMap<String,Object> requestSharedDataContext) |
CommandReport |
AutoSkipFailedSummaryAction.execute(ConcurrentMap<String,Object> requestSharedDataContext)
Executes this ServerAction
This is typically called by the ServerActionExecutor in it's own thread, but there is no
guarantee that this is the case.
|
CommandReport |
ComponentVersionCheckAction.execute(ConcurrentMap<String,Object> requestSharedDataContext) |
CommandReport |
FinalizeUpgradeAction.execute(ConcurrentMap<String,Object> requestSharedDataContext) |
Modifier and Type | Method and Description |
---|---|
CommandReport |
PostUserCreationHookServerAction.execute(ConcurrentMap<String,Object> requestSharedDataContext) |
Copyright © 2022 Apache Software Foundation. All rights reserved.