| Modifier and Type | Method and Description |
|---|---|
GridNode |
Grid.localNode()
Gets local grid node.
|
<K> GridNode |
Grid.mapKeyToNode(String cacheName,
K key)
This method provides ability to detect which cache keys are mapped to which nodes
on cache instance with given name.
|
GridNode |
GridProjection.node()
Gets first node from the list of nodes in this projection.
|
GridNode |
GridProjection.node(UUID nid)
Gets a node for given ID from this grid projection.
|
| Modifier and Type | Method and Description |
|---|---|
<K> Map<GridNode,Collection<K>> |
Grid.mapKeysToNodes(String cacheName,
Collection<? extends K> keys)
This method provides ability to detect which cache keys are mapped to which nodes
on cache instance with given name.
|
Collection<GridNode> |
GridProjection.nodes()
Gets read-only collections of nodes in this projection.
|
GridPredicate<GridNode> |
GridProjection.predicate()
Gets predicate that defines a subset of nodes for this projection.
|
Collection<GridNode> |
Grid.topology(long topVer)
Gets a topology by version.
|
| Modifier and Type | Method and Description |
|---|---|
GridProjection |
GridProjection.forHost(GridNode node)
Gets grid projection consisting from the nodes in this projection residing on the
same host as given node.
|
GridProjection |
GridProjection.forNode(GridNode node,
GridNode... nodes)
Creates a grid projection for the given node.
|
GridProjection |
GridProjection.forNode(GridNode node,
GridNode... nodes)
Creates a grid projection for the given node.
|
GridProjection |
GridProjection.forOthers(GridNode node,
GridNode... nodes)
Creates a grid projection for nodes other than given nodes.
|
GridProjection |
GridProjection.forOthers(GridNode node,
GridNode... nodes)
Creates a grid projection for nodes other than given nodes.
|
| Modifier and Type | Method and Description |
|---|---|
GridProjection |
GridProjection.forNodes(Collection<? extends GridNode> nodes)
Creates a grid projection over a given set of nodes.
|
GridProjection |
GridProjection.forPredicate(GridPredicate<GridNode> p)
Creates a grid projection which includes all nodes that pass the given predicate filter.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridCacheAffinity.mapKeyToNode(K key)
This method provides ability to detect to which primary node the given key
is mapped.
|
GridNode |
GridCacheAffinity.mapPartitionToNode(int part)
Gets primary node for the given partition.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<GridNode>> |
GridCacheAffinityFunction.assignPartitions(GridCacheAffinityFunctionContext affCtx)
Gets affinity nodes for a partition.
|
List<GridNode> |
GridCacheAffinityFunctionContext.currentTopologySnapshot()
Gets current topology snapshot.
|
Map<GridNode,Collection<K>> |
GridCacheAffinity.mapKeysToNodes(Collection<? extends K> keys)
This method provides ability to detect which keys are mapped to which nodes.
|
Collection<GridNode> |
GridCacheAffinity.mapKeyToPrimaryAndBackups(K key)
Gets primary and backup nodes for the key.
|
Map<Integer,GridNode> |
GridCacheAffinity.mapPartitionsToNodes(Collection<Integer> parts)
Gets primary nodes for the given partitions.
|
Collection<GridNode> |
GridCacheAffinity.mapPartitionToPrimaryAndBackups(int part)
Gets primary and backup nodes for partition.
|
List<GridNode> |
GridCacheAffinityFunctionContext.previousAssignment(int part)
Gets affinity assignment for given partition on previous topology version.
|
| Modifier and Type | Method and Description |
|---|---|
int[] |
GridCacheAffinity.allPartitions(GridNode n)
Gets partition ids for which nodes of the given projection has ownership
(either primary or backup).
|
int[] |
GridCacheAffinity.backupPartitions(GridNode n)
Gets partition ids for which nodes of the given projection has backup
ownership.
|
boolean |
GridCacheAffinity.isBackup(GridNode n,
K key)
Returns
true if local node is one of the backup nodes for given key. |
boolean |
GridCacheAffinity.isPrimary(GridNode n,
K key)
Returns
true if given node is the primary node for given key. |
boolean |
GridCacheAffinity.isPrimaryOrBackup(GridNode n,
K key)
Returns
true if local node is primary or one of the backup nodes
for given key. |
int[] |
GridCacheAffinity.primaryPartitions(GridNode n)
Gets partition ids for which nodes of the given projection has primary
ownership.
|
Object |
GridCacheAffinityNodeIdHashResolver.resolve(GridNode node)
Resolve alternate hash value for the given Grid node.
|
Object |
GridCacheAffinityNodeHashResolver.resolve(GridNode node)
Resolve alternate hash value for the given Grid node.
|
Object |
GridCacheAffinityNodeAddressHashResolver.resolve(GridNode node)
Resolve alternate hash value for the given Grid node.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<GridNode>> |
GridCacheConsistentHashAffinityFunction.assignPartitions(GridCacheAffinityFunctionContext ctx)
Gets affinity nodes for a partition.
|
GridBiPredicate<GridNode,GridNode> |
GridCacheConsistentHashAffinityFunction.getBackupFilter()
Gets optional backup filter.
|
GridBiPredicate<GridNode,GridNode> |
GridCacheConsistentHashAffinityFunction.getBackupFilter()
Gets optional backup filter.
|
Collection<GridNode> |
GridCacheConsistentHashAffinityFunction.nodes(int part,
Collection<GridNode> nodes,
int backups)
Assigns nodes to one partition.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridNode> |
GridCacheConsistentHashAffinityFunction.nodes(int part,
Collection<GridNode> nodes,
int backups)
Assigns nodes to one partition.
|
void |
GridCacheConsistentHashAffinityFunction.setBackupFilter(GridBiPredicate<GridNode,GridNode> backupFilter)
Sets optional backup filter.
|
void |
GridCacheConsistentHashAffinityFunction.setBackupFilter(GridBiPredicate<GridNode,GridNode> backupFilter)
Sets optional backup filter.
|
| Constructor and Description |
|---|
GridCacheConsistentHashAffinityFunction(int parts,
GridBiPredicate<GridNode,GridNode> backupFilter)
Initializes optional counts for replicas and backups.
|
GridCacheConsistentHashAffinityFunction(int parts,
GridBiPredicate<GridNode,GridNode> backupFilter)
Initializes optional counts for replicas and backups.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<GridNode>> |
GridCachePartitionFairAffinity.assignPartitions(GridCacheAffinityFunctionContext ctx)
Gets affinity nodes for a partition.
|
| Modifier and Type | Method and Description |
|---|---|
List<GridNode> |
GridCacheRendezvousAffinityFunction.assignPartition(int part,
List<GridNode> nodes,
int backups,
Map<UUID,Collection<GridNode>> neighborhoodCache)
Returns collection of nodes (primary first) for specified partition.
|
List<List<GridNode>> |
GridCacheRendezvousAffinityFunction.assignPartitions(GridCacheAffinityFunctionContext affCtx)
Gets affinity nodes for a partition.
|
GridBiPredicate<GridNode,GridNode> |
GridCacheRendezvousAffinityFunction.getBackupFilter()
Gets optional backup filter.
|
GridBiPredicate<GridNode,GridNode> |
GridCacheRendezvousAffinityFunction.getBackupFilter()
Gets optional backup filter.
|
| Modifier and Type | Method and Description |
|---|---|
List<GridNode> |
GridCacheRendezvousAffinityFunction.assignPartition(int part,
List<GridNode> nodes,
int backups,
Map<UUID,Collection<GridNode>> neighborhoodCache)
Returns collection of nodes (primary first) for specified partition.
|
List<GridNode> |
GridCacheRendezvousAffinityFunction.assignPartition(int part,
List<GridNode> nodes,
int backups,
Map<UUID,Collection<GridNode>> neighborhoodCache)
Returns collection of nodes (primary first) for specified partition.
|
void |
GridCacheRendezvousAffinityFunction.setBackupFilter(GridBiPredicate<GridNode,GridNode> backupFilter)
Sets optional backup filter.
|
void |
GridCacheRendezvousAffinityFunction.setBackupFilter(GridBiPredicate<GridNode,GridNode> backupFilter)
Sets optional backup filter.
|
| Constructor and Description |
|---|
GridCacheRendezvousAffinityFunction(int parts,
GridBiPredicate<GridNode,GridNode> backupFilter)
Initializes optional counts for replicas and backups.
|
GridCacheRendezvousAffinityFunction(int parts,
GridBiPredicate<GridNode,GridNode> backupFilter)
Initializes optional counts for replicas and backups.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridComputeLoadBalancer.getBalancedNode(GridComputeJob job,
Collection<GridNode> exclNodes)
Gets the next balanced node according to the underlying load balancing policy.
|
GridNode |
GridComputeJobResult.getNode()
Gets node this job executed on.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
GridComputeTaskSplitAdapter.map(List<GridNode> subgrid,
T arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridComputeTask.map(List<GridNode> subgrid,
T arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridComputeTaskContinuousMapper.send(GridComputeJob job,
GridNode node)
Sends given job to a specific grid node.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridComputeLoadBalancer.getBalancedNode(GridComputeJob job,
Collection<GridNode> exclNodes)
Gets the next balanced node according to the underlying load balancing policy.
|
Map<? extends GridComputeJob,GridNode> |
GridComputeTaskSplitAdapter.map(List<GridNode> subgrid,
T arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridComputeTask.map(List<GridNode> subgrid,
T arg)
This method is called to map or split grid task into multiple grid jobs.
|
void |
GridComputeTaskContinuousMapper.send(Map<? extends GridComputeJob,GridNode> mappedJobs)
Sends collection of grid jobs to assigned nodes.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
GridifyDefaultTask.map(List<GridNode> subgrid,
GridifyArgument arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridifyDefaultRangeTask.map(List<GridNode> subgrid,
GridifyRangeArgument arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
GridifyDefaultTask.map(List<GridNode> subgrid,
GridifyArgument arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridifyDefaultRangeTask.map(List<GridNode> subgrid,
GridifyRangeArgument arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridCachePreloadingEvent.discoveryNode()
Gets shadow of the node that triggered this preloading event.
|
GridNode |
GridDiscoveryEvent.eventNode()
Gets node that caused this event to be generated.
|
GridNode |
GridCacheEvent.eventNode()
Gets node which initiated cache operation or
null if that node is not available. |
GridNode |
GridEventAdapter.node()
Node where event occurred and was recorded
|
GridNode |
GridEvent.node()
Node where event occurred and was recorded
|
GridNode |
GridJobEvent.taskNode()
Get node where parent task of the job has originated.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridNode> |
GridDiscoveryEvent.topologyNodes()
Gets topology nodes from topology snapshot.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDiscoveryEvent.eventNode(GridNode evtNode)
Sets node this event is referring to.
|
void |
GridEventAdapter.node(GridNode node)
Sets node where even is occurred (i.e.
|
void |
GridJobEvent.taskNode(GridNode taskNode)
Sets node where parent task of the job has originated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDiscoveryEvent.topologySnapshot(long topVer,
Collection<GridNode> topSnapshot)
Sets the topology snapshot.
|
| Constructor and Description |
|---|
GridAuthenticationEvent(GridNode node,
String msg,
int type)
Creates authentication event with given parameters.
|
GridAuthenticationEvent(GridNode node,
String msg,
int type,
GridSecuritySubjectType subjType,
UUID subjId,
Object login)
Creates authentication event with given parameters.
|
GridAuthorizationEvent(GridNode node,
String msg,
int type)
Creates authorization event with given parameters.
|
GridAuthorizationEvent(GridNode node,
String msg,
int type,
GridSecurityPermission op,
GridSecuritySubject subj)
Creates authorization event with given parameters.
|
GridCacheEvent(String cacheName,
GridNode node,
GridNode evtNode,
String msg,
int type,
int part,
boolean near,
Object key,
GridUuid xid,
Object lockId,
Object newVal,
boolean hasNewVal,
Object oldVal,
boolean hasOldVal,
UUID subjId)
Constructs cache event.
|
GridCachePreloadingEvent(String cacheName,
GridNode node,
String msg,
int type,
int part,
GridNode discoNode,
int discoEvtType,
long discoTs)
Constructs cache event.
|
GridCheckpointEvent(GridNode node,
String msg,
int type,
String cpKey)
Creates new checkpoint event with given parameters.
|
GridDeploymentEvent(GridNode node,
String msg,
int type)
Creates deployment event with given parameters.
|
GridDiscoveryEvent(GridNode node,
String msg,
int type)
Creates new discovery event with given parameters.
|
GridDiscoveryEvent(GridNode node,
String msg,
int type,
GridNode evtNode)
Creates new discovery event with given parameters.
|
GridEventAdapter(GridNode node,
String msg,
int type)
Creates event based with given parameters.
|
GridGgfsEvent(GridGgfsPath path,
GridGgfsPath newPath,
GridNode node,
int type)
Constructs an event instance for path modification event
(
GridEventType.EVT_GGFS_FILE_RENAMED,
GridEventType.EVT_GGFS_DIR_RENAMED). |
GridGgfsEvent(GridGgfsPath path,
GridNode node,
int type)
Constructs an event instance.
|
GridGgfsEvent(GridGgfsPath path,
GridNode node,
int type,
long dataSize)
Constructs an event instance for close events:
(
GridEventType.EVT_GGFS_FILE_CLOSED_READ,
GridEventType.EVT_GGFS_FILE_CLOSED_WRITE). |
GridGgfsEvent(GridGgfsPath path,
GridNode node,
int type,
Map<String,String> meta)
Constructs an event instance for file metadata update events
(
GridEventType.EVT_GGFS_META_UPDATED). |
GridJobEvent(GridNode node,
String msg,
int type)
Creates job event with given parameters.
|
GridLicenseEvent(GridNode node,
String msg,
int type)
Creates license event with given parameters.
|
GridSecureSessionEvent(GridNode node,
String msg,
int type)
Creates secure session event with given parameters.
|
GridSecureSessionEvent(GridNode node,
String msg,
int type,
GridSecuritySubjectType subjType,
UUID subjId)
Creates secure session event with given parameters.
|
GridSwapSpaceEvent(GridNode node,
String msg,
int type,
String space)
Creates swap space event.
|
GridTaskEvent(GridNode node,
String msg,
int type,
GridUuid sesId,
String taskName,
String taskClsName,
boolean internal,
UUID subjId)
Creates task event with given parameters.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
GridGgfsTask.map(List<GridNode> subgrid,
GridGgfsTaskArgs<T> args)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
GridGgfsTask.map(List<GridNode> subgrid,
GridGgfsTaskArgs<T> args)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridJobResultImpl.getNode()
Gets node this job executed on.
|
GridNode |
GridKernal.localNode()
Gets local grid node.
|
<K> GridNode |
GridKernal.mapKeyToNode(String cacheName,
K key)
This method provides ability to detect which cache keys are mapped to which nodes
on cache instance with given name.
|
GridNode |
GridProjectionAdapter.node()
Gets first node from the list of nodes in this projection.
|
GridNode |
GridProjectionAdapter.node(UUID id)
Gets a node for given ID from this grid projection.
|
| Modifier and Type | Method and Description |
|---|---|
<K> Map<GridNode,Collection<K>> |
GridKernal.mapKeysToNodes(String cacheName,
Collection<? extends K> keys)
This method provides ability to detect which cache keys are mapped to which nodes
on cache instance with given name.
|
Collection<GridNode> |
GridProjectionAdapter.nodes()
Gets read-only collections of nodes in this projection.
|
GridPredicate<GridNode> |
GridProjectionAdapter.predicate()
Gets predicate that defines a subset of nodes for this projection.
|
Collection<GridNode> |
GridKernal.topology(long topVer)
Gets a topology by version.
|
| Modifier and Type | Method and Description |
|---|---|
int |
GridNodeOrderComparator.compare(GridNode n1,
GridNode n2) |
GridProjection |
GridProjectionAdapter.forHost(GridNode node)
Gets grid projection consisting from the nodes in this projection residing on the
same host as given node.
|
GridProjection |
GridProjectionAdapter.forNode(GridNode node,
GridNode... nodes)
Creates a grid projection for the given node.
|
GridProjection |
GridProjectionAdapter.forNode(GridNode node,
GridNode... nodes)
Creates a grid projection for the given node.
|
GridProjection |
GridProjectionAdapter.forOthers(GridNode node,
GridNode... nodes)
Creates a grid projection for nodes other than given nodes.
|
GridProjection |
GridProjectionAdapter.forOthers(GridNode node,
GridNode... nodes)
Creates a grid projection for nodes other than given nodes.
|
void |
GridJobResultImpl.setNode(GridNode node) |
GridNodeValidationResult |
GridComponent.validateNode(GridNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
GridProjection |
GridProjectionAdapter.forNodes(Collection<? extends GridNode> nodes)
Creates a grid projection over a given set of nodes.
|
GridProjection |
GridProjectionAdapter.forPredicate(GridPredicate<GridNode> p)
Creates a grid projection which includes all nodes that pass the given predicate filter.
|
| Constructor and Description |
|---|
GridJobResultImpl(GridComputeJob job,
GridUuid jobId,
GridNode node,
GridJobSiblingImpl sib) |
GridLocalNodeMetrics(GridNode node) |
| Constructor and Description |
|---|
GridProjectionAdapter(GridProjection parent,
GridKernalContext ctx,
UUID subjId,
GridPredicate<GridNode> p) |
| Modifier and Type | Method and Description |
|---|---|
GridNodeValidationResult |
GridManagerAdapter.validateNode(GridNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
GridNodeValidationResult |
GridNoopManagerAdapter.validateNode(GridNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoManager.send(GridNode node,
GridTopic topic,
GridTcpCommunicationMessageAdapter msg,
GridIoPolicy plc) |
void |
GridIoManager.send(GridNode node,
Object topic,
GridTcpCommunicationMessageAdapter msg,
GridIoPolicy plc) |
void |
GridIoManager.sendOrderedMessage(GridNode node,
Object topic,
long msgId,
GridTcpCommunicationMessageAdapter msg,
GridIoPolicy plc,
long timeout,
boolean skipOnTimeout) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoManager.send(Collection<? extends GridNode> nodes,
GridTopic topic,
GridTcpCommunicationMessageAdapter msg,
GridIoPolicy plc) |
void |
GridIoManager.send(Collection<? extends GridNode> nodes,
Object topic,
GridTcpCommunicationMessageAdapter msg,
GridIoPolicy plc) |
void |
GridIoManager.sendOrderedMessage(Collection<? extends GridNode> nodes,
Object topic,
long msgId,
GridTcpCommunicationMessageAdapter msg,
GridIoPolicy plc,
long timeout,
boolean skipOnTimeout) |
void |
GridIoManager.sendUserMessage(Collection<? extends GridNode> nodes,
Object msg)
Sends a peer deployable user message.
|
void |
GridIoManager.sendUserMessage(Collection<? extends GridNode> nodes,
Object msg,
Object topic,
boolean ordered,
long timeout)
Sends a peer deployable user message.
|
| Modifier and Type | Method and Description |
|---|---|
GridDeployment |
GridDeploymentManager.getGlobalDeployment(GridDeploymentMode depMode,
String rsrcName,
String clsName,
String userVer,
UUID sndNodeId,
GridUuid clsLdrId,
Map<UUID,GridUuid> participants,
GridPredicate<GridNode> nodeFilter) |
void |
GridDeploymentManager.undeployTask(String taskName,
boolean locUndeploy,
Collection<GridNode> rmtNodes) |
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridDiscoveryManager.localNode() |
GridNode |
GridDiscoveryManager.node(UUID nodeId) |
| Modifier and Type | Method and Description |
|---|---|
Collection<GridNode> |
GridDiscoveryManager.aliveCacheNodes(String cacheName,
long topVer)
Gets cache nodes for cache with given name.
|
Collection<GridNode> |
GridDiscoveryManager.aliveRemoteCacheNodes(String cacheName,
long topVer)
Gets cache remote nodes for cache with given name.
|
Collection<GridNode> |
GridDiscoveryManager.allNodes() |
Collection<GridNode> |
GridDiscoveryManager.cacheAffinityNodes(String cacheName,
long topVer)
Gets cache nodes for cache with given name that participate in affinity calculation.
|
Collection<GridNode> |
GridDiscoveryManager.cacheNodes(String cacheName,
long topVer)
Gets cache nodes for cache with given name.
|
Collection<GridNode> |
GridDiscoveryManager.daemonNodes() |
Collection<GridNode> |
GridDiscoveryManager.nodes(Collection<UUID> ids,
GridPredicate<UUID>... p)
Gets collection of node for given node IDs and predicates.
|
Collection<GridNode> |
GridDiscoveryManager.nodes(long topVer)
Gets all nodes for given topology version.
|
Collection<GridNode> |
GridDiscoveryManager.remoteCacheNodes(String cacheName,
long topVer)
Gets cache remote nodes for cache with given name.
|
Collection<GridNode> |
GridDiscoveryManager.remoteNodes() |
Collection<GridNode> |
GridDiscoveryManager.topology(long topVer)
Gets topology by specified version from history storage.
|
Collection<GridNode> |
GridDiscoveryTopologySnapshot.topologyNodes() |
NavigableMap<GridProductVersion,Collection<GridNode>> |
GridDiscoveryManager.topologyVersionMap()
Gets topology grouped by node versions.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDiscoveryManager.alive(GridNode node) |
GridNodeShadow |
GridDiscoveryManager.shadow(GridNode node)
Gets node shadow.
|
| Modifier and Type | Method and Description |
|---|---|
long |
GridDiscoveryManager.topologyHash(Iterable<? extends GridNode> nodes)
Gets topology hash for given set of nodes.
|
| Constructor and Description |
|---|
GridDiscoveryTopologySnapshot(long topVer,
Collection<GridNode> topNodes)
Creates a topology snapshot with given topology version and topology nodes.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends GridEvent> |
GridEventStorageManager.remoteEventsAsync(GridPredicate<T> p,
Collection<? extends GridNode> nodes,
long timeout) |
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridFailoverManager.failover(GridTaskSessionImpl taskSes,
GridComputeJobResult jobRes,
List<GridNode> top) |
GridNode |
GridFailoverContextImpl.getBalancedNode(List<GridNode> top)
Gets the next balanced node for failed job.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridFailoverManager.failover(GridTaskSessionImpl taskSes,
GridComputeJobResult jobRes,
List<GridNode> top) |
GridNode |
GridFailoverContextImpl.getBalancedNode(List<GridNode> top)
Gets the next balanced node for failed job.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridLoadBalancerManager.getBalancedNode(GridTaskSessionImpl ses,
List<GridNode> top,
GridComputeJob job) |
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridLoadBalancerManager.getBalancedNode(GridTaskSessionImpl ses,
List<GridNode> top,
GridComputeJob job) |
GridComputeLoadBalancer |
GridLoadBalancerManager.getLoadBalancer(GridTaskSessionImpl ses,
List<GridNode> top) |
| Modifier and Type | Method and Description |
|---|---|
GridSecurityContext |
GridSecurityManager.authenticateNode(GridNode node,
GridSecurityCredentials cred)
Authenticates grid node with it's attributes via underlying
GridAuthenticationSpis. |
| Modifier and Type | Method and Description |
|---|---|
GridSecurityContext |
GridOsSecurityManager.authenticateNode(GridNode node,
GridSecurityCredentials cred)
Authenticates grid node with it's attributes via underlying
GridAuthenticationSpis. |
| Modifier and Type | Method and Description |
|---|---|
GridNodeValidationResult |
GridProcessorAdapter.validateNode(GridNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
<K> GridNode |
GridAffinityProcessor.mapKeyToNode(K key)
Maps single key to a node on default cache.
|
<K> GridNode |
GridAffinityProcessor.mapKeyToNode(String cacheName,
K key)
Maps single key to a node.
|
| Modifier and Type | Method and Description |
|---|---|
List<List<GridNode>> |
GridAffinityAssignmentCache.assignments(long topVer) |
List<List<GridNode>> |
GridAffinityAssignmentCache.calculate(long topVer,
GridDiscoveryEvent discoEvt)
Calculates affinity cache for given topology version.
|
List<GridNode> |
GridCacheAffinityFunctionContextImpl.currentTopologySnapshot()
Gets current topology snapshot.
|
<K> Map<GridNode,Collection<K>> |
GridAffinityProcessor.mapKeysToNodes(Collection<? extends K> keys)
Maps keys to nodes on default cache.
|
<K> Map<GridNode,Collection<K>> |
GridAffinityProcessor.mapKeysToNodes(String cacheName,
Collection<? extends K> keys)
Maps keys to nodes for given cache.
|
Collection<GridNode> |
GridAffinityAssignmentCache.nodes(int part,
long topVer)
Gets affinity nodes for specified partition.
|
List<GridNode> |
GridCacheAffinityFunctionContextImpl.previousAssignment(int part)
Gets affinity assignment for given partition on previous topology version.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridAffinityAssignmentCache.initialize(long topVer,
List<List<GridNode>> affAssignment)
Initializes affinity with given topology version and assignment.
|
| Constructor and Description |
|---|
GridCacheAffinityFunctionContextImpl(List<GridNode> topSnapshot,
List<List<GridNode>> prevAssignment,
GridDiscoveryEvent discoEvt,
long topVer,
int backups) |
GridCacheAffinityFunctionContextImpl(List<GridNode> topSnapshot,
List<List<GridNode>> prevAssignment,
GridDiscoveryEvent discoEvt,
long topVer,
int backups) |
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridCacheContext.localNode() |
static GridNode |
GridCacheUtils.localOrPrimary(Iterable<GridNode> nodes,
UUID locId) |
GridNode |
GridCacheContext.node(UUID nodeId) |
static GridNode |
GridCacheUtils.oldest(GridCacheContext cctx)
Gets oldest alive node for specified topology version.
|
static GridNode |
GridCacheUtils.oldest(GridCacheContext cctx,
long topOrder)
Gets oldest alive node for specified topology version.
|
GridNode |
GridCacheAffinityManager.primary(int part,
long topVer) |
static GridNode |
GridCacheUtils.primary(Iterable<? extends GridNode> nodes) |
GridNode |
GridCacheAffinityManager.primary(K key,
long topVer) |
static GridNode |
GridCacheUtils.primaryNode(GridCacheContext ctx,
Object key)
Gets primary node on which given key is cached.
|
| Modifier and Type | Method and Description |
|---|---|
static Collection<GridNode> |
GridCacheUtils.affinityNodes(GridCacheContext ctx)
Gets all nodes on which cache with the same name is started and the local DHT storage is enabled.
|
static Collection<GridNode> |
GridCacheUtils.affinityNodes(GridCacheContext ctx,
long topOrder)
Gets DHT affinity nodes.
|
static Collection<GridNode> |
GridCacheUtils.aliveNodes(GridCacheContext ctx,
long topOrder)
Gets alive nodes.
|
static Collection<GridNode> |
GridCacheUtils.aliveRemoteNodes(GridCacheContext ctx,
long topOrder)
Gets alive nodes.
|
static Collection<GridNode> |
GridCacheUtils.allNodes(GridCacheContext ctx)
Gets all nodes on which cache with the same name is started.
|
static Collection<GridNode> |
GridCacheUtils.allNodes(GridCacheContext ctx,
long topOrder)
Gets all nodes on which cache with the same name is started.
|
List<List<GridNode>> |
GridCacheAffinityManager.assignments(long topVer) |
static Collection<GridNode> |
GridCacheUtils.backups(Collection<GridNode> nodes) |
Collection<GridNode> |
GridCacheAffinityManager.backups(int part,
long topVer) |
Collection<GridNode> |
GridCacheAffinityManager.backups(K key,
long topVer) |
List<List<GridNode>> |
GridCacheAffinityManager.calculateAffinity(long topVer,
GridDiscoveryEvent discoEvt)
Calculates affinity cache for given topology version.
|
static <K> Map<GridNode,Collection<K>> |
GridCacheUtils.mapKeysToNodes(GridCacheContext<K,?> ctx,
Collection<? extends K> keys) |
static Comparator<GridNode> |
GridCacheUtils.nodeComparator(boolean asc) |
Collection<? extends GridNode> |
GridCacheFuture.nodes() |
Collection<GridNode> |
GridCacheAffinityManager.nodes(int part,
long topVer) |
Collection<GridNode> |
GridCacheAffinityManager.nodes(K key,
long topVer) |
static Collection<GridNode> |
GridCacheUtils.remoteNodes(GridCacheContext ctx)
Gets remote nodes on which cache with the same name is started.
|
static Collection<GridNode> |
GridCacheUtils.remoteNodes(GridCacheContext ctx,
long topOrder)
Gets remote nodes on which cache with the same name is started.
|
Collection<GridNode> |
GridCacheAffinityManager.remoteNodes(Iterable<? extends K> keys,
long topVer) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheEventManager.addPreloadEvent(int part,
int type,
GridNode discoNode,
int discoType,
long discoTs)
Adds preloading event.
|
static boolean |
GridCacheUtils.affinityNode(GridCacheContext ctx,
GridNode s)
Checks if given node has specified cache started and the local DHT storage is enabled.
|
boolean |
GridCacheAffinityManager.belongs(GridNode node,
int part,
long topVer) |
static boolean |
GridCacheUtils.cacheNode(GridCacheContext ctx,
GridNode node)
Checks if given node contains configured cache with the name
as described by given cache context.
|
static boolean |
GridCacheUtils.cacheNode(String cacheName,
GridNode node)
Checks if given node has specified cache started.
|
static void |
GridCacheUtils.checkAttributeMismatch(GridLogger log,
GridCacheConfiguration locCfg,
GridCacheConfiguration rmtCfg,
GridNode rmt,
T2<String,String> attr,
boolean fail)
Checks that local and remove configurations have the same value of given attribute.
|
static void |
GridCacheUtils.checkAttributeMismatch(GridLogger log,
String cfgName,
GridNode rmt,
String attrName,
String attrMsg,
Object locVal,
Object rmtVal,
boolean fail)
Checks that cache configuration attribute has the same value in local and remote cache configurations.
|
boolean |
GridCacheContext.isLocalNode(GridNode n) |
boolean |
GridCacheAffinityManager.primary(GridNode n,
int part,
long topVer) |
boolean |
GridCacheAffinityManager.primary(GridNode n,
K key,
long topVer) |
void |
GridCacheIoManager.send(GridNode node,
GridCacheMessage<K,V> msg)
Sends communication message.
|
void |
GridCacheIoManager.send(GridNode node,
GridCacheMessage<K,V> msg,
GridIoPolicy plc)
Sends communication message.
|
void |
GridCacheIoManager.sendOrderedMessage(GridNode node,
Object topic,
long msgId,
GridCacheMessage<K,V> msg,
long timeout) |
GridNodeValidationResult |
GridCacheProcessor.validateNode(GridNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
static Collection<GridNode> |
GridCacheUtils.backups(Collection<GridNode> nodes) |
boolean |
GridCacheContext.dhtMap(UUID nearNodeId,
long topVer,
GridDhtCacheEntry<K,V> entry,
GridLogger log,
Map<GridNode,List<GridDhtCacheEntry<K,V>>> dhtMap,
Map<GridNode,List<GridDhtCacheEntry<K,V>>> nearMap) |
boolean |
GridCacheContext.dhtMap(UUID nearNodeId,
long topVer,
GridDhtCacheEntry<K,V> entry,
GridLogger log,
Map<GridNode,List<GridDhtCacheEntry<K,V>>> dhtMap,
Map<GridNode,List<GridDhtCacheEntry<K,V>>> nearMap) |
void |
GridCacheAffinityManager.initializeAffinity(long topVer,
List<List<GridNode>> affAssignment)
Initializes affinity for joined node.
|
static GridNode |
GridCacheUtils.localOrPrimary(Iterable<GridNode> nodes,
UUID locId) |
static GridNode |
GridCacheUtils.primary(Iterable<? extends GridNode> nodes) |
boolean |
GridCacheIoManager.safeSend(Collection<? extends GridNode> nodes,
GridCacheMessage<K,V> msg,
GridPredicate<GridNode> fallback)
Sends message and automatically accounts for lefts nodes.
|
boolean |
GridCacheIoManager.safeSend(Collection<? extends GridNode> nodes,
GridCacheMessage<K,V> msg,
GridPredicate<GridNode> fallback)
Sends message and automatically accounts for lefts nodes.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridCacheAffinityProxy.mapKeyToNode(K key)
This method provides ability to detect to which primary node the given key
is mapped.
|
GridNode |
GridCacheAffinityImpl.mapKeyToNode(K key)
This method provides ability to detect to which primary node the given key
is mapped.
|
GridNode |
GridCacheAffinityProxy.mapPartitionToNode(int part)
Gets primary node for the given partition.
|
GridNode |
GridCacheAffinityImpl.mapPartitionToNode(int part)
Gets primary node for the given partition.
|
| Modifier and Type | Method and Description |
|---|---|
Map<GridNode,Collection<K>> |
GridCacheAffinityProxy.mapKeysToNodes(Collection<? extends K> keys)
This method provides ability to detect which keys are mapped to which nodes.
|
Map<GridNode,Collection<K>> |
GridCacheAffinityImpl.mapKeysToNodes(Collection<? extends K> keys)
This method provides ability to detect which keys are mapped to which nodes.
|
Collection<GridNode> |
GridCacheAffinityProxy.mapKeyToPrimaryAndBackups(K key)
Gets primary and backup nodes for the key.
|
Collection<GridNode> |
GridCacheAffinityImpl.mapKeyToPrimaryAndBackups(K key)
Gets primary and backup nodes for the key.
|
Map<Integer,GridNode> |
GridCacheAffinityProxy.mapPartitionsToNodes(Collection<Integer> parts)
Gets primary nodes for the given partitions.
|
Map<Integer,GridNode> |
GridCacheAffinityImpl.mapPartitionsToNodes(Collection<Integer> parts)
Gets primary nodes for the given partitions.
|
Collection<GridNode> |
GridCacheAffinityProxy.mapPartitionToPrimaryAndBackups(int part)
Gets primary and backup nodes for partition.
|
Collection<GridNode> |
GridCacheAffinityImpl.mapPartitionToPrimaryAndBackups(int part)
Gets primary and backup nodes for partition.
|
| Modifier and Type | Method and Description |
|---|---|
int[] |
GridCacheAffinityProxy.allPartitions(GridNode n)
Gets partition ids for which nodes of the given projection has ownership
(either primary or backup).
|
int[] |
GridCacheAffinityImpl.allPartitions(GridNode n)
Gets partition ids for which nodes of the given projection has ownership
(either primary or backup).
|
int[] |
GridCacheAffinityProxy.backupPartitions(GridNode n)
Gets partition ids for which nodes of the given projection has backup
ownership.
|
int[] |
GridCacheAffinityImpl.backupPartitions(GridNode n)
Gets partition ids for which nodes of the given projection has backup
ownership.
|
boolean |
GridCacheAffinityProxy.isBackup(GridNode n,
K key)
Returns
true if local node is one of the backup nodes for given key. |
boolean |
GridCacheAffinityImpl.isBackup(GridNode n,
K key)
Returns
true if local node is one of the backup nodes for given key. |
boolean |
GridCacheAffinityProxy.isPrimary(GridNode n,
K key)
Returns
true if given node is the primary node for given key. |
boolean |
GridCacheAffinityImpl.isPrimary(GridNode n,
K key)
Returns
true if given node is the primary node for given key. |
boolean |
GridCacheAffinityProxy.isPrimaryOrBackup(GridNode n,
K key)
Returns
true if local node is primary or one of the backup nodes
for given key. |
boolean |
GridCacheAffinityImpl.isPrimaryOrBackup(GridNode n,
K key)
Returns
true if local node is primary or one of the backup nodes
for given key. |
int[] |
GridCacheAffinityProxy.primaryPartitions(GridNode n)
Gets partition ids for which nodes of the given projection has primary
ownership.
|
int[] |
GridCacheAffinityImpl.primaryPartitions(GridNode n)
Gets partition ids for which nodes of the given projection has primary
ownership.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridDistributedTxMapping.node() |
| Modifier and Type | Method and Description |
|---|---|
Collection<? extends GridNode> |
GridCachePessimisticCheckCommittedTxFuture.nodes() |
Collection<? extends GridNode> |
GridCacheOptimisticCheckPreparedTxFuture.nodes() |
| Constructor and Description |
|---|
GridDistributedTxMapping(GridNode node) |
| Modifier and Type | Method and Description |
|---|---|
List<List<GridNode>> |
GridDhtAffinityAssignmentResponse.affinityAssignment() |
List<GridNode> |
GridDhtPartitionTopology.moving(int p) |
Collection<? extends GridNode> |
GridDhtTxPrepareFuture.nodes() |
Collection<? extends GridNode> |
GridPartitionedGetFuture.nodes() |
Collection<? extends GridNode> |
GridDhtLockFuture.nodes() |
Collection<? extends GridNode> |
GridDhtTxFinishFuture.nodes() |
Collection<GridNode> |
GridDhtPartitionTopology.nodes(int p,
long topVer) |
List<GridNode> |
GridDhtPartitionTopology.owners(int p) |
List<GridNode> |
GridDhtPartitionTopology.owners(int p,
long topVer) |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<GridNearLockResponse<K,V>> |
GridDhtTransactionalCacheAdapter.lockAllAsync(GridNode nearNode,
GridNearLockRequest<K,V> req,
GridPredicate<GridCacheEntry<K,V>>[] filter0) |
void |
GridDhtAssignmentFetchFuture.onResponse(GridNode node,
GridDhtAffinityAssignmentResponse<K,V> res) |
GridFuture<GridCacheTxEx<K,V>> |
GridDhtTransactionalCacheAdapter.prepareTx(GridNode nearNode,
GridNearTxPrepareRequest<K,V> req) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtTxMapping.addMapping(Collection<GridNode> nodes)
Adds information about next mapping.
|
boolean |
GridDhtAssignmentFetchFuture.onDone(List<List<GridNode>> res,
Throwable err)
Callback to notify that future is finished.
|
| Constructor and Description |
|---|
GridDhtAffinityAssignmentResponse(long topVer,
List<List<GridNode>> affAssignment) |
GridDhtAssignmentFetchFuture(GridCacheContext<K,V> ctx,
long topVer,
Collection<GridNode> availableNodes) |
| Modifier and Type | Method and Description |
|---|---|
Collection<? extends GridNode> |
GridNearAtomicUpdateFuture.nodes() |
Collection<? extends GridNode> |
GridDhtAtomicUpdateFuture.nodes() |
| Modifier and Type | Method and Description |
|---|---|
Collection<? extends GridNode> |
GridDhtColocatedTxPrepareFuture.nodes() |
Collection<? extends GridNode> |
GridDhtColocatedTxFinishFuture.nodes() |
Collection<? extends GridNode> |
GridDhtColocatedLockFuture.nodes() |
| Modifier and Type | Method and Description |
|---|---|
List<List<GridNode>> |
GridDhtPartitionsFullMessage.affinityAssignment() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPartitionsFullMessage.affinityAssignment(List<List<GridNode>> affAssignment) |
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridNearLockMapping.node() |
| Modifier and Type | Method and Description |
|---|---|
Collection<? extends GridNode> |
GridNearTxFinishFuture.nodes() |
Collection<? extends GridNode> |
GridNearLockFuture.nodes() |
Collection<? extends GridNode> |
GridNearTxPrepareFuture.nodes() |
Collection<? extends GridNode> |
GridNearGetFuture.nodes() |
| Constructor and Description |
|---|
GridNearLockMapping(GridNode node,
K firstKey)
Creates near lock mapping for specified node and key.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<? extends GridNode> |
GridLocalLockFuture.nodes() |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
GridCacheQueryManager.loadPage(long id,
GridCacheQueryAdapter<?> qry,
Collection<GridNode> nodes,
boolean all)
Loads page.
|
void |
GridCacheDistributedQueryManager.loadPage(long id,
GridCacheQueryAdapter<?> qry,
Collection<GridNode> nodes,
boolean all)
Loads page.
|
void |
GridCacheLocalQueryManager.loadPage(long id,
GridCacheQueryAdapter<?> qry,
Collection<GridNode> nodes,
boolean all)
Loads page.
|
abstract GridCacheQueryFuture<?> |
GridCacheQueryManager.queryDistributed(GridCacheQueryBean qry,
Collection<GridNode> nodes)
Executes distributed query.
|
GridCacheQueryFuture<?> |
GridCacheDistributedQueryManager.queryDistributed(GridCacheQueryBean qry,
Collection<GridNode> nodes)
Executes distributed query.
|
GridCacheQueryFuture<?> |
GridCacheLocalQueryManager.queryDistributed(GridCacheQueryBean qry,
Collection<GridNode> nodes)
Executes distributed query.
|
abstract GridCacheQueryFuture<?> |
GridCacheQueryManager.queryFieldsDistributed(GridCacheQueryBean qry,
Collection<GridNode> nodes)
Executes distributed fields query.
|
GridCacheQueryFuture<?> |
GridCacheDistributedQueryManager.queryFieldsDistributed(GridCacheQueryBean qry,
Collection<GridNode> nodes)
Executes distributed fields query.
|
GridCacheQueryFuture<?> |
GridCacheLocalQueryManager.queryFieldsDistributed(GridCacheQueryBean qry,
Collection<GridNode> nodes)
Executes distributed fields query.
|
| Constructor and Description |
|---|
GridCacheDistributedFieldsQueryFuture(GridCacheContext<?,?> ctx,
long reqId,
GridCacheQueryBean qry,
Iterable<GridNode> nodes) |
GridCacheDistributedQueryFuture(GridCacheContext<K,V> ctx,
long reqId,
GridCacheQueryBean qry,
Iterable<GridNode> nodes) |
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
GridCacheQueryJdbcTask.map(List<GridNode> subgrid,
byte[] arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridCacheQueryJdbcMetadataTask.map(List<GridNode> subgrid,
String cacheName)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
GridCacheQueryJdbcTask.map(List<GridNode> subgrid,
byte[] arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridCacheQueryJdbcMetadataTask.map(List<GridNode> subgrid,
String cacheName)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
<R> GridFuture<R> |
GridClosureProcessor.affinityCall(String cacheName,
Object affKey,
Callable<R> job,
Collection<GridNode> nodes) |
GridFuture<?> |
GridClosureProcessor.affinityRun(String cacheName,
Object affKey,
Runnable job,
Collection<GridNode> nodes) |
<T,R> GridFuture<Collection<R>> |
GridClosureProcessor.broadcast(GridClosure<T,R> job,
T arg,
Collection<GridNode> nodes) |
<T,R> GridFuture<Collection<R>> |
GridClosureProcessor.callAsync(GridClosure<T,R> job,
Collection<? extends T> args,
Collection<GridNode> nodes) |
<T,R> GridFuture<R> |
GridClosureProcessor.callAsync(GridClosure<T,R> job,
T arg,
Collection<GridNode> nodes) |
<T,R1,R2> GridFuture<R2> |
GridClosureProcessor.callAsync(GridClosure<T,R1> job,
Collection<? extends T> args,
GridReducer<R1,R2> rdc,
Collection<GridNode> nodes) |
<R> GridFuture<R> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
Callable<R> job,
Collection<GridNode> nodes) |
<R> GridFuture<R> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
Callable<R> job,
Collection<GridNode> nodes,
boolean sys) |
<R> GridFuture<Collection<R>> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
Collection<? extends Callable<R>> jobs,
Collection<GridNode> nodes) |
<R> GridFuture<Collection<R>> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
Collection<? extends Callable<R>> jobs,
Collection<GridNode> nodes,
boolean sys) |
<R> GridFuture<R> |
GridClosureProcessor.callAsyncNoFailover(GridClosureCallMode mode,
Callable<R> job,
Collection<GridNode> nodes,
boolean sys) |
<R> GridFuture<Collection<R>> |
GridClosureProcessor.callAsyncNoFailover(GridClosureCallMode mode,
Collection<? extends Callable<R>> jobs,
Collection<GridNode> nodes,
boolean sys) |
<R1,R2> GridFuture<R2> |
GridClosureProcessor.forkjoinAsync(GridClosureCallMode mode,
Collection<? extends Callable<R1>> jobs,
GridReducer<R1,R2> rdc,
Collection<GridNode> nodes) |
GridFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Collection<? extends Runnable> jobs,
Collection<GridNode> nodes) |
GridFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Collection<? extends Runnable> jobs,
Collection<GridNode> nodes,
boolean sys) |
GridFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Runnable job,
Collection<GridNode> nodes) |
GridFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Runnable job,
Collection<GridNode> nodes,
boolean sys) |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<UUID> |
GridContinuousProcessor.startRoutine(GridContinuousHandler hnd,
int bufSize,
long interval,
boolean autoUnsubscribe,
GridPredicate<GridNode> prjPred) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridJobProcessor.processJobExecuteRequest(GridNode node,
GridJobExecuteRequest req) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridStreamerContextDelegate.broadcast(GridInClosure<GridStreamerContext> clo,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
void |
GridStreamerContextImpl.broadcast(GridInClosure<GridStreamerContext> clo,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
<R> Collection<R> |
GridStreamerContextDelegate.query(GridClosure<GridStreamerContext,R> clo,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
<R> Collection<R> |
GridStreamerContextImpl.query(GridClosure<GridStreamerContext,R> clo,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
<R1,R2> R2 |
GridStreamerContextDelegate.reduce(GridClosure<GridStreamerContext,R1> clo,
GridReducer<R1,R2> rdc,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
<R1,R2> R2 |
GridStreamerContextImpl.reduce(GridClosure<GridStreamerContext,R1> clo,
GridReducer<R1,R2> rdc,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
GridStreamerReduceTask.map(List<GridNode> subgrid,
Void arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridStreamerBroadcastTask.map(List<GridNode> subgrid,
Void arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridStreamerQueryTask.map(List<GridNode> subgrid,
Void arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
GridStreamerReduceTask.map(List<GridNode> subgrid,
Void arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridStreamerBroadcastTask.map(List<GridNode> subgrid,
Void arg)
This method is called to map or split grid task into multiple grid jobs.
|
Map<? extends GridComputeJob,GridNode> |
GridStreamerQueryTask.map(List<GridNode> subgrid,
Void arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridVersionProcessor.onNodeJoined(GridNode node)
Handles node joined event.
|
void |
GridVersionProcessor.onNodeLeft(GridNode node)
Handles node left event.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridVersionProcessor.onStart(Collection<GridNode> remoteNodes)
Handles node start.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridOsVersionProcessor.onNodeJoined(GridNode node)
Handles node joined event.
|
void |
GridOsVersionProcessor.onNodeLeft(GridNode node)
Handles node left event.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridOsVersionProcessor.onStart(Collection<GridNode> remoteNodes)
Handles node start.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
VisorMultiNodeTask.map(List<GridNode> subgrid,
GridBiTuple<Set<UUID>,A> arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
Map<? extends GridComputeJob,GridNode> |
VisorMultiNodeTask.map(List<GridNode> subgrid,
GridBiTuple<Set<UUID>,A> arg)
This method is called to map or split grid task into multiple grid jobs.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridSpiContext.localNode()
Gets local grid node.
|
GridNode |
GridSpiContext.node(UUID nodeId)
Gets a node instance based on its ID.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridNode> |
GridSpiContext.nodes()
Gets a collection of all grid nodes.
|
Collection<GridNode> |
GridSpiContext.remoteNodes()
Gets a collection of remote grid nodes.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridSpiAdapter.checkConfigurationConsistency0(GridSpiContext spiCtx,
GridNode node,
boolean starting)
Method which is called in the end of checkConfigurationConsistency() method.
|
void |
GridSpiContext.send(GridNode node,
Serializable msg,
String topic)
Sends a message to a remote node.
|
GridNodeValidationResult |
GridSpiContext.validateNode(GridNode node)
Validates that new node can join grid topology, this method is called on coordinator
node before new node joins topology.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCommunicationSpi.sendMessage(GridNode destNode,
T msg)
Sends given message to destination node.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridTcpCommunicationSpi.checkConfigurationConsistency0(GridSpiContext spiCtx,
GridNode node,
boolean starting)
Method which is called in the end of checkConfigurationConsistency() method.
|
protected GridCommunicationClient |
GridTcpCommunicationSpi.createNioClient(GridNode node) |
protected GridCommunicationClient |
GridTcpCommunicationSpi.createShmemClient(GridNode node,
Integer port) |
protected GridCommunicationClient |
GridTcpCommunicationSpi.createTcpClient(GridNode node)
Establish TCP connection to remote node and returns client.
|
void |
GridTcpCommunicationSpi.sendMessage(GridNode node,
GridTcpCommunicationMessageAdapter msg)
Sends given message to destination node.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridDiscoverySpi.getLocalNode()
Gets local node.
|
GridNode |
GridDiscoverySpi.getNode(UUID nodeId)
Gets node by ID.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridNode> |
GridDiscoverySpi.getRemoteNodes()
Gets collection of remote nodes in grid or empty collection if no remote nodes found.
|
| Modifier and Type | Method and Description |
|---|---|
GridSecurityContext |
GridDiscoverySpiNodeAuthenticator.authenticateNode(GridNode node,
GridSecurityCredentials cred)
Security credentials.
|
void |
GridDiscoverySpiListener.onDiscovery(int type,
long topVer,
GridNode node,
Collection<GridNode> topSnapshot,
Map<Long,Collection<GridNode>> topHist)
Notification for grid node discovery events.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDiscoverySpiListener.onDiscovery(int type,
long topVer,
GridNode node,
Collection<GridNode> topSnapshot,
Map<Long,Collection<GridNode>> topHist)
Notification for grid node discovery events.
|
void |
GridDiscoverySpiListener.onDiscovery(int type,
long topVer,
GridNode node,
Collection<GridNode> topSnapshot,
Map<Long,Collection<GridNode>> topHist)
Notification for grid node discovery events.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridTcpDiscoverySpi.getLocalNode()
Gets local node.
|
GridNode |
GridTcpDiscoverySpi.getNode(UUID nodeId)
Gets node by ID.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridNode> |
GridTcpDiscoverySpi.getRemoteNodes()
Gets collection of remote nodes in grid or empty collection if no remote nodes found.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridTcpDiscoveryNode
Node for
GridTcpDiscoverySpi. |
| Modifier and Type | Method and Description |
|---|---|
Map<Long,Collection<GridNode>> |
GridTcpDiscoveryNodeAddedMessage.topologyHistory()
Gets topology snapshots history.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridTcpDiscoveryNodeAddedMessage.topologyHistory(Map<Long,Collection<GridNode>> topHist)
Sets topology snapshots history.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridFailoverSpi.failover(GridFailoverContext ctx,
List<GridNode> top)
This method is called when method
GridComputeTask.result(GridComputeJobResult, List) returns
value GridComputeJobResultPolicy.FAILOVER policy indicating that the result of
job execution must be failed over. |
GridNode |
GridFailoverContext.getBalancedNode(List<GridNode> top)
Gets the next balanced node for failed job.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridFailoverSpi.failover(GridFailoverContext ctx,
List<GridNode> top)
This method is called when method
GridComputeTask.result(GridComputeJobResult, List) returns
value GridComputeJobResultPolicy.FAILOVER policy indicating that the result of
job execution must be failed over. |
GridNode |
GridFailoverContext.getBalancedNode(List<GridNode> top)
Gets the next balanced node for failed job.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridAlwaysFailoverSpi.failover(GridFailoverContext ctx,
List<GridNode> top)
This method is called when method
GridComputeTask.result(GridComputeJobResult, List) returns
value GridComputeJobResultPolicy.FAILOVER policy indicating that the result of
job execution must be failed over. |
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridAlwaysFailoverSpi.failover(GridFailoverContext ctx,
List<GridNode> top)
This method is called when method
GridComputeTask.result(GridComputeJobResult, List) returns
value GridComputeJobResultPolicy.FAILOVER policy indicating that the result of
job execution must be failed over. |
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridJobStealingFailoverSpi.failover(GridFailoverContext ctx,
List<GridNode> top)
This method is called when method
GridComputeTask.result(GridComputeJobResult, List) returns
value GridComputeJobResultPolicy.FAILOVER policy indicating that the result of
job execution must be failed over. |
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridJobStealingFailoverSpi.failover(GridFailoverContext ctx,
List<GridNode> top)
This method is called when method
GridComputeTask.result(GridComputeJobResult, List) returns
value GridComputeJobResultPolicy.FAILOVER policy indicating that the result of
job execution must be failed over. |
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridNeverFailoverSpi.failover(GridFailoverContext ctx,
List<GridNode> top)
This method is called when method
GridComputeTask.result(GridComputeJobResult, List) returns
value GridComputeJobResultPolicy.FAILOVER policy indicating that the result of
job execution must be failed over. |
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridNeverFailoverSpi.failover(GridFailoverContext ctx,
List<GridNode> top)
This method is called when method
GridComputeTask.result(GridComputeJobResult, List) returns
value GridComputeJobResultPolicy.FAILOVER policy indicating that the result of
job execution must be failed over. |
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridLoadBalancingSpi.getBalancedNode(GridComputeTaskSession ses,
List<GridNode> top,
GridComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridLoadBalancingSpi.getBalancedNode(GridComputeTaskSession ses,
List<GridNode> top,
GridComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridAdaptiveLoadBalancingSpi.getBalancedNode(GridComputeTaskSession ses,
List<GridNode> top,
GridComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
double |
GridAdaptiveCpuLoadProbe.getLoad(GridNode node,
int jobsSentSinceLastUpdate)
Calculates load value for a given node.
|
double |
GridAdaptiveJobCountLoadProbe.getLoad(GridNode node,
int jobsSentSinceLastUpdate)
Calculates load value for a given node.
|
double |
GridAdaptiveLoadProbe.getLoad(GridNode node,
int jobsSentSinceLastUpdate)
Calculates load value for a given node.
|
double |
GridAdaptiveProcessingTimeLoadProbe.getLoad(GridNode node,
int jobsSentSinceLastUpdate)
Calculates load value for a given node.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridAdaptiveLoadBalancingSpi.getBalancedNode(GridComputeTaskSession ses,
List<GridNode> top,
GridComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridRoundRobinLoadBalancingSpi.getBalancedNode(GridComputeTaskSession ses,
List<GridNode> top,
GridComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridRoundRobinLoadBalancingSpi.getBalancedNode(GridComputeTaskSession ses,
List<GridNode> top,
GridComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridWeightedRandomLoadBalancingSpi.getBalancedNode(GridComputeTaskSession ses,
List<GridNode> top,
GridComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridWeightedRandomLoadBalancingSpi.getBalancedNode(GridComputeTaskSession ses,
List<GridNode> top,
GridComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
<T> GridNode |
GridStreamerEventRouter.route(GridStreamerContext ctx,
String stageName,
T evt)
Selects a node for given event that should be processed by a stage with given name.
|
| Modifier and Type | Method and Description |
|---|---|
<T> Map<GridNode,Collection<T>> |
GridStreamerEventRouter.route(GridStreamerContext ctx,
String stageName,
Collection<T> evts)
Selects a node for given events that should be processed by a stage with given name.
|
<T> Map<GridNode,Collection<T>> |
GridStreamerEventRouterAdapter.route(GridStreamerContext ctx,
String stageName,
Collection<T> evts)
Selects a node for given events that should be processed by a stage with given name.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridStreamerContext.broadcast(GridInClosure<GridStreamerContext> clo,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
<R> Collection<R> |
GridStreamerContext.query(GridClosure<GridStreamerContext,R> clo,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
<R1,R2> R2 |
GridStreamerContext.reduce(GridClosure<GridStreamerContext,R1> clo,
GridReducer<R1,R2> rdc,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridStreamerRandomEventRouter.route(GridStreamerContext ctx,
String stageName,
Object evt)
Selects a node for given event that should be processed by a stage with given name.
|
GridNode |
GridStreamerRoundRobinEventRouter.route(GridStreamerContext ctx,
String stageName,
Object evt)
Selects a node for given event that should be processed by a stage with given name.
|
<T> GridNode |
GridStreamerLocalEventRouter.route(GridStreamerContext ctx,
String stageName,
T evt)
Selects a node for given event that should be processed by a stage with given name.
|
<T> GridNode |
GridStreamerAffinityEventRouter.route(GridStreamerContext ctx,
String stageName,
T evt)
Selects a node for given event that should be processed by a stage with given name.
|
<T> GridNode |
GridStreamerCacheAffinityEventRouter.route(GridStreamerContext ctx,
String stageName,
T evt)
Selects a node for given event that should be processed by a stage with given name.
|
| Modifier and Type | Method and Description |
|---|---|
<T> Map<GridNode,Collection<T>> |
GridStreamerLocalEventRouter.route(GridStreamerContext ctx,
String stageName,
Collection<T> evts)
Selects a node for given events that should be processed by a stage with given name.
|
| Constructor and Description |
|---|
GridStreamerRandomEventRouter(Collection<GridPredicate<GridNode>> predicates)
Constructs random event router with optional set of filters to apply to streamer projection.
|
| Modifier and Type | Method and Description |
|---|---|
static GridClosure<UUID,GridNode> |
GridUtils.id2Node(GridKernalContext ctx) |
static Map<String,Collection<GridNode>> |
GridUtils.neighborhood(Iterable<GridNode> nodes)
Groups given nodes by the node's physical computer (host).
|
| Modifier and Type | Method and Description |
|---|---|
static String |
GridUtils.addressesAsString(GridNode node)
Returns string representation of node addresses.
|
static GridCacheAtomicityMode |
GridUtils.atomicityMode(GridNode n,
String cacheName)
Gets cache mode or a cache on given node or
null if cache is not
present on given node. |
static GridCacheAttributes[] |
GridUtils.cacheAttributes(GridNode n)
Gets cache attributes for the node.
|
static GridCacheAttributes |
GridUtils.cacheAttributes(GridNode n,
String cacheName)
Gets cache attributes from the given node for the given cache name.
|
static GridCacheMode |
GridUtils.cacheMode(GridNode n,
String cacheName)
Gets cache mode or a cache on given node or
null if cache is not
present on given node. |
static Collection<String> |
GridUtils.cacheNames(GridNode n)
Gets view on all cache names started on the node.
|
static boolean |
GridUtils.hasCache(GridNode n,
String cacheName)
Checks if given node has specified cache started.
|
static boolean |
GridUtils.hasNearCache(GridNode n,
String cacheName)
Checks if given node has near cache enabled for the specified
partitioned cache.
|
static boolean |
GridUtils.hasStreamer(GridNode n,
String streamerName)
Checks if given node has specified streamer started.
|
static double |
GridUtils.heapSize(GridNode node,
int precision)
Gets heap size in GB rounded to specified precision.
|
static boolean |
GridUtils.isVisorNode(GridNode node)
Checks whether a node is a Visor node.
|
static GridProductVersion |
GridUtils.productVersion(GridNode node)
Gets node product version based on node attributes.
|
static boolean |
GridUtils.sameMacs(GridNode loc,
GridNode rmt) |
static Collection<InetAddress> |
GridUtils.toInetAddresses(GridNode node)
Returns tha list of resolved inet addresses.
|
static String |
GridUtils.toShortString(GridNode n)
Short node representation.
|
static Collection<InetSocketAddress> |
GridUtils.toSocketAddresses(GridNode node,
int port)
Returns tha list of resolved socket addresses.
|
| Modifier and Type | Method and Description |
|---|---|
static double |
GridUtils.heapSize(Iterable<GridNode> nodes,
int precision)
Gets total heap size in GB rounded to specified precision.
|
static Map<String,Collection<GridNode>> |
GridUtils.neighborhood(Iterable<GridNode> nodes)
Groups given nodes by the node's physical computer (host).
|
static Collection<UUID> |
GridUtils.nodeIds(Collection<? extends GridNode> nodes)
Converts collection of nodes to collection of node IDs.
|
static Collection<String> |
GridUtils.nodes2names(Collection<? extends GridNode> nodes)
Converts collection of grid nodes to collection of grid names.
|
static String |
GridUtils.toShortString(Collection<? extends GridNode> ns)
Short node representation.
|
| Modifier and Type | Method and Description |
|---|---|
static <T extends GridNode> |
GridFunc.localNode(UUID locNodeId)
Gets predicate that evaluates to
true only for given local node ID. |
static <T extends GridNode> |
GridFunc.nodeForNodeId(UUID nodeId)
Creates grid node predicate evaluating on the given node ID.
|
static <T extends GridNode> |
GridFunc.nodeForNodeIds(Collection<UUID> nodeIds)
Creates grid node predicate evaluating on the given node IDs.
|
static <T extends GridNode> |
GridFunc.nodeForNodeIds(UUID... nodeIds)
Creates grid node predicate evaluating on the given node IDs.
|
static <T extends GridNode> |
GridFunc.remoteNodes(UUID locNodeId)
Gets predicate that evaluates to
false for given local node ID. |
| Modifier and Type | Method and Description |
|---|---|
static GridPredicate<GridNode> |
GridFunc.cacheNodesForNames(String... cacheNames)
Gets node predicate which returns
true for all nodes which have given cache names
started. |
static GridClosure<GridNode,UUID> |
GridFunc.node2id()
Gets closure which converts node to node ID.
|
static GridClosure<GridNode,String> |
GridFunc.node2id8()
Gets closure which converts node to node ID8 representation (shorter and good enough).
|
static GridPredicate<GridNode> |
GridFunc.nodeForNodes(Collection<? extends GridNode> nodes)
Creates predicates that evaluates to
true for each node in given collection. |
static GridPredicate<GridNode> |
GridFunc.nodeForNodes(GridNode... nodes)
Creates predicates that evaluates to
true for each node in given collection. |
static GridClosure<GridProjection,GridPredicate<GridNode>> |
GridFunc.predicate()
Gets closure that transform a grid projection into its predicate.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridNodePredicate.apply(GridNode n)
Predicate body.
|
static GridPredicate<GridNode> |
GridFunc.nodeForNodes(GridNode... nodes)
Creates predicates that evaluates to
true for each node in given collection. |
| Modifier and Type | Method and Description |
|---|---|
static GridPredicate<GridEvent> |
GridFunc.eventNode(Collection<? extends GridNode> nodes)
Gets event predicate that returns
true only if node that produced the event
is one of the given. |
static <T> Collection<T> |
GridFunc.nodeAttributes(Collection<? extends GridNode> nodes,
String attr)
Convenient utility method that returns collection of node attributes for a given
collection of grid nodes.
|
static GridPredicate<GridNode> |
GridFunc.nodeForNodes(Collection<? extends GridNode> nodes)
Creates predicates that evaluates to
true for each node in given collection. |
static Collection<String> |
GridFunc.nodeId8s(Collection<? extends GridNode> nodes)
Convenient utility method that returns collection of node ID8s for a given
collection of grid nodes.
|
static Collection<UUID> |
GridFunc.nodeIds(Collection<? extends GridNode> nodes)
Convenient utility method that returns collection of node IDs for a given
collection of grid nodes.
|
| Constructor and Description |
|---|
GridNodePredicate(GridNode... nodes)
Creates node predicate that evaluates to
true for all
provided nodes. |
Copyright © 2014. All rights reserved.