Examples of execute()

Examples of org.elasticsearch.client.action.bulk.BulkRequestBuilder.execute()

91
92
93
94
95
96
97
98
99
100
101
            BulkRequestBuilder request = client1.prepareBulk();
            for (int j = 0; j < BATCH; j++) {
                counter++;
                request.add(Requests.indexRequest("test").type("type1").id(Integer.toString(counter)).source(source(Integer.toString(counter), "test" + counter)));
            }
            BulkResponse response = request.execute().actionGet();
            if (response.hasFailures()) {
                System.err.println("failures...");
            }
            if (((i * BATCH) % 10000) == 0) {
                System.out.println("Indexed " + (i * BATCH) + " took " + stopWatch.stop().lastTaskTime());
View Full Code Here

Examples of org.elasticsearch.client.action.delete.DeleteRequestBuilder.execute()

374
375
376
377
378
379
380
381
382
383
384
    DeleteRequestBuilder drb = _elasticClient.prepareDelete(_sIndexName, _sIndexType, _id);
    if (null != sParentId) {
      drb.setRouting(sParentId);
    }
    drb.setConsistencyLevel(WriteConsistencyLevel.ONE);
    DeleteResponse dr = drb.execute().actionGet();
    return DeleteResponseUtils.isFound(dr);
   
  }//TESTED (including children)
   
  ///////////////////////////////////////////////////////////////////////////////////////
View Full Code Here

Examples of org.elasticsearch.client.action.get.GetRequestBuilder.execute()

345
346
347
348
349
350
351
352
353
354
355
  public Map<String, GetField> getDocument(String _id, String... sFields) {
    GetRequestBuilder grb = _elasticClient.prepareGet(_sIndexName, _sIndexType, _id);
    if (null != sFields) {
      grb.setFields(sFields);
    }
    GetResponse gr = grb.execute().actionGet();
    Map<String, GetField> fieldsMap = gr.getFields();
    if (null != fieldsMap) {
      if (fieldsMap.isEmpty()) {
        fieldsMap = null;
      }
View Full Code Here

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

Examples of org.elasticsearch.client.action.search.SearchRequestBuilder.execute()

190
191
192
193
194
195
196
197
198
199
200
                        builder.setFrom(size / 2);
                    }
                    String value = nextFieldValue();
                    builder.setQuery(termQuery("field", value));
                    searchCounter.incrementAndGet();
                    SearchResponse searchResponse = builder.execute().actionGet();
                    if (searchResponse.failedShards() > 0) {
                        logger.warn("failed search " + Arrays.toString(searchResponse.shardFailures()));
                    }
                    // verify that all come from the requested index
                    for (SearchHit hit : searchResponse.hits()) {
View Full Code Here

Examples of org.elfinder.servlets.commands.AbstractCommand.execute()

126
127
128
129
130
131
132
133
134
135
136
      }

      // prepare command and run
      AbstractCommand command = prepareCommand((String) requestParams.get("cmd"), request, response, config);
      try {
        command.execute();
      } catch (ConnectorException e) {
        logger.warn("command returned an error", e);
        putResponse("error", e.getMessage());
      }
View Full Code Here

Examples of org.encog.engine.opencl.EncogCLQueue.execute()

352
353
354
355
356
357
358
359
360
361
362
      queue.array2Buffer(this.tempDataArray, this.tempDataInBuffer);
      queue.array2Buffer(this.gradients, this.gradientInBuffer);
      queue.array2Buffer(this.paramArray, this.paramBuffer);

      // Execute the kernel
      queue.execute(this);
      queue.waitFinish();

      // Read the results
      queue.buffer2Array(this.errorBuffer, this.errors);
      queue.buffer2Array(this.weightOutArrayBuffer, this.weightOutArray);
View Full Code Here

Examples of org.encog.ml.bayesian.query.BayesianQuery.execute()

657
658
659
660
661
662
663
664
665
666
667
      q.setEventValue(event, parsedEvent.resolveValue(event));
    }
   
    q.locateEventTypes();
   
    q.execute();
    return q.getProbability();
  }

  /**
   * {@inheritDoc}
 
View Full Code Here

Examples of org.encog.ml.bayesian.query.enumerate.EnumerationQuery.execute()

140
141
142
143
144
145
146
147
148
149
150
      query.setEventValue(event, true);
      index++;
    }

    //query.setSampleSize(100000000);
    query.execute();
    return query.getProbability();   
  }
 
  public void test(String message) {
    double d = probabilitySpam(message);
View Full Code Here

Examples of org.encog.ml.bayesian.query.sample.SamplingQuery.execute()

51
52
53
54
55
56
57
58
59
60
61
    SamplingQuery query = new SamplingQuery(network);
    query.defineEventType(a, EventType.Evidence);
    query.defineEventType(b, EventType.Outcome);
    query.setEventValue(b, true);
    query.setEventValue(a, true);
    query.execute();
    testPercent(query.getProbability(),20);
  }
 
  public void testSampling2() {
    BayesianNetwork network = new BayesianNetwork();
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.