ggjh-159 commented on issue #12459: URL: https://github.com/apache/gluten/issues/12459#issuecomment-4990845938
> Thanks for the detailed design. and I have some questions: > > * 1. The flink rowdata convert to velox's `ChangelogRowVector`, does this means that：the input rowdata is generated by flink operators (like source), and then convert to velox data structure? as we have implemented some native operators(kafka/pulsar source) in velox side, should we use these to process the data directly without these convertions? > * 2. `ChangeRowVector` is a new data structure, can we use `StatefulRecord` that has been introduced in `Velox` by adding a new field `RowKind` instead of using this new one? A new column `rowKind_` has been added to StreamRecord to replace ChangelogRowVector. For details, please refer to pr bigo-sg/velox#70. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
