Elasticsearch6UpsertTableSink 的构造方法过于复杂

[巫旭阳]

public Elasticsearch6UpsertTableSink(

      boolean isAppendOnly,

      TableSchema schema,

      List<Host> hosts,

      String index,

      String docType,

      String keyDelimiter,

      String keyNullLiteral,

      SerializationSchema<Row> serializationSchema,

      XContentType contentType,

      ActionRequestFailureHandler failureHandler,

      Map<SinkOption, String> sinkOptions) {

 

   super(

      isAppendOnly,

      schema,

      hosts,

      index,

      docType,

      keyDelimiter,

      keyNullLiteral,

      serializationSchema,

      contentType,

      failureHandler,

      sinkOptions,

      UPDATE_REQUEST_FACTORY);

}

 

请问，是不是我的用法不对？

有没有类似ElasticTableSink.bulid 的建造类，方便构造tableSink对象。