flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jark Wu <imj...@gmail.com>
Subject Re: 关于elasticSearch table sink 构造过于复杂
Date Mon, 26 Aug 2019 08:39:49 GMT
Hi ,


Elasticsearch6UpsertTableSink 是标记成 @internal 的,不是开放给用户直接去构造的。
如果要注册一个 ES sink,可以使用 descriptor API,也就是 org.apache.flink.table.descriptors.Elasticsearch。
或者使用 DDL 方式注册。


Best,
Jark

> 在 2019年8月26日,16:33,aven.wu <danxieai258@163.com> 写道:
> 
> 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
View raw message