[FLINK-19357] Introduce createBucketWriter to BucketsBuilder

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.12.0
• Component/s: Runtime / Task
• Labels: pull-request-available
• Assignee: Jingsong Lee
• Reporter: Jingsong Lee
• Created: 22/Sep/20 10:31
• Updated: 30/Oct/20 02:04
• Resolved: 30/Oct/20 02:04

Description

@Internal
public abstract static class BucketsBuilder {
   ...
   
   @Internal
   public abstract BucketWriter<IN, BucketID> createBucketWriter() throws IOException;
}

FLINK-19345 depends on BucketWriter to write compacted file.

Issue Links

• blocks: FLINK-19345 In Table File Sink, introduce streaming sink compaction
• links to: GitHub Pull Request #13697