Repository: samza Updated Branches: refs/heads/master 27c9e4c2e -> 1b3b36b6e
SAMZA-956: fix javadoc warns and error when compiling via JDK8 Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/1b3b36b6 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/1b3b36b6 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/1b3b36b6 Branch: refs/heads/master Commit: 1b3b36b6ef7b3d841beec17243943696728b7972 Parents: 27c9e4c Author: Yi Pan (Data Infrastructure) <[email protected]> Authored: Tue Jun 21 14:23:43 2016 -0700 Committer: Yi Pan (Data Infrastructure) <[email protected]> Committed: Tue Jun 21 14:23:43 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/samza/container/disk/DiskQuotaPolicy.java | 3 +++ .../org/apache/samza/container/disk/DiskQuotaPolicyFactory.java | 1 + .../samza/container/disk/WatermarkDiskQuotaPolicyFactory.java | 4 ++-- 3 files changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/1b3b36b6/samza-core/src/main/java/org/apache/samza/container/disk/DiskQuotaPolicy.java ---------------------------------------------------------------------- diff --git a/samza-core/src/main/java/org/apache/samza/container/disk/DiskQuotaPolicy.java b/samza-core/src/main/java/org/apache/samza/container/disk/DiskQuotaPolicy.java index 060f980..4ccb96d 100644 --- a/samza-core/src/main/java/org/apache/samza/container/disk/DiskQuotaPolicy.java +++ b/samza-core/src/main/java/org/apache/samza/container/disk/DiskQuotaPolicy.java @@ -27,6 +27,9 @@ public interface DiskQuotaPolicy { /** * Given the latest percentage of available disk quota, this method returns the work rate that * should be applied to the container as a value in (0.0, 1.0]. + * + * @param availableDiskQuotaPercentage latest percentage of available disk quota + * @return work rate to be applied */ double apply(double availableDiskQuotaPercentage); } http://git-wip-us.apache.org/repos/asf/samza/blob/1b3b36b6/samza-core/src/main/java/org/apache/samza/container/disk/DiskQuotaPolicyFactory.java ---------------------------------------------------------------------- diff --git a/samza-core/src/main/java/org/apache/samza/container/disk/DiskQuotaPolicyFactory.java b/samza-core/src/main/java/org/apache/samza/container/disk/DiskQuotaPolicyFactory.java index 00202a4..e9d8bce 100644 --- a/samza-core/src/main/java/org/apache/samza/container/disk/DiskQuotaPolicyFactory.java +++ b/samza-core/src/main/java/org/apache/samza/container/disk/DiskQuotaPolicyFactory.java @@ -29,6 +29,7 @@ public interface DiskQuotaPolicyFactory { /** * Creates and returns a disk quota policy instance. * @param config configuration that may apply to this factory + * @return the disk quote policy instance created */ DiskQuotaPolicy create(Config config); } http://git-wip-us.apache.org/repos/asf/samza/blob/1b3b36b6/samza-core/src/main/java/org/apache/samza/container/disk/WatermarkDiskQuotaPolicyFactory.java ---------------------------------------------------------------------- diff --git a/samza-core/src/main/java/org/apache/samza/container/disk/WatermarkDiskQuotaPolicyFactory.java b/samza-core/src/main/java/org/apache/samza/container/disk/WatermarkDiskQuotaPolicyFactory.java index 42e2d3b..92b8b83 100644 --- a/samza-core/src/main/java/org/apache/samza/container/disk/WatermarkDiskQuotaPolicyFactory.java +++ b/samza-core/src/main/java/org/apache/samza/container/disk/WatermarkDiskQuotaPolicyFactory.java @@ -30,8 +30,8 @@ import java.util.List; * A factory for producing {@link WatermarkDiskQuotaPolicy} instances. This class is only required * due to Samza's string-only config. In the event that a richer config system is added it would * be possible to construct a {@link WatermarkDiskQuotaPolicy} directly. - * <p> - * <table> + * + * <table summary=""> * <tr><th>Name</th><th>Default</th><th>Description</th></tr> * <tr> * <td>container.disk.quota.policy.count</td>
