You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by GitBox <gi...@apache.org> on 2019/01/15 09:19:57 UTC
[flink] Diff for: [GitHub] asfgit closed pull request #7484: [hotfix][docs]
Add clock as an argument
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 f2eebf377ef..e712b2e69b9 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 @@
/**
* 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.
*
With regards,
Apache Git Services