zhijiang created FLINK-11885: -------------------------------- Summary: Introduce RecordWriterBuilder for creating RecordWriter instance Key: FLINK-11885 URL: https://issues.apache.org/jira/browse/FLINK-11885 Project: Flink Issue Type: Sub-task Components: Runtime / Network Reporter: zhijiang Assignee: zhijiang
The current {{RecordWriter}} would be refactored as an abstract class for improving broadcast mode mentioned in FLINK-10995. So it is better to migrate the logic of building {{RecordWriter}} instance into a separate {{RecordWriterBuilder}} utility class which should be the only entrance for other usages. -- This message was sent by Atlassian JIRA (v7.6.3#76005)