Class ElasticsearchBulkIndexOperation
- java.lang.Object
-
- org.nuxeo.ecm.automation.elasticsearch.ElasticsearchBulkIndexOperation
-
public class ElasticsearchBulkIndexOperation extends Object
Run Elasticsearch indexing operation using the Bulk Service- Since:
- 10.3
-
-
Field Summary
Fields Modifier and Type Field Description protected BulkService
bulkService
protected OperationContext
ctx
protected ElasticSearchAdmin
esa
static String
ID
protected CoreSession
session
-
Constructor Summary
Constructors Constructor Description ElasticsearchBulkIndexOperation()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
checkAccess()
Blob
run()
Blob
run(String nxql)
protected String
submitBulkCommand(String nxql, boolean syncAlias)
-
-
-
Field Detail
-
ID
public static final String ID
- See Also:
- Constant Field Values
-
session
protected CoreSession session
-
ctx
protected OperationContext ctx
-
esa
protected ElasticSearchAdmin esa
-
bulkService
protected BulkService bulkService
-
-
Constructor Detail
-
ElasticsearchBulkIndexOperation
public ElasticsearchBulkIndexOperation()
-
-
Method Detail
-
run
public Blob run() throws IOException
- Throws:
IOException
-
submitBulkCommand
protected String submitBulkCommand(String nxql, boolean syncAlias)
-
checkAccess
protected void checkAccess()
-
run
public Blob run(String nxql) throws IOException
- Throws:
IOException
-
-