public class IndexRequestComputation extends AbstractBulkComputation
Modifier and Type | Field and Description |
---|---|
protected String |
bucketKey |
protected org.elasticsearch.action.bulk.BulkRequest |
bulkRequest |
protected List<org.elasticsearch.action.bulk.BulkRequest> |
bulkRequests |
protected static String |
INDEX_OPTION |
protected static long |
MAX_RECORD_SIZE |
command, commands, delta, SELECT_DOCUMENTS_IN
Constructor and Description |
---|
IndexRequestComputation() |
Modifier and Type | Method and Description |
---|---|
protected void |
append(org.elasticsearch.action.index.IndexRequest indexRequest) |
protected void |
compute(CoreSession session,
List<String> documentIds,
Map<String,Serializable> properties) |
void |
endBucket(ComputationContext context,
BulkStatus delta)
Can be overridden to write to downstream computation or add results to status
|
protected String |
getIndexName(CoreSession session,
Map<String,Serializable> properties) |
void |
startBucket(String bucketKey)
Can be overridden to init stuff before processing the bucket
|
protected byte[] |
toBytes(org.elasticsearch.action.bulk.BulkRequest request) |
getCommand, getCurrentCommand, isAbortedCommand, loadDocuments, processBatchOfDocuments, processFailure, processRecord, updateStatus
init, metadata, processRetry, processTimer
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
destroy, signalStop
protected static final long MAX_RECORD_SIZE
protected static final String INDEX_OPTION
protected org.elasticsearch.action.bulk.BulkRequest bulkRequest
protected List<org.elasticsearch.action.bulk.BulkRequest> bulkRequests
public IndexRequestComputation()
public void startBucket(String bucketKey)
AbstractBulkComputation
startBucket
in class AbstractBulkComputation
protected void compute(CoreSession session, List<String> documentIds, Map<String,Serializable> properties)
compute
in class AbstractBulkComputation
protected void append(org.elasticsearch.action.index.IndexRequest indexRequest)
public void endBucket(ComputationContext context, BulkStatus delta)
AbstractBulkComputation
endBucket
in class AbstractBulkComputation
protected String getIndexName(CoreSession session, Map<String,Serializable> properties)
protected byte[] toBytes(org.elasticsearch.action.bulk.BulkRequest request)
Copyright © 2019 Nuxeo. All rights reserved.