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)