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 Description protected SchemaAbstractOperationopOperation.
-
Constructor Summary
Constructors Modifier Constructor Description protectedSchemaAbstractDiscoveryMessage(SchemaAbstractOperation op)Constructor.
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description @Nullable DiscoCachecreateDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)Creates new discovery cache if message caused topology version change.abstract booleanexchange()IgniteUuidid()SchemaAbstractOperationoperation()StringtoString()-
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:
idin interfaceDiscoveryCustomMessage- Returns:
- Unique custom message ID.
-
createDiscoCache
@Nullable public @Nullable DiscoCache createDiscoCache(GridDiscoveryManager mgr, AffinityTopologyVersion topVer, DiscoCache discoCache)
Creates new discovery cache if message caused topology version change.- Specified by:
createDiscoCachein interfaceDiscoveryCustomMessage- 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.
-
-