You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by bl...@apache.org on 2019/05/22 18:49:19 UTC
[flink] 02/03: [FLINK-12539] [fs-connector] Make StreamingFileSink
customizable (#8469)
This is an automated email from the ASF dual-hosted git repository.
bli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 774872927d12ed6662addb8b601a9140226c8625
Author: Kailash Dayanand <kd...@lyft.com>
AuthorDate: Wed May 22 10:40:27 2019 -0700
[FLINK-12539] [fs-connector] Make StreamingFileSink customizable (#8469)
---
.../streaming/api/functions/sink/filesystem/StreamingFileSink.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java
index dc0b1c6..f5b1bf9 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java
@@ -127,7 +127,7 @@ public class StreamingFileSink<IN>
/**
* Creates a new {@code StreamingFileSink} that writes files to the given base directory.
*/
- private StreamingFileSink(
+ protected StreamingFileSink(
final StreamingFileSink.BucketsBuilder<IN, ?> bucketsBuilder,
final long bucketCheckInterval) {
@@ -170,7 +170,7 @@ public class StreamingFileSink<IN>
/**
* The base abstract class for the {@link RowFormatBuilder} and {@link BulkFormatBuilder}.
*/
- private abstract static class BucketsBuilder<IN, BucketID> implements Serializable {
+ protected abstract static class BucketsBuilder<IN, BucketID> implements Serializable {
private static final long serialVersionUID = 1L;