Regards,
Fábio Dias.
Abdul Salam Shaikh <abd.salam.sha...@gmail.com> escreveu no dia sexta,
28/04/2017 às 10:18:
> Hi,
>
> I am trying to write the results of my stream into a CSV format using the
> following code and it has compilation issues:
>
> DataStream objectStream = wi
the second
scenario, where I need to perform this task every hour, what it is the best
way to do it?
Thanks,
Fábio Dias.
che.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1657)
at
org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:40)
at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1116)
Do I need to downgrade my elastic version or there is some other way to
make it work?
Thanks,
Fábio Dias.
esJson.put("data", element);
>
> What you should do here is parse the field values from `element`, and
> simply treat them as key-value pairs of the `esJson` map.
>
> So, the `esJson` should be prepared by doing:
>
> esJson.put(“id”, 6);
>
> esJson.put(“name”, “A
Hi,
I'm using Flink and Elasticsearch and I want to recieve in elasticsearch a
json object ({"id":1, "name":"X"} ect...), I already have a string with
this information, but I don't want to save it as string.
I recieve this:
{
"_index": "logs",
"_type": "object",
"_id":
