The function execution time of saveMode is after the sink is created, and the specific call is in . For example, in the execute(List> upstreamDataStreams) method of SinkExecuteProcessor, in the createSinkAction() method in MultipleTableJobConfigParser. Taking jdbcsink as an example, jdbcSink implements the SupportSaveMode interface, implements the method getSaveModeHandler(), and returns a DefaultSaveModeHandler instance. You can view the "Taking jdbcsink as an example" and "Code execution time" section in the design document
Lucifer Tyrant <[email protected]> 于2023年8月29日周二 11:12写道： > Hi xupeng, > > Thank you for your proposal. It looks like an exciting feature. Can > you explain the details for this feature? I can't see any useful > information for this. For example, the whole work process for save > mode? I only see the interface definition in the document. > > Chao Tian > > JUN GAO <[email protected]> 于2023年8月28日周一 20:41写道： > > > > A little suggestion, can you add design document link to the issue > > https://github.com/apache/seatunnel/issues/5390 ? > > > > xuepeng wang <[email protected]> 于2023年8月28日周一 20:23写道： > > > > > Issues Address*https://github.com/apache/seatunnel/issues/5390* > > > <https://github.com/apache/seatunnel/issues/5390> > > > Design document link > > > > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=263427916 > > > > > > > > > -- > > > > Best Regards > > > > ------------ > > > > EricJoy2048 > > [email protected] >
