org.apache.ambari.server.controller.internal

Class UnitUpdater

java.lang.Object

org.apache.ambari.server.controller.internal.UnitUpdater

All Implemented Interfaces:

BlueprintConfigurationProcessor.PropertyUpdater

public class UnitUpdater
extends Object
implements BlueprintConfigurationProcessor.PropertyUpdater

I append the stack defined unit to the original property value. For example, "1024" would be updated to "1024m" if the stack unit is MB Properties with any other unit than the stack defined unit are rejected.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	UnitUpdater.PropertyUnit
static class	UnitUpdater.PropertyValue

Constructor Summary

Constructors

Constructor and Description
UnitUpdater(String serviceName, String configType)

Method Summary

Modifier and Type	Method and Description
Collection<String>	getRequiredHostGroups(String propertyName, String origValue, Map<String,Map<String,String>> properties, ClusterTopology topology) Determine the required host groups for the provided property.
static void	removeUnits(Configuration configuration, Stack stack)
String	updateForBlueprintExport(String propertyName, String origValue, Map<String,Map<String,String>> properties, ClusterTopology topology)
static String	updateForClusterCreate(Stack stack, String serviceName, String configType, String propertyName, String origValue)
String	updateForClusterCreate(String propertyName, String origValue, Map<String,Map<String,String>> properties, ClusterTopology topology) Update a property value.
static void	updateUnits(Configuration configuration, Stack stack)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.ambari.server.controller.internal.BlueprintConfigurationProcessor.PropertyUpdater

defaultUpdater

Constructor Detail

UnitUpdater

public UnitUpdater(String serviceName,
                   String configType)

Method Detail

updateForClusterCreate

public String updateForClusterCreate(String propertyName,
                                     String origValue,
                                     Map<String,Map<String,String>> properties,
                                     ClusterTopology topology)

Description copied from interface: BlueprintConfigurationProcessor.PropertyUpdater

Update a property value.

Specified by:

updateForClusterCreate in interface BlueprintConfigurationProcessor.PropertyUpdater

Parameters:

propertyName - property name

origValue - original value of property

properties - all properties

topology - cluster topology

Returns:

property value with updated unit

updateForClusterCreate

public static String updateForClusterCreate(Stack stack,
                                            String serviceName,
                                            String configType,
                                            String propertyName,
                                            String origValue)

updateUnits

public static void updateUnits(Configuration configuration,
                               Stack stack)

removeUnits

public static void removeUnits(Configuration configuration,
                               Stack stack)

updateForBlueprintExport

public String updateForBlueprintExport(String propertyName,
                                       String origValue,
                                       Map<String,Map<String,String>> properties,
                                       ClusterTopology topology)

Specified by:

updateForBlueprintExport in interface BlueprintConfigurationProcessor.PropertyUpdater

Returns:

property value with removed unit

getRequiredHostGroups

public Collection<String> getRequiredHostGroups(String propertyName,
                                                String origValue,
                                                Map<String,Map<String,String>> properties,
                                                ClusterTopology topology)

Description copied from interface: BlueprintConfigurationProcessor.PropertyUpdater

Determine the required host groups for the provided property.

Specified by:

getRequiredHostGroups in interface BlueprintConfigurationProcessor.PropertyUpdater

Parameters:

propertyName - property name

origValue - original value of property

properties - all properties

topology - cluster topology

Returns:

new property value