          &lt;-&gt; Flow1, Flow2, .... &lt;-&gt; 算是DataElement
 *  -&gt; Connector2(Sink)
 * 数据连接
 */
trait Connector extends AutoCloseable {
  /**
   * 连接名，由用户设置。在整个应用业务生命周期内应保持唯一。
   */
  def name: String

  /**
   * 连接类型。不同的连接类型具有不同的配置选项，数据存取方式
   */
  def `type`: ConnectorType

  def setting: ConnectorSetting

  def configuration: Configuration = setting.parameters
}</code></pre>
<