refactor(connector): remove WriteGuard and fulfill_meta_column from parser

[BugenZhao]

Signed-off-by: Bugen Zhao [email protected]I hereby agree to the terms of the RisingWave Labs, Inc. Contributor License Agreement.

What's changed and what's your intention?

• Since fix(parser): allow insert multiple rows in one record #6541, the WriteGuard does not make any sense in the interface. So we may totally remove this to avoid confusion.
• For each source message, parse then fulfill_meta_column is not that clear for readability. We directly embed the metadata in the RowWriter and wrap f in do_action to handle columns with types other than Normal.

Preparation for #12366. Also some minor refactors on the JSON parser.

Checklist

• I have written necessary rustdoc comments
• I have added necessary unit tests and integration tests
• All checks passed in ./risedev check (or alias, ./risedev c)

Documentation

• My PR needs documentation updates. (Please use the Release note section below to summarize the impact on users)

Release note

If this PR includes changes that directly affect users or other significant modifications relevant to the community, kindly draft a release note to provide a concise summary of these changes. Please prioritize highlighting the impact these changes will have on users.

[codecov]

Codecov Report

Merging #12542 (f9b07af) into main (ea9b94c) will decrease coverage by 0.01%.
Report is 17 commits behind head on main.
The diff coverage is 54.71%.

@@            Coverage Diff             @@
##             main   #12542      +/-   ##
==========================================
- Coverage   69.40%   69.40%   -0.01%     
==========================================
  Files        1429     1429              
  Lines      238724   238709      -15     
==========================================
- Hits       165696   165680      -16     
- Misses      73028    73029       +1     

Flag	Coverage Δ
rust	69.40% <54.71%> (-0.01%)	⬇️

Flags with carried forward coverage won't be shown. Click here to find out more.

Files	Coverage Δ
src/connector/src/lib.rs	81.25% <ø> (ø)
src/connector/src/parser/common.rs	100.00% <100.00%> (ø)
src/connector/src/parser/canal/simd_json_parser.rs	84.74% <50.00%> (ø)
src/connector/src/parser/csv_parser.rs	87.09% <66.66%> (ø)
...connector/src/parser/debezium/mongo_json_parser.rs	81.10% <50.00%> (ø)
src/connector/src/parser/maxwell/maxwell_parser.rs	55.81% <50.00%> (ø)
src/connector/src/parser/plain_parser.rs	56.41% <50.00%> (ø)
src/connector/src/parser/unified/json.rs	63.70% <75.00%> (ø)
src/connector/src/parser/unified/util.rs	70.11% <83.33%> (ø)
src/connector/src/parser/upsert_parser.rs	67.46% <50.00%> (ø)
... and 4 more

... and 5 files with indirect coverage changes

📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more

[StrikeW]

The input parameter is also named f, I am confused which is which. You may rename the input f to column_func or something.

[BugenZhao]

Renamed wrapped f with f_with_meta.

[StrikeW]

Rest lgtm!