[jira] [Created] (FLINK-19357) Introduce createBucketWriter to BucketsBuilder

[Shang Yuanchun (Jira)]

Jingsong Lee created FLINK-19357:
------------------------------------

             Summary: Introduce createBucketWriter to BucketsBuilder
                 Key: FLINK-19357
                 URL: https://issues.apache.org/jira/browse/FLINK-19357
             Project: Flink
          Issue Type: New Feature
          Components: Runtime / Task
            Reporter: Jingsong Lee
             Fix For: 1.12.0


{code:java}
@Internal
public abstract static class BucketsBuilder {
   ...
   
   @Internal
   public abstract BucketWriter<IN, BucketID> createBucketWriter() throws IOException;
}
{code}
FLINK-19345 depends on {{BucketWriter}} to write compacted file.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)