关于elasticSearch table sink 构造过于复杂

Posted by aven.wu on Aug 26, 2019; 8:33am
URL: http://apache-flink.370.s1.nabble.com/elasticSearch-table-sink-tp475.html

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对象。