[flink] 01/03: [FLINK-14869][core] Introduce Resource#isZero

[xt...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

xtsong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit f1d0799e93f587829aefbaee57a25941a4fb5802
Author: Xintong Song <to...@gmail.com>
AuthorDate: Thu Feb 18 13:18:58 2021 +0800

    [FLINK-14869][core] Introduce Resource#isZero
---
 .../java/org/apache/flink/api/common/resources/Resource.java     | 4 ++++
 .../java/org/apache/flink/api/common/resources/ResourceTest.java | 9 +++++++++
 2 files changed, 13 insertions(+)

diff --git a/flink-core/src/main/java/org/apache/flink/api/common/resources/Resource.java b/flink-core/src/main/java/org/apache/flink/api/common/resources/Resource.java
index 7333ac9..920434f 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/resources/Resource.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/resources/Resource.java
@@ -119,6 +119,10 @@ public abstract class Resource implements Serializable {
         return value;
     }
 
+    public boolean isZero() {
+        return value.compareTo(BigDecimal.ZERO) == 0;
+    }
+
     /**
      * Create a new instance of the sub resource.
      *
diff --git a/flink-core/src/test/java/org/apache/flink/api/common/resources/ResourceTest.java b/flink-core/src/test/java/org/apache/flink/api/common/resources/ResourceTest.java
index ec27e91..1e67fe9 100644
--- a/flink-core/src/test/java/org/apache/flink/api/common/resources/ResourceTest.java
+++ b/flink-core/src/test/java/org/apache/flink/api/common/resources/ResourceTest.java
@@ -152,6 +152,15 @@ public class ResourceTest extends TestLogger {
         resource.multiply(by);
     }
 
+    @Test
+    public void testIsZero() {
+        final Resource resource1 = new TestResource(0.0);
+        final Resource resource2 = new TestResource(1.0);
+
+        assertTrue(resource1.isZero());
+        assertFalse(resource2.isZero());
+    }
+
     private static void assertTestResourceValueEquals(final double value, final Resource resource) {
         assertEquals(new TestResource(value), resource);
     }