Elasticsearch6UpsertTableSink 的构造方法过于复杂

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Elasticsearch6UpsertTableSink 的构造方法过于复杂

aven.wu
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对象。