From 32144d46fcb7580156e544114ee56925adef331f Mon Sep 17 00:00:00 2001 From: Fokko Driesprong Date: Mon, 14 Jan 2019 14:54:32 +0100 Subject: [PATCH] [hotfix][docs] Add clock as an argument The clock is missing in the docstring. --- .../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 f2eebf377efcb..e712b2e69b956 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 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. *