Re:Re: 关于elasticSearch table sink 构造过于复杂

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

感谢解答，
我的意图是 构建EStablesink，可以将table 查询的结果 直接写入ES 避免再转换DataStream 通过ESSink写入






在 2019-08-26 16:39:49，"Jark Wu" <[hidden email]> 写道：

>Hi ,
>
>
>Elasticsearch6UpsertTableSink 是标记成 @internal 的，不是开放给用户直接去构造的。
>如果要注册一个 ES sink，可以使用 descriptor API，也就是 org.apache.flink.table.descriptors.Elasticsearch。
>或者使用 DDL 方式注册。
>
>
>Best,
>Jark
>
>> 在 2019年8月26日，16:33，aven.wu <[hidden email]> 写道：
>>
>> 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对象。
>>