You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2017/03/16 12:14:18 UTC
ignite git commit: Added transient index state to message.
Repository: ignite
Updated Branches:
refs/heads/ignite-4565-ddl 4d1f7107e -> 2f5706dee
Added transient index state to message.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/2f5706de
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2f5706de
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2f5706de
Branch: refs/heads/ignite-4565-ddl
Commit: 2f5706deef338c142634f714d643e4be5298e660
Parents: 4d1f710
Author: devozerov <vo...@gridgain.com>
Authored: Thu Mar 16 15:14:09 2017 +0300
Committer: devozerov <vo...@gridgain.com>
Committed: Thu Mar 16 15:14:09 2017 +0300
----------------------------------------------------------------------
.../query/ddl/IndexAbstractDiscoveryMessage.java | 19 +++++++++++++++++++
1 file changed, 19 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/2f5706de/modules/core/src/main/java/org/apache/ignite/internal/processors/query/ddl/IndexAbstractDiscoveryMessage.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/ddl/IndexAbstractDiscoveryMessage.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/ddl/IndexAbstractDiscoveryMessage.java
index 5d26074..c362b91 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/query/ddl/IndexAbstractDiscoveryMessage.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/query/ddl/IndexAbstractDiscoveryMessage.java
@@ -18,9 +18,11 @@
package org.apache.ignite.internal.processors.query.ddl;
import org.apache.ignite.internal.managers.discovery.DiscoveryCustomMessage;
+import org.apache.ignite.internal.processors.query.QueryIndexStates;
import org.apache.ignite.internal.util.tostring.GridToStringInclude;
import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.lang.IgniteUuid;
+import org.jetbrains.annotations.Nullable;
/**
* Abstract discovery message for index operations.
@@ -36,6 +38,9 @@ public abstract class IndexAbstractDiscoveryMessage implements DiscoveryCustomMe
@GridToStringInclude
protected final AbstractIndexOperation op;
+ /** Local cache index state at the moment of message receive. */
+ private transient QueryIndexStates idxStates;
+
/**
* Constructor.
*
@@ -57,6 +62,20 @@ public abstract class IndexAbstractDiscoveryMessage implements DiscoveryCustomMe
return op;
}
+ /**
+ * @return Index states.
+ */
+ @Nullable public QueryIndexStates indexStates() {
+ return idxStates;
+ }
+
+ /**
+ * @param idxStates Index states.
+ */
+ public void indexStates(QueryIndexStates idxStates) {
+ this.idxStates = idxStates;
+ }
+
/** {@inheritDoc} */
@Override public String toString() {
return S.toString(IndexAbstractDiscoveryMessage.class, this);