This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 5654e0f4750cd9fbe7cba2bdebd16ea3cb4011d6 Author: Stephan Ewen <se...@apache.org> AuthorDate: Thu Jul 11 17:40:41 2019 +0200 [hotfix][core] Minor cleanups to the ResourceSpec class - Some JavaDoc comments - Make the class final, because several methods are not designed to handle inheritence well. - Avoid repeated string concatenation/building --- .../apache/flink/api/common/operators/ResourceSpec.java | 15 +++++++++++---- 1 file changed, 11 insertions(+), 4 deletions(-) diff --git a/flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java b/flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java index dc6a611..2d56746 100755 --- a/flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java @@ -50,12 +50,19 @@ import static org.apache.flink.util.Preconditions.checkArgument; * </ol> */ @Internal -public class ResourceSpec implements Serializable { +public final class ResourceSpec implements Serializable { private static final long serialVersionUID = 1L; + /** + * A ResourceSpec that indicates an unknown set of resources. + */ public static final ResourceSpec UNKNOWN = new ResourceSpec(); + /** + * The default ResourceSpec used for operators and transformation functions. + * Currently equal to {@link #UNKNOWN}. + */ public static final ResourceSpec DEFAULT = UNKNOWN; public static final String GPU_NAME = "GPU"; @@ -91,7 +98,7 @@ public class ResourceSpec implements Serializable { * @param managedMemoryInMB The size of managed memory, in megabytes. * @param extendedResources The extended resources, associated with the resource manager used */ - protected ResourceSpec( + private ResourceSpec( double cpuCores, int heapMemoryInMB, int directMemoryInMB, @@ -273,9 +280,9 @@ public class ResourceSpec implements Serializable { @Override public String toString() { - String extend = ""; + StringBuilder extend = new StringBuilder(); for (Resource resource : extendedResources.values()) { - extend += ", " + resource.getName() + "=" + resource.getValue(); + extend.append(", ").append(resource.getName()).append("=").append(resource.getValue()); } return "ResourceSpec{" + "cpuCores=" + cpuCores +