Index index = searchService.getIndex(IndexSpec.newBuilder()
.setName(indexName)
.build());
List<Document> documents = new ArrayList<>();
Field field = Field.newBuilder().setName("subject").setText("put(Document)").build();
Document document1 = Document.newBuilder()
.setId(docId + "1")
.addField(field).build();
field = Field.newBuilder().setName("subject").setText("put(Document)").build();
Document document2 = Document.newBuilder()
.setId(docId + "2")
.addField(field).build();
documents.add(document1);
documents.add(document2);
Future<PutResponse> resp = index.putAsync(documents);
while (!resp.isDone()) {
if (resp.isCancelled()) {
break;
}
}
GetIndexesRequest request = GetIndexesRequest.newBuilder()
.setIndexNamePrefix(indexName)
.build();
GetResponse<Index> response = searchService.getIndexes(request);
List<Index> listIndexes = response.getResults();
for (Index oneIndex : listIndexes) {
Field retField = oneIndex.get(docId + "1").getOnlyField("subject");
assertEquals("put(Document)", retField.getText());
retField = oneIndex.get(docId + "2").getOnlyField("subject");
assertEquals("put(Document)", retField.getText());
sync();
}
}