[hotfix] [fs] Add clock as an argument in Javadocs

The clock parameter is missing in the docstring. This closes apache#7484.
mbalassi · Jan 15, 2019 · e7b02b4 · e7b02b4
1 parent baea9a3
commit e7b02b4
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/Bucketer.java b/...filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/Bucketer.java
@@ -38,6 +38,7 @@ public interface Bucketer<T> extends Serializable {
  /**
  * Returns the {@link Path} of a bucket file.
  *
+ * @param clock The current system time in milliseconds.
  * @param basePath The base path containing all the buckets.
  * @param element The current element being processed.
  *