You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2019/01/15 09:17:44 UTC
[flink] 03/03: [hotfix] [fs] Add clock as an argument in Javadocs
This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit e7b02b42364563dfa20c8189da50d1a0a7529f4a
Author: Fokko Driesprong <fo...@apache.org>
AuthorDate: Mon Jan 14 14:54:32 2019 +0100
[hotfix] [fs] Add clock as an argument in Javadocs
The clock parameter is missing in the docstring.
This closes #7484.
---
.../org/apache/flink/streaming/connectors/fs/bucketing/Bucketer.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/Bucketer.java b/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/Bucketer.java
index f2eebf3..e712b2e 100644
--- a/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/Bucketer.java
+++ b/flink-connectors/flink-connector-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.
*