Package org.elasticsearch.client.action.index

Examples of org.elasticsearch.client.action.index.IndexRequestBuilder.execute()

73
74
75
76
77
78
79
80
81
82
83
         
        }
      }
      // insert the document into elasticsearch
      response.setSource(mp);
      response.execute();
     
  }

  @Override
  public void close() throws IOException {
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
        XContentBuilder builder = XContentFactory.jsonBuilder();

        IndexRequestBuilder indexRequestbuilder = client.prepareIndex(INDEX_NAME, CHILD_TYPE_NAME, id);
        indexRequestbuilder = indexRequestbuilder.setParent(id);
        indexRequestbuilder = indexRequestbuilder.setSource(builder.map(objectMap));
        indexRequestbuilder.execute().actionGet();
    }

    /**
     * Execute a search based on a JSON String in QueryDSL format.
     *
 
View Full Code Here
155
156
157
158
159
160
161
162
163
164
165
    public void feedDoc(String twitterId, XContentBuilder b) {
//        String getIndexName() = new SimpleDateFormat("yyyyMMdd").format(tw.getCreatedAt());
        IndexRequestBuilder irb = client.prepareIndex(getIndexName(), getIndexType(), twitterId).
                setConsistencyLevel(WriteConsistencyLevel.DEFAULT).
                setSource(b);
        irb.execute().actionGet();
    }

    public void deleteById(String id) {
        DeleteResponse response = client.prepareDelete(getIndexName(), getIndexType(), id).
                execute().
View Full Code Here
317
318
319
320
321
322
323
324
325
326
327
    // This ensures that the write goes through if I can write to any nodes, which seems sensible
    // You could always check the response and handle minimal success like failure if you want
    irb.setConsistencyLevel(WriteConsistencyLevel.ONE);
 
    try {
      irb.execute().actionGet();
    }
    catch (org.elasticsearch.transport.RemoteTransportException e) {     
      boolean bDocAlreadyExists =
        e.contains(org.elasticsearch.index.engine.DocumentAlreadyExistsEngineException.class) // 0.18
          ||
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.