setDeadtimePeriod() => setPeriod() (like PeriodicMXBean)
Project: http://git-wip-us.apache.org/repos/asf/incubator-quarks/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-quarks/commit/f018ec56
Tree: http://git-wip-us.apache.org/repos/asf/incubator-quarks/tree/f018ec56
Diff: http://git-wip-us.apache.org/repos/asf/incubator-quarks/diff/f018ec56
Branch: refs/heads/master
Commit: f018ec567caf72770369ffcb0e7ca62768e165fb
Parents: d4a1338
Author: Dale LaBossiere <dl...@us.ibm.com>
Authored: Tue Apr 19 11:52:29 2016 -0400
Committer: Dale LaBossiere <dl...@us.ibm.com>
Committed: Tue Apr 19 11:52:29 2016 -0400
----------------------------------------------------------------------
.../main/java/quarks/analytics/sensors/Deadtime.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-quarks/blob/f018ec56/analytics/sensors/src/main/java/quarks/analytics/sensors/Deadtime.java
----------------------------------------------------------------------
diff --git a/analytics/sensors/src/main/java/quarks/analytics/sensors/Deadtime.java b/analytics/sensors/src/main/java/quarks/analytics/sensors/Deadtime.java
index 6357afb..f79516a 100644
--- a/analytics/sensors/src/main/java/quarks/analytics/sensors/Deadtime.java
+++ b/analytics/sensors/src/main/java/quarks/analytics/sensors/Deadtime.java
@@ -15,7 +15,7 @@ import quarks.function.Predicate;
* Then the next tuple is accepted and a new deadtime period begun.
* </p><p>
* The deadtime period may be changed while the topology is running
- * via {@link #setDeadtimePeriod(long, TimeUnit)}.
+ * via {@link #setPeriod(long, TimeUnit)}.
* </p>
*
* @param <T> tuple type
@@ -34,18 +34,18 @@ public class Deadtime<T> implements Predicate<T> {
* Same as {@code Deadtime(0, TimeUnit.SECONDS)}
*/
public Deadtime() {
- setDeadtimePeriod(0, TimeUnit.SECONDS);
+ setPeriod(0, TimeUnit.SECONDS);
}
/**
* Create a new deadtime Predicate
* <p>
* The first received tuple is always "accepted".
- * @param deadtimePeriod see {@link #setDeadtimePeriod(long, TimeUnit) setDeadtimePeriod()}
+ * @param deadtimePeriod see {@link #setPeriod(long, TimeUnit) setDeadtimePeriod()}
* @param unit {@link TimeUnit} of {@code deadtimePeriod}
*/
public Deadtime(long deadtimePeriod, TimeUnit unit) {
- setDeadtimePeriod(deadtimePeriod, unit);
+ setPeriod(deadtimePeriod, unit);
}
/**
@@ -56,7 +56,7 @@ public class Deadtime<T> implements Predicate<T> {
* </p><p>
* The deadtime period behavior is subject to the accuracy
* of the system's {@link System#currentTimeMillis()}.
- * </p
+ * </p>
* @param deadtimePeriod the amount of to time to reject
* tuples received after the last passed tuple.
* Specify a value of 0 to pass all received tuples.
@@ -64,7 +64,7 @@ public class Deadtime<T> implements Predicate<T> {
* A period of 0 is used if the specified period is less than 1ms.
* @param unit {@link TimeUnit} of {@code deadtimePeriod}
*/
- public synchronized void setDeadtimePeriod(long deadtimePeriod, TimeUnit unit) {
+ public synchronized void setPeriod(long deadtimePeriod, TimeUnit unit) {
if (deadtimePeriod < 0)
throw new IllegalArgumentException("deadtimePeriod");
Objects.requireNonNull(unit, "unit");