org.apache.ignite.internal.processors.query.schema.message

Class SchemaAbstractDiscoveryMessage

java.lang.Object

org.apache.ignite.internal.processors.query.schema.message.SchemaAbstractDiscoveryMessage

All Implemented Interfaces:

Serializable, DiscoveryCustomMessage

Direct Known Subclasses:

SchemaFinishDiscoveryMessage, SchemaProposeDiscoveryMessage

public abstract class SchemaAbstractDiscoveryMessage
extends Object
implements DiscoveryCustomMessage

Abstract discovery message for schema operations.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected SchemaAbstractOperation	op Operation.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SchemaAbstractDiscoveryMessage(SchemaAbstractOperation op) Constructor.

Method Summary

Modifier and Type	Method and Description
DiscoCache	createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache) Creates new discovery cache if message caused topology version change.
abstract boolean	exchange()
IgniteUuid	id()
SchemaAbstractOperation	operation()
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage

ackMessage, isMutable, stopProcess

Field Detail

op

@GridToStringInclude
protected final SchemaAbstractOperation op

Operation.

Constructor Detail

SchemaAbstractDiscoveryMessage

protected SchemaAbstractDiscoveryMessage(SchemaAbstractOperation op)

Constructor.

Parameters:

op - Operation.

Method Detail

id

public IgniteUuid id()

Specified by:

id in interface DiscoveryCustomMessage

Returns:

Unique custom message ID.

createDiscoCache

@Nullable
public DiscoCache createDiscoCache(GridDiscoveryManager mgr,
                                             AffinityTopologyVersion topVer,
                                             DiscoCache discoCache)

Creates new discovery cache if message caused topology version change.

Specified by:

createDiscoCache in interface DiscoveryCustomMessage

Parameters:

mgr - Discovery manager.

topVer - New topology version.

discoCache - Current discovery cache.

Returns:

Reused discovery cache.

operation

public SchemaAbstractOperation operation()

Returns:

Operation.

exchange

public abstract boolean exchange()

Returns:

Whether request must be propagated to exchange thread.

toString

public String toString()

Overrides:

toString in class Object