如何扩展flink sql以支持CTAS/CDAS语句？

[casel.chen]

flink sql社区版貌似还不支持CTAS/CDAS语句，请问要如何扩展flink sql以支持CTAS/CDAS语句？可以给个思路或代码示例吗？谢谢！