You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2014/12/05 11:03:17 UTC
[16/32] incubator-ignite git commit: # Renaming
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f54e7bac/modules/core/src/test/java/org/gridgain/loadtests/streamer/GridStreamerIndexLoadTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/gridgain/loadtests/streamer/GridStreamerIndexLoadTest.java b/modules/core/src/test/java/org/gridgain/loadtests/streamer/GridStreamerIndexLoadTest.java
index 7cb368a..0d01c03 100644
--- a/modules/core/src/test/java/org/gridgain/loadtests/streamer/GridStreamerIndexLoadTest.java
+++ b/modules/core/src/test/java/org/gridgain/loadtests/streamer/GridStreamerIndexLoadTest.java
@@ -37,12 +37,13 @@ public class GridStreamerIndexLoadTest {
*/
TREE_INDEX_NOT_UNIQUE {
/** {@inheritDoc} */
- @Override GridStreamerIndexProvider<Integer, Integer, Long> indexProvider() {
- GridStreamerTreeIndexProvider<Integer, Integer, Long> idx = new GridStreamerTreeIndexProvider<>();
+ @Override
+ StreamerIndexProvider<Integer, Integer, Long> indexProvider() {
+ StreamerTreeIndexProvider<Integer, Integer, Long> idx = new StreamerTreeIndexProvider<>();
idx.setUpdater(new IndexUpdater());
idx.setUnique(false);
- idx.setPolicy(GridStreamerIndexPolicy.EVENT_TRACKING_OFF);
+ idx.setPolicy(StreamerIndexPolicy.EVENT_TRACKING_OFF);
return idx;
}
@@ -53,12 +54,13 @@ public class GridStreamerIndexLoadTest {
*/
HASH_INDEX_NOT_UNIQUE {
/** {@inheritDoc} */
- @Override GridStreamerIndexProvider<Integer, Integer, Long> indexProvider() {
- GridStreamerHashIndexProvider<Integer, Integer, Long> idx = new GridStreamerHashIndexProvider<>();
+ @Override
+ StreamerIndexProvider<Integer, Integer, Long> indexProvider() {
+ StreamerHashIndexProvider<Integer, Integer, Long> idx = new StreamerHashIndexProvider<>();
idx.setUpdater(new IndexUpdater());
idx.setUnique(false);
- idx.setPolicy(GridStreamerIndexPolicy.EVENT_TRACKING_OFF);
+ idx.setPolicy(StreamerIndexPolicy.EVENT_TRACKING_OFF);
return idx;
}
@@ -67,7 +69,7 @@ public class GridStreamerIndexLoadTest {
/**
* @return Index provider for this index configuration.
*/
- abstract GridStreamerIndexProvider<Integer, Integer, Long> indexProvider();
+ abstract StreamerIndexProvider<Integer, Integer, Long> indexProvider();
}
/**
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f54e7bac/modules/core/src/test/java/org/gridgain/loadtests/streamer/IndexUpdater.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/gridgain/loadtests/streamer/IndexUpdater.java b/modules/core/src/test/java/org/gridgain/loadtests/streamer/IndexUpdater.java
index f1d9dfd..15927f1 100644
--- a/modules/core/src/test/java/org/gridgain/loadtests/streamer/IndexUpdater.java
+++ b/modules/core/src/test/java/org/gridgain/loadtests/streamer/IndexUpdater.java
@@ -15,19 +15,19 @@ import org.jetbrains.annotations.*;
/**
* Streamer benchmark window index updater.
*/
-class IndexUpdater implements GridStreamerIndexUpdater<Integer, Integer, Long> {
+class IndexUpdater implements StreamerIndexUpdater<Integer, Integer, Long> {
/** {@inheritDoc} */
@Override public Integer indexKey(Integer evt) {
return evt;
}
/** {@inheritDoc} */
- @Nullable @Override public Long onAdded(GridStreamerIndexEntry<Integer, Integer, Long> entry, Integer evt) {
+ @Nullable @Override public Long onAdded(StreamerIndexEntry<Integer, Integer, Long> entry, Integer evt) {
return entry.value() + 1;
}
/** {@inheritDoc} */
- @Nullable @Override public Long onRemoved(GridStreamerIndexEntry<Integer, Integer, Long> entry, Integer evt) {
+ @Nullable @Override public Long onRemoved(StreamerIndexEntry<Integer, Integer, Long> entry, Integer evt) {
return entry.value() - 1 == 0 ? null : entry.value() - 1;
}