Added tx participating node IDs to transaction record.
package org.apache.ignite.internal.pagemem.wal.record;
+import java.util.UUID;
import org.apache.ignite.internal.processors.cache.version.GridCacheVersion;
/**
@@ -62,6 +63,9 @@ public class TxRecord extends WALRecord {
/** */
private GridCacheVersion dhtVer;
+ /** */
+ private UUID[] participatingNodeIds;
+
/** {@inheritDoc} */
@Override public RecordType type() {
return RecordType.TX_RECORD;
@@ -108,4 +112,18 @@ public class TxRecord extends WALRecord {
public void action(TxAction action) {
this.action = action;
}
+
+ /**
+ * @param participatingNodeIds Participating node IDs.
+ */
+ public void participatingNodeIds(UUID[] participatingNodeIds) {
+ this.participatingNodeIds = participatingNodeIds;
+ }
+
+ /**
+ * @return Participating node IDs.
+ */
+ public UUID[] participatingNodeId() {
+ return participatingNodeIds;
+ }
}
