`df.sinks.register("my_sink", MySink)` 插件接口,讨论见 discussion #8。
df.sinks.register("my_sink", MySink)插件接口,讨论见 discussion #8。