>From Wail Alkowaileet <[email protected]>:
Wail Alkowaileet has uploaded this change for review. (
https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/17931 )
Change subject: [NO ISSUE][OTH] Add I/O related helper methods
......................................................................
[NO ISSUE][OTH] Add I/O related helper methods
- user model changes: no
- storage format changes: no
- interface changes: no
Details:
Add I/O related helper methods
Change-Id: I15167705e1fad0a5331ecc736d6867eff845f417
---
M
asterixdb/asterix-common/src/main/java/org/apache/asterix/common/replication/AllDatasetsReplicationStrategy.java
M
asterixdb/asterix-common/src/main/java/org/apache/asterix/common/storage/StorageIOStats.java
2 files changed, 21 insertions(+), 0 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/31/17931/1
diff --git
a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/replication/AllDatasetsReplicationStrategy.java
b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/replication/AllDatasetsReplicationStrategy.java
index c969777..84f0a39 100644
---
a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/replication/AllDatasetsReplicationStrategy.java
+++
b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/replication/AllDatasetsReplicationStrategy.java
@@ -19,6 +19,7 @@
package org.apache.asterix.common.replication;
public class AllDatasetsReplicationStrategy implements IReplicationStrategy {
+ public static final IReplicationStrategy INSTANCE = new
AllDatasetsReplicationStrategy();
@Override
public boolean isMatch(int datasetId) {
diff --git
a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/storage/StorageIOStats.java
b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/storage/StorageIOStats.java
index da4578f..b58f63d 100644
---
a/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/storage/StorageIOStats.java
+++
b/asterixdb/asterix-common/src/main/java/org/apache/asterix/common/storage/StorageIOStats.java
@@ -47,4 +47,8 @@
public int getPendingReplications() {
return pendingReplications;
}
+
+ public int getTotalPendingOperations() {
+ return pendingFlushes + pendingMerges + pendingReplications;
+ }
}
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/17931
To unsubscribe, or for help writing mail filters, visit
https://asterix-gerrit.ics.uci.edu/settings
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Change-Id: I15167705e1fad0a5331ecc736d6867eff845f417
Gerrit-Change-Number: 17931
Gerrit-PatchSet: 1
Gerrit-Owner: Wail Alkowaileet <[email protected]>
Gerrit-MessageType: newchange
