Thanks a lot for the support!
On 9 May 2017 07:53, "Tzu-Li (Gordon) Tai" wrote:
> Hi!
>
> Thanks for sharing that repo! I think that would be quite an useful
> contribution to Flink for the users, if you’re up to preparing a PR for it
> :)
>
> It also looks like you’ve adopted most of the curren
Hi!
Thanks for sharing that repo! I think that would be quite an useful
contribution to Flink for the users, if you’re up to preparing a PR for it :)
It also looks like you’ve adopted most of the current ElasticsearchSink APIs
(RequestIndexer, ElasticsearchSinkFunction, etc.) for the
Elasticse
Hi Flavio
Maybe this is what you want:
https://github.com/397090770/flink-elasticsearch2-connector, It can save Flink
DataSet to elasticsearch.
importscala.collection.JavaConversions._
valconfig=Map("bulk.flush.max.actions"->"1000",
"cluster.name"->"elasticsearch")valhosts="www.iteblog.com"val
