When building the request, you should build an UpdateRequest, like the
following snippet:
import org.elasticsearch.action.update.UpdateRequest
import org.elasticsearch.common.xcontent.XContentType
val doc: String = ???
val targetIndex: String = ???
val indexType: Option[String] = ???
new
a lot.
De: Kostas Kloudas <k.klou...@data-artisans.com>
Enviat el: dimecres, 29 de novembre de 2017 11:15:16
Per a: ORIOL LOPEZ SANCHEZ
A/c: user@flink.apache.org
Tema: Re: Are there plans to support Hadoop 2.9.0 on near future?
Hi Oriol,
As you may have see
/FLINK-5174 related to keys of the
KeyedStreams? I'm not sure what kind of keys it is related to. If so, is it
going to be addressed soon?
Thanks,
Oriol.
