public final class DocumentProcessor extends Object
Modifier and Type | Field and Description |
---|---|
static org.elasticsearch.common.unit.ByteSizeValue |
DEFAULT_BULK_MEMORY |
static int |
DEFAULT_BULK_SIZE |
static int |
DEFAULT_CONCURRENT_BULK_REQUESTS |
static org.elasticsearch.common.xcontent.XContentType |
DEFAULT_CONTENT_TYPE |
static int |
DEFAULT_DELETE_UNSEEN_BULK_SIZE |
static int |
DEFAULT_MAX_QUEUE |
static int |
DEFAULT_NUM_THREADS |
static String |
HARVESTER_METADATA_TYPE |
Map<String,String> |
harvesterMetadata |
Modifier and Type | Method and Description |
---|---|
void |
addDocument(MetadataDocument mdoc) |
org.elasticsearch.action.DocWriteRequest<?> |
buildDocumentAction(MetadataDocument mdoc)
Processes the given
MetadataDocument and returns
the DocWriteRequest to pass to Elasticsearch
(can either be IndexRequest or DeleteRequest ). |
void |
close(Set<String> validIdentifiers) |
boolean |
isClosed() |
boolean |
isFailed() |
public static final String HARVESTER_METADATA_TYPE
public static final int DEFAULT_BULK_SIZE
public static final org.elasticsearch.common.unit.ByteSizeValue DEFAULT_BULK_MEMORY
public static final int DEFAULT_MAX_QUEUE
public static final int DEFAULT_CONCURRENT_BULK_REQUESTS
public static final int DEFAULT_NUM_THREADS
public static final int DEFAULT_DELETE_UNSEEN_BULK_SIZE
public static final org.elasticsearch.common.xcontent.XContentType DEFAULT_CONTENT_TYPE
public boolean isFailed()
public boolean isClosed()
public void addDocument(MetadataDocument mdoc) throws BackgroundFailure
BackgroundFailure
public org.elasticsearch.action.DocWriteRequest<?> buildDocumentAction(MetadataDocument mdoc) throws Exception
MetadataDocument
and returns
the DocWriteRequest
to pass to Elasticsearch
(can either be IndexRequest
or DeleteRequest
).Exception
Copyright ©2007-2013 panFMP Developers c/o Uwe Schindler