Describe the proposal

Data integration lightweight

Task list

• [Feature][Sort] ExtractNode,LoadNode implementation #3777
• [Feature][Sort] FieldInfo enhanced to support transform in the future #3778
• [Feature][Sort] Add Operator interface and derived interface definitions to support transform #3786
• [Feature][Sort] Add Function interface and derived interface definitions to support transform #3787
• [Feature][Sort] Add Node interface and derived interface definitions to support transform #3788
• [Feature][Sort] Add NodeRelationShip definition to support transform #3789
• [Feature][Sort] Add FieldRelationShip definition to support transform #3790
• [Feature][Sort] Add WatermarkField definition to support transform #3791
• [Feature][Sort] Add ConstantParam definition to support transform #3793
• [Feature][Sort] Add TimeUnitConstantParam definition to support transform #3794
• [Feature][Sort] Add GroupInfo,StreamInfo definition to support transform #3800
• [Feature][Sort] Add operators definition to support transform #3805
• [Feature][Sort] Fix meta field sync error #3815
• [Feature][Sort] Fix NPE in RegexpReplaceFirstFunction #3816
• [Feature][Sort] Fix null point exception in canal-json format #3817
• [Feature][Sort] Add node relations definition to support transform #3822
• [Feature][Sort] Fix error caused by unregistered custom function #3823
• [Feature][Sort] Enhance field format to support varchar types and timestamp of different precisions #3826
• [Feature][Sort] Add functions definition to support transform #3827
• [Feature][Sort] Enhanced the node filter capabilities #3828
• [Feature][Sort] Optimize the sort entrance program to support lightweight #3829
• [Feature][Sort] Fix the error that the SQL execution order is inconsistent with the generation order #3830
• [Feature][Sort] Add meta field support for sort lightweight #3831
• [Feature][Sort] Fix hive partition fields format error #3833
• [Feature][Sort] Fix unit test sporadic errors #3834
• [Feature][Sort] Register CascadeFunctionWrapper in the parent interface #3835
• [Feature][Sort] Add join support for transform #3836
• [Feature][Sort] Optimize the time window correlation function format #3837
• [Feature][Sort] Add cascade function support for transform #3839
• [Feature][Sort] Add distinct support based time column for transform #3841
• [Improve][Sort] Add some format for ExtractNode and LoadNode #3860
• [Feature][Sort] Support data from mysql binlog sync to kafka #3868
• [Feature][Sort] Add StringConstantParam to enhance support for constant parameters #3890
• [Feature][Sort] Add string delimiting support for transform #3893
• [Feature][Sort] Add string regexp replace support for transform #3899
• [Feature][Sort] Add MySQL dynamic table implementation - modified from Flink CDC #3953

InLong Component

InLong Sort

Are you willing to submit PR?

• Yes, I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct