How to create and use Pipelines via Java API in ElasticSearch -

-

i'm trying create timestamp attach documents indexed. know possible in query dsl via below set of commands. cannot find out how through java api. have of done before?

thanks!

delete anindex   put _ingest/pipeline/timestamp {     "description" : "describe pipeline",     "processors" : [{                       "set" : {                                 "field": "timestamp",                                 "value": "{{_ingest.timestamp}}"                               }                     }]                }   put anindex {    "mappings": {                  "jeff": {                          }                } }   put anindex/jeff/id10?pipeline=timestamp {   "hi": "jeff" }   anindex/jeff/id10

as far know, elasticsearch doesn't have java api defining ingest pipeline. work around, can following define ingest pipeline java using httpurlconnection:

url obj = new url("http://localhost:9200/_ingest/pipeline/timestamp"); string json = "{\n" +          "  \"description\": \"describe pipeline\",\n" +          "  \"processors\": [\n" +          "    {\n" +          "      \"set\": {\n" +          "        \"field\": \"timestamp\",\n" +          "        \"value\": \"{{_ingest.timestamp}}\"\n" +          "      }\n" +          "    }\n" +          "  ]\n" +          "}"; httpurlconnection con = (httpurlconnection) obj.openconnection();  con.setrequestmethod("put"); con.setdoinput(true); con.setdooutput(true); con.setrequestproperty("content-type", "application/json; charset=utf-8");  outputstreamwriter osw = new outputstreamwriter(con.getoutputstream()); osw.write(json); osw.flush(); osw.close();  system.out.println(con.getresponsecode() + " : " + con.getresponsemessage()); if (con != null)     con.disconnect();

and now, below java code indexing document passing them through created "timestamp" ingest pipeline:

transportclient client = buildtransportclient();  map<string, object> object = new hashmap<string, object>(); object.put("user","kimchy"); object.put("postdate",new date()); object.put("message","trying out elasticsearch");  indexresponse response = client.prepareindex("test", "test", "100")         .setsource(object)         .setpipeline("timestamp")         .get();  system.out.println(response);

Comments

Post a Comment

Popular posts from this blog

ios - MKAnnotationView layer is not of expected type: MKLayer -

-
Image
so code works fine logger riddled message. there way rid of or suppress it? postannotation.swift class postannotation: mkpointannotation { //mark: properties let post: post //mark: initialization init(post: post) { self.post = post super.init() self.coordinate = cllocationcoordinate2d(latitude: post.latitude, longitude: post.longitude) self.title = post.title self.subtitle = post.timestring() } } adding annotation let annotation = postannotation(post: post) self.map.addannotation(annotation) func mapview func mapview(_ mapview: mkmapview, viewfor annotation: mkannotation) -> mkannotationview? { if annotation mkuserlocation { return nil } var annotationview = mapview.dequeuereusableannotationview(withidentifier: "pin") as? mkpinannotationview if annotationview == nil { annotationview = mkpinannotationview(annotation: annotation, reuseidentifier: "pin")
Read more

ZeroMQ on Windows, with Qt Creator -

-
i have installed zmq link given below on windows 7. http://zeromq.org/distro:microsoft-windows 1) have c++ project in qt-creator , i'm using zmq c++ binding (zhelpers.hpp etc). 2) have added .lib installed zmq folder qtcreator 3) while compiling, compiler looks _imp__zmq_verion, in .dll files present in .lib have __imp_zmq_version. 4) causing undefined reference zmq_version. anyone else faced problem , has solution ?
Read more

unity3d - Unity SceneManager.LoadScene quits application -

-
i have 2 different scenes 1 named 'main' , other 'game' both added scenes in load. when use scenemanager.loadscene("game"); works no problem when tried return main scene code if (input.getkeydown (keycode.escape)) { scenemanager.loadscene("main"); } strangely game quits. thanks. sorry interruption. somewhere on other script found code. if (input.getkeydown (keycode.escape)) { application.quit (); } that's bad, know...
Read more