gong commented on PR #6618: URL: https://github.com/apache/inlong/pull/6618#issuecomment-1327602909
> > how can the connector be applied to the existed connector, can you describe it in the description ? > > It is necessary to create DirtySink through DirtyFactory in the connector, and then call DirtySink's invoke method where dirty data occurs. @yunqingmoswu Maybe, add a tool class like `org.apache.flink.table.factories.FactoryUtil`. It can find sub class of `DirtyFactory` to create `dirtySink` object. -- 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]
