flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aven.wu <danxieai...@163.com>
Subject 关于elasticSearch table sink 构造过于复杂
Date Mon, 26 Aug 2019 08:33:27 GMT
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对象。

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message