[FLINK-12539] [fs-connector] Make StreamingFileSink customizable (apa…

…che#8469)
Pance · May 22, 2019 · 7748729 · 7748729
1 parent f652bb5
commit 7748729
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java b/...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 static <IN> StreamingFileSink.BulkFormatBuilder<IN, String> forBulkFormat
  /**
  * 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;