XiaoYou201 opened a new pull request, #10231:
URL: https://github.com/apache/inlong/pull/10231
### Prepare a Pull Request
- [INLONG-10195][Sort] Hudi connector support audit ID
- Fixes #10195
- Parent issue: https://github.com/apache/inlong/issues/8803
### Motivation
Hudi connector not support audit function. So this pr will make it support
audit function.
### Modifications
Modify MongoDB connector sink.when sinkreceive data, it will send audit
information at same time.Some implement are as follows:
Program will get the audit information from the incoming sql statement and
pass it to the StreamWriteFunction class. During StreamWrite , the program will
report the number of data received.
--
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]
