flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tzu-Li (Gordon) Tai" <tzuli...@apache.org>
Subject Re: ElasticsearchSink on DataSet
Date Tue, 09 May 2017 04:59:50 GMT
Hi Flavio,

I don’t think there is a bridge class for this. At the moment you’ll have to implement
your own OutputFormat.
The ElasticsearchSink is a SinkFunction which is part of the DataStream API, which generally
speaking at the moment has no bridge or unification yet with the DataSet API.

Cheers,
Gordon


On 3 May 2017 at 10:15:51 PM, Flavio Pompermaier (pompermaier@okkam.it) wrote:


Hi to all,
at the moment I have a Flink Job that generates a DataSet<String> that I write to a
File that is read by Logstash to index data on ES.
I'd like to use the new ElasticsearchSink to index those JSON directly from Flink but ElasticsearchSink
only works with streaming environment.

Is there any bridge class for this?

Best,
Flavio
Mime
View raw message