GIRAPH-1215
authorMaja Kabiljo <majakabiljo@fb.com>
Wed, 5 Dec 2018 17:54:55 +0000 (09:54 -0800)
committerMaja Kabiljo <majakabiljo@fb.com>
Thu, 6 Dec 2018 01:18:20 +0000 (17:18 -0800)
closes #97

giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntByteMinHeap.java
giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntDoubleMinHeap.java
giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntFloatMinHeap.java
giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntIntMinHeap.java
giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityIntLongMinHeap.java
giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongByteMinHeap.java
giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongDoubleMinHeap.java
giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongFloatMinHeap.java
giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongIntMinHeap.java
giraph-core/src/main/java/org/apache/giraph/types/heaps/FixedCapacityLongLongMinHeap.java
giraph-core/templates/FixedCapacityType2TypeMinHeap.java

index d3dd1e0..a71472a 100644 (file)
@@ -81,7 +81,8 @@ public class FixedCapacityIntByteMinHeap
    * @param value Value
    */
   public void add(int key, byte value) {
-    if (size == capacity && compare(keys[0], values[0], key, value) >= 0) {
+    if (capacity == 0 ||
+        (size == capacity && compare(keys[0], values[0], key, value) >= 0)) {
       // If the heap is full and smallest element in it is not smaller
       // than value, do nothing
       return;
index aef4509..85debf8 100644 (file)
@@ -81,7 +81,8 @@ public class FixedCapacityIntDoubleMinHeap
    * @param value Value
    */
   public void add(int key, double value) {
-    if (size == capacity && compare(keys[0], values[0], key, value) >= 0) {
+    if (capacity == 0 ||
+        (size == capacity && compare(keys[0], values[0], key, value) >= 0)) {
       // If the heap is full and smallest element in it is not smaller
       // than value, do nothing
       return;
index a9c2f37..4f88844 100644 (file)
@@ -81,7 +81,8 @@ public class FixedCapacityIntFloatMinHeap
    * @param value Value
    */
   public void add(int key, float value) {
-    if (size == capacity && compare(keys[0], values[0], key, value) >= 0) {
+    if (capacity == 0 ||
+        (size == capacity && compare(keys[0], values[0], key, value) >= 0)) {
       // If the heap is full and smallest element in it is not smaller
       // than value, do nothing
       return;
index 3cb15e1..4f76739 100644 (file)
@@ -81,7 +81,8 @@ public class FixedCapacityIntIntMinHeap
    * @param value Value
    */
   public void add(int key, int value) {
-    if (size == capacity && compare(keys[0], values[0], key, value) >= 0) {
+    if (capacity == 0 ||
+        (size == capacity && compare(keys[0], values[0], key, value) >= 0)) {
       // If the heap is full and smallest element in it is not smaller
       // than value, do nothing
       return;
index 3c8c1f6..ae64070 100644 (file)
@@ -81,7 +81,8 @@ public class FixedCapacityIntLongMinHeap
    * @param value Value
    */
   public void add(int key, long value) {
-    if (size == capacity && compare(keys[0], values[0], key, value) >= 0) {
+    if (capacity == 0 ||
+        (size == capacity && compare(keys[0], values[0], key, value) >= 0)) {
       // If the heap is full and smallest element in it is not smaller
       // than value, do nothing
       return;
index 65fadf4..9859b4d 100644 (file)
@@ -81,7 +81,8 @@ public class FixedCapacityLongByteMinHeap
    * @param value Value
    */
   public void add(long key, byte value) {
-    if (size == capacity && compare(keys[0], values[0], key, value) >= 0) {
+    if (capacity == 0 ||
+        (size == capacity && compare(keys[0], values[0], key, value) >= 0)) {
       // If the heap is full and smallest element in it is not smaller
       // than value, do nothing
       return;
index 4350655..f572ac5 100644 (file)
@@ -81,7 +81,8 @@ public class FixedCapacityLongDoubleMinHeap
    * @param value Value
    */
   public void add(long key, double value) {
-    if (size == capacity && compare(keys[0], values[0], key, value) >= 0) {
+    if (capacity == 0 ||
+        (size == capacity && compare(keys[0], values[0], key, value) >= 0)) {
       // If the heap is full and smallest element in it is not smaller
       // than value, do nothing
       return;
index 1d79015..5fc0d6b 100644 (file)
@@ -81,7 +81,8 @@ public class FixedCapacityLongFloatMinHeap
    * @param value Value
    */
   public void add(long key, float value) {
-    if (size == capacity && compare(keys[0], values[0], key, value) >= 0) {
+    if (capacity == 0 ||
+        (size == capacity && compare(keys[0], values[0], key, value) >= 0)) {
       // If the heap is full and smallest element in it is not smaller
       // than value, do nothing
       return;
index 67b4154..6eb65a2 100644 (file)
@@ -81,7 +81,8 @@ public class FixedCapacityLongIntMinHeap
    * @param value Value
    */
   public void add(long key, int value) {
-    if (size == capacity && compare(keys[0], values[0], key, value) >= 0) {
+    if (capacity == 0 ||
+        (size == capacity && compare(keys[0], values[0], key, value) >= 0)) {
       // If the heap is full and smallest element in it is not smaller
       // than value, do nothing
       return;
index b318d17..b94dda5 100644 (file)
@@ -81,7 +81,8 @@ public class FixedCapacityLongLongMinHeap
    * @param value Value
    */
   public void add(long key, long value) {
-    if (size == capacity && compare(keys[0], values[0], key, value) >= 0) {
+    if (capacity == 0 ||
+        (size == capacity && compare(keys[0], values[0], key, value) >= 0)) {
       // If the heap is full and smallest element in it is not smaller
       // than value, do nothing
       return;
index 5dc37bc..70ad2a2 100644 (file)
@@ -81,7 +81,8 @@ public class FixedCapacity${type1.camel}${type2.camel}MinHeap
    * @param value Value
    */
   public void add(${type1.lower} key, ${type2.lower} value) {
-    if (size == capacity && compare(keys[0], values[0], key, value) >= 0) {
+    if (capacity == 0 ||
+        (size == capacity && compare(keys[0], values[0], key, value) >= 0)) {
       // If the heap is full and smallest element in it is not smaller
       // than value, do nothing
       return;