flink cdc 3.0 schema变更问题

[zapjone]

大佬们好：
    想请假下，在flink 
cdc3.0中支持schema变更，但看到是pipeline方式的，因业务问题需要使用datastream进行特殊处理，所以想请假下，在flink cdc 
3.0中datastream api中怎么使用schema变更呢？或者相关文档呢？