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 Update
nks a lot.
De: Kostas Kloudas
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 seen form the mailing list w
Hi, I'm currently working on designing a data-processing cluster, and one of
the distributed processing tools we want to use is Flink.
As we're creating our cluster from barebones, without relying on any Hadoop
distributions such as Hortonworks or Cloudera, we want to use Flink with Hadoop
2.9
