Class IsolatedNode
- java.lang.Object
-
- org.apache.ignite.spi.discovery.isolated.IsolatedNode
-
- All Implemented Interfaces:
BaselineNode,ClusterNode,org.apache.ignite.internal.managers.discovery.IgniteClusterNode
public class IsolatedNode extends Object implements org.apache.ignite.internal.managers.discovery.IgniteClusterNode
Special isolated node.
-
-
Constructor Summary
Constructors Constructor Description IsolatedNode(UUID id, Map<String,Object> attrs, IgniteProductVersion ver)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Collection<String>addresses()Gets collection of addresses this node is known by.<T> Tattribute(String name)Gets a node attribute.Map<String,Object>attributes()Gets all node attributes.Map<Integer,CacheMetrics>cacheMetrics()Gets collections of cache metrics for this node.ObjectconsistentId()Gets consistent globally unique node ID.Collection<String>hostNames()Gets collection of host names this node is known by.UUIDid()Gets globally unique node ID.booleanisClient()Whether this node is cache client (seeIgniteConfiguration.isClientMode()).booleanisLocal()Tests whether or not this node is a local node.ClusterMetricsmetrics()Gets metrics snapshot for this node.longorder()Node order within grid topology.voidsetAttributes(Map<String,Object> attrs)voidsetCacheMetrics(Map<Integer,CacheMetrics> cacheMetrics)Sets node cache metrics.voidsetConsistentId(Serializable consistentId)Sets consistent globally unique node ID which survives node restarts.voidsetMetrics(ClusterMetrics metrics)Sets node metrics.IgniteProductVersionversion()Gets node version.
-
-
-
Constructor Detail
-
IsolatedNode
public IsolatedNode(UUID id, Map<String,Object> attrs, IgniteProductVersion ver)
- Parameters:
id- Node ID.attrs- Node attributes.ver- Node version.
-
-
Method Detail
-
id
public UUID id()
Gets globally unique node ID. A new ID is generated every time a node restarts.- Specified by:
idin interfaceClusterNode- Returns:
- Globally unique node ID.
-
consistentId
public Object consistentId()
Gets consistent globally unique node ID. UnlikeClusterNode.id()method, this method returns consistent node ID which survives node restarts.- Specified by:
consistentIdin interfaceBaselineNode- Specified by:
consistentIdin interfaceClusterNode- Returns:
- Consistent globally unique node ID.
-
attribute
public <T> T attribute(String name)
Gets a node attribute. Attributes are assigned to nodes at startup viaIgniteConfiguration.getUserAttributes()method.The system adds the following attributes automatically:
{@link System#getProperties()}- All system properties.{@link System#getenv(String)}- All environment properties.- All attributes defined in
IgniteNodeAttributes
Note that attributes cannot be changed at runtime.
- Specified by:
attributein interfaceBaselineNode- Specified by:
attributein interfaceClusterNode- Type Parameters:
T- Attribute Type.- Parameters:
name- Attribute name. Note that attribute names starting withorg.apache.igniteare reserved for internal use.- Returns:
- Attribute value or
null.
-
metrics
public ClusterMetrics metrics()
Gets metrics snapshot for this node. Note that node metrics are constantly updated and provide up to date information about nodes. For example, you can get an idea about CPU load on remote node viaClusterMetrics.getCurrentCpuLoad()method and use it duringComputeTask.map(List, Object)or during collision resolution.Node metrics are updated with some delay which is controlled by
IgniteConfiguration.getMetricsUpdateFrequency()parameter. By default the update will happen every2seconds.- Specified by:
metricsin interfaceClusterNode- Returns:
- Runtime metrics snapshot for this node.
-
attributes
public Map<String,Object> attributes()
Gets all node attributes. Attributes are assigned to nodes at startup viaIgniteConfiguration.getUserAttributes()method.The system adds the following attributes automatically:
{@link System#getProperties()}- All system properties.{@link System#getenv(String)}- All environment properties.- All attributes defined in
IgniteNodeAttributes
Note that attributes cannot be changed at runtime.
- Specified by:
attributesin interfaceBaselineNode- Specified by:
attributesin interfaceClusterNode- Returns:
- All node attributes.
-
addresses
public Collection<String> addresses()
Gets collection of addresses this node is known by.If
IgniteConfiguration.getLocalHost()value isn'tnullnode will try to use that address for all communications and returned collection will contain only that address. If it isnullthen local wildcard address will be used, and Ignite will make the best effort to supply all addresses of that node in returned collection.- Specified by:
addressesin interfaceClusterNode- Returns:
- Collection of addresses.
-
hostNames
public Collection<String> hostNames()
Gets collection of host names this node is known by.If
IgniteConfiguration.getLocalHost()value isn'tnullnode will try to use the host name of that resolved address for all communications and returned collection will contain only that host name. If that host name can not be resolved then ip address returned by methodClusterNode.addresses()is used.If
IgniteConfiguration.getLocalHost()value isnullthen local wildcard address will be used, and this method returns host names of all addresses of that node.Note: the loopback address will be omitted in results.
- Specified by:
hostNamesin interfaceClusterNode- Returns:
- Collection of host names.
-
order
public long order()
Node order within grid topology. Discovery SPIs that support node ordering will assign a proper order to each node and will guarantee that discovery event notifications for new nodes will come in proper order. All other SPIs not supporting ordering may choose to return node startup time here.NOTE: in cases when discovery SPI doesn't support ordering Ignite cannot guarantee that orders on all nodes will be unique or chronologically correct. If such guarantee is required - make sure use discovery SPI that provides ordering.
- Specified by:
orderin interfaceClusterNode- Returns:
- Node startup order.
-
version
public IgniteProductVersion version()
Gets node version.- Specified by:
versionin interfaceClusterNode- Returns:
- Node version.
-
isLocal
public boolean isLocal()
Tests whether or not this node is a local node.- Specified by:
isLocalin interfaceClusterNode- Returns:
Trueif this node is a local node,falseotherwise.
-
isClient
public boolean isClient()
Whether this node is cache client (seeIgniteConfiguration.isClientMode()).- Specified by:
isClientin interfaceClusterNode- Returns:
True if client.- See Also:
IgniteConfiguration.isClientMode()
-
setConsistentId
public void setConsistentId(Serializable consistentId)
Sets consistent globally unique node ID which survives node restarts.- Specified by:
setConsistentIdin interfaceorg.apache.ignite.internal.managers.discovery.IgniteClusterNode- Parameters:
consistentId- Consistent globally unique node ID.
-
setMetrics
public void setMetrics(ClusterMetrics metrics)
Sets node metrics.- Specified by:
setMetricsin interfaceorg.apache.ignite.internal.managers.discovery.IgniteClusterNode- Parameters:
metrics- Node metrics.
-
cacheMetrics
public Map<Integer,CacheMetrics> cacheMetrics()
Gets collections of cache metrics for this node. Note that node cache metrics are constantly updated and provide up to date information about caches.Cache metrics are updated with some delay which is directly related to metrics update frequency. For example, by default the update will happen every
2seconds.- Specified by:
cacheMetricsin interfaceorg.apache.ignite.internal.managers.discovery.IgniteClusterNode- Returns:
- Runtime metrics snapshots for this node.
-
setCacheMetrics
public void setCacheMetrics(Map<Integer,CacheMetrics> cacheMetrics)
Sets node cache metrics.- Specified by:
setCacheMetricsin interfaceorg.apache.ignite.internal.managers.discovery.IgniteClusterNode- Parameters:
cacheMetrics- Cache metrics.
-
-