Jiangjie Qin created FLINK-18680: ------------------------------------ Summary: Improve RecordsWithSplitIds API Key: FLINK-18680 URL: https://issues.apache.org/jira/browse/FLINK-18680 Project: Flink Issue Type: Sub-task Components: Connectors / Common Affects Versions: 1.11.1 Reporter: Jiangjie Qin
The current API requires some improvements in a few aspects: # The current API enforces the {{SplitReaders}} to expose the records via a java collection which is not performance friendly in some cases. # Some information does not change across the records, but the current RecordsWithSplitIds data structure does not support per-batch information. -- This message was sent by Atlassian Jira (v8.3.4#803005)