Examples of bulkAddDocuments()

Examples of com.ikanow.infinit.e.data_model.index.ElasticSearchManager.bulkAddDocuments()

198
199
200
201
202
203
204
205
206
207
208
      nSynced++;
     
      // Add the entities
      if ( entities.size() > 1000 )
      {
        elasticManager.bulkAddDocuments(
            IndexManager.mapListToIndex(entities, EntityFeaturePojo.listType(), new EntityFeaturePojoIndexMap()),
            "_id", null, true);
          // (note EntityFeaturePojoIndexMap creates an "_id" field of the format index:community)
       
        entities = new ArrayList<EntityFeaturePojo>();
View Full Code Here

Examples of com.ikanow.infinit.e.data_model.index.ElasticSearchManager.bulkAddDocuments()

207
208
209
210
211
212
213
214
215
216
217
       
        entities = new ArrayList<EntityFeaturePojo>();
      }
    }
    //write whatevers left
    elasticManager.bulkAddDocuments(
        IndexManager.mapListToIndex(entities, EntityFeaturePojo.listType(), new EntityFeaturePojoIndexMap()),
        "_id", null, true);
      // (note EntityFeaturePojoIndexMap creates an "_id" field of the format index:community)
   
    if (null != chunk) {
View Full Code Here

Examples of com.ikanow.infinit.e.data_model.index.ElasticSearchManager.bulkAddDocuments()

208
209
210
211
212
213
214
215
216
217
218
      events.add(evt);
      nSynced++;
         
      if ( events.size() > 1000 )
      {
        elasticManager.bulkAddDocuments(IndexManager.mapListToIndex(events, AssociationFeaturePojo.listType(), new AssociationFeaturePojoIndexMap()), "_id", null,true);
        events.clear();
      }
    }
     // End loop over entities
   
View Full Code Here

Examples of com.ikanow.infinit.e.data_model.index.ElasticSearchManager.bulkAddDocuments()

215
216
217
218
219
220
221
222
223
224
225
      }
    }
     // End loop over entities
   
    //write whatevers left
    elasticManager.bulkAddDocuments(IndexManager.mapListToIndex(events, AssociationFeaturePojo.listType(), new AssociationFeaturePojoIndexMap()), "_id", null,true);
   
    if (null != chunk) {
      System.out.println("Found " + nSynced + " records to sync in chunk");
    }       
  }
View Full Code Here

Examples of com.ikanow.infinit.e.data_model.index.ElasticSearchManager.bulkAddDocuments()

490
491
492
493
494
495
496
497
498
499
500
   
    ElasticSearchManager indexManager = IndexManager.createIndex("test", null, false, null, null, ImmutableSettings.settingsBuilder());
   
    BulkResponse result = null;
    // All docs
    result = indexManager.bulkAddDocuments(IndexManager.mapListToIndex(docset, new TypeToken<Set<DocumentPojo>>(){},
                                  new DocumentPojoIndexMap()), "_id", null, true);
    if (result.hasFailures()) {
      System.out.print("****** FAILED: ");
      System.out.println(result.buildFailureMessage());
    }
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.