Package org.apache.ignite.internal.processors.configuration.distributed

Class SimpleDistributedProperty<T extends Serializable>

java.lang.Object

org.apache.ignite.internal.processors.configuration.distributed.SimpleDistributedProperty<T>

All Implemented Interfaces:

DistributedChangeableProperty<T>, DistributedProperty<T>

Direct Known Subclasses:

DistributedBooleanProperty, DistributedComparableProperty, DistributedTracingConfiguration

public class SimpleDistributedProperty<T extends Serializable>
extends Object
implements DistributedChangeableProperty<T>

Wrapper of some serializable property providing ability of change this value across whole cluster.

Field Summary

Fields

Modifier and Type	Field	Description
protected T	val	Property value.

Constructor Summary

Constructors

Constructor	Description
SimpleDistributedProperty(String name, Function<String,T> parser, String description)

Method Summary

Modifier and Type	Method	Description
void	addListener(DistributePropertyListener<? super T> listener)
String	description()
T	get()
String	getName()
T	getOrDefault(T dfltVal)
void	localUpdate(Serializable newVal)	Update only local value without updating remote cluster.
void	onAttached()	This property have been attached to processor.
void	onReadyForUpdate(@NotNull PropertyUpdateClosure updater)	On this property ready to be update on cluster wide.
T	parse(String str)
static Integer	parseNonNegativeInteger(String val)
static Long	parseNonNegativeLong(String val)
static HashSet<String>	parseStringSet(String val)
boolean	propagate(T newVal)	Change value across whole cluster.
GridFutureAdapter<?>	propagateAsync(T newVal)	Change value across whole cluster.
GridFutureAdapter<?>	propagateAsync(T expectedVal, T newVal)	Change value across whole cluster.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

val

protected volatile T extends Serializable val

Property value.

Constructor Detail

SimpleDistributedProperty

public SimpleDistributedProperty(String name,
                                 Function<String,T> parser,
                                 String description)

Parameters:

name - Name of property.

parser - Property value parser.

description - Description of property.

Method Detail

propagate

public boolean propagate(T newVal)
                  throws IgniteCheckedException

Change value across whole cluster.

Specified by:

propagate in interface DistributedProperty<T extends Serializable>

Parameters:

newVal - Value which this property should be changed on.

Returns:

true if value was successfully updated and false if cluster wide update was failed, perhaps some concurrent operation was changed this value in same moment.

Throws:

DetachedPropertyException - If this property have not been attached to processor yet, please call DistributedConfigurationProcessor.registerProperty(DistributedChangeableProperty) before this method.

NotWritablePropertyException - If this property don't ready to cluster wide update yet, perhaps cluster is not active yet.

IgniteCheckedException - If failed during cluster wide update.

propagateAsync

public GridFutureAdapter<?> propagateAsync(T newVal)
                                    throws IgniteCheckedException

Change value across whole cluster.

Specified by:

propagateAsync in interface DistributedProperty<T extends Serializable>

Parameters:

newVal - Value which this property should be changed on.

Returns:

Future for update operation.

Throws:

DetachedPropertyException - If this property have not been attached to processor yet, please call DistributedConfigurationProcessor.registerProperty(DistributedChangeableProperty) before this method.

NotWritablePropertyException - If this property don't ready to cluster wide update yet, perhaps cluster is not active yet.

IgniteCheckedException - If failed during cluster wide update.

propagateAsync

public GridFutureAdapter<?> propagateAsync(T expectedVal,
                                           T newVal)
                                    throws IgniteCheckedException

Change value across whole cluster.

Specified by:

propagateAsync in interface DistributedProperty<T extends Serializable>

Parameters:

expectedVal - Value from which this property should be changed.

newVal - Value which this property should be changed on.

Returns:

Future for update operation.

Throws:

DetachedPropertyException - If this property have not been attached to processor yet, please call DistributedConfigurationProcessor.registerProperty(DistributedChangeableProperty) before this method.

NotWritablePropertyException - If this property don't ready to cluster wide update yet, perhaps cluster is not active yet.

IgniteCheckedException - If failed during cluster wide update.

get

public T get()

Specified by:

get in interface DistributedProperty<T extends Serializable>

Returns:

Current property value.

getOrDefault

public T getOrDefault(T dfltVal)

Specified by:

getOrDefault in interface DistributedProperty<T extends Serializable>

Parameters:

dfltVal - Default value when current value is null.

Returns:

Current property value.

getName

public String getName()

Specified by:

getName in interface DistributedProperty<T extends Serializable>

Returns:

Name of property.

description

public String description()

Specified by:

description in interface DistributedProperty<T extends Serializable>

Returns:

Property description.

addListener

public void addListener(DistributePropertyListener<? super T> listener)

Specified by:

addListener in interface DistributedProperty<T extends Serializable>

Parameters:

listener - Update listener.

onAttached

public void onAttached()

This property have been attached to processor.

Specified by:

onAttached in interface DistributedChangeableProperty<T extends Serializable>

onReadyForUpdate

public void onReadyForUpdate(@NotNull
                             @NotNull PropertyUpdateClosure updater)

On this property ready to be update on cluster wide.

Specified by:

onReadyForUpdate in interface DistributedChangeableProperty<T extends Serializable>

Parameters:

updater - Consumer for update value across cluster.

localUpdate

public void localUpdate(Serializable newVal)

Update only local value without updating remote cluster.

Specified by:

localUpdate in interface DistributedChangeableProperty<T extends Serializable>

Parameters:

newVal - New value.

parse

public T parse(String str)

Specified by:

parse in interface DistributedChangeableProperty<T extends Serializable>

Parameters:

str - String representation of the property value.

Returns:

Property value.

toString

public String toString()

Overrides:

toString in class Object

parseNonNegativeInteger

public static Integer parseNonNegativeInteger(String val)

Parameters:

val - String to parse.

Returns:

Integer value.

parseNonNegativeLong

public static Long parseNonNegativeLong(String val)

Parameters:

val - String to parse.

Returns:

Long value.

parseStringSet

public static HashSet<String> parseStringSet(String val)

Parameters:

val - String value.

Returns:

String set.