Fixes #
In multiple tables example, using StarRocksRowData as input type will introduce much serialize/deserialize cost because it's an interface, and Flink will use KryoSerializer for it. Instead we replace it with DefaultStarRocksRowData, and Flink will use PojoSerializer whose performance is better than KryoSerializer. In my test, the percentage of serialize/deserialize can drop from 53% to 27%.
Problem Summary(Required) ：
Checklist:
[ ] I have added test cases for my bug fix or my new feature
[ ] This pr will affect users' behaviors
[ ] This pr needs user documentation (for new or modified features or behaviors)
[ ] I have added documentation for my new feature or new function
What type of PR is this：
Which issues of this PR fixes ：
Fixes # In multiple tables example, using
StarRocksRowDataas input type will introduce much serialize/deserialize cost because it's an interface, and Flink will useKryoSerializerfor it. Instead we replace it withDefaultStarRocksRowData, and Flink will usePojoSerializerwhose performance is better thanKryoSerializer. In my test, the percentage of serialize/deserialize can drop from 53% to 27%.Problem Summary(Required) ：
Checklist: