Griffin 中的spark、connector使用问题

[大鹏]

1、Griffin 中的spark组件作用具体是什么？是不是Griffin服务根据rule中定义的条件，组装一个spark sql去spark里执行数据统计呢？
2、自己如何扩展一个connector和sink，需要注意什么？