Modifier and Type | Class and Description |
---|---|
class |
DeleteRequest
A committer deletion request.
|
class |
UpsertRequest
A committer upsert request (update or insert).
|
Modifier and Type | Method and Description |
---|---|
ICommitterRequest |
CommitterEvent.getRequest() |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractCommitter.accept(ICommitterRequest request) |
boolean |
ICommitter.accept(ICommitterRequest request) |
protected void |
AbstractCommitter.applyFieldMappings(ICommitterRequest req) |
static void |
CommitterUtil.applyTargetContent(ICommitterRequest req,
String targetContentField)
Applies the document content (input stream) to the target
field name.
|
static void |
CommitterUtil.applyTargetId(ICommitterRequest req,
String sourceIdField,
String targetIdField)
Applies the source ID field value after extracting it using
CommitterUtil.extractSourceIdValue(ICommitterRequest, String) ,
to the target ID ID field supplied. |
CommitterEvent.Builder |
CommitterEvent.Builder.committerRequest(ICommitterRequest request) |
static String |
CommitterUtil.extractSourceIdValue(ICommitterRequest req,
String sourceIdField)
Extracts the source ID value.
|
static String |
CommitterUtil.extractSourceIdValue(ICommitterRequest req,
String sourceIdField,
boolean keepSourceIdField)
Extracts the source ID value.
|
protected void |
AbstractCommitter.fireDebug(String name,
ICommitterRequest req) |
protected void |
AbstractCommitter.fireError(String name,
ICommitterRequest req,
Exception e) |
protected void |
AbstractCommitter.fireInfo(String name,
ICommitterRequest req) |
static String |
CommitterUtil.getContentAsString(ICommitterRequest req)
Gets the request content as a string.
|
Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractBatchCommitter.commitBatch(Iterator<ICommitterRequest> it) |
void |
AbstractBatchCommitter.consume(Iterator<ICommitterRequest> it) |
void |
IBatchConsumer.consume(Iterator<ICommitterRequest> it) |
Modifier and Type | Method and Description |
---|---|
void |
ICommitterQueue.queue(ICommitterRequest request) |
Modifier and Type | Method and Description |
---|---|
static ICommitterRequest |
FSQueueUtil.fromZipFile(Path sourceFile) |
static ICommitterRequest |
FSQueueUtil.fromZipFile(Path sourceFile,
CachedStreamFactory streamFactory) |
Modifier and Type | Method and Description |
---|---|
void |
FSQueue.queue(ICommitterRequest request) |
static void |
FSQueueUtil.toZipFile(ICommitterRequest request,
Path targetFile) |
Modifier and Type | Method and Description |
---|---|
List<ICommitterRequest> |
MemoryCommitter.getAllRequests() |
Modifier and Type | Method and Description |
---|---|
boolean |
MemoryCommitter.removeRequest(ICommitterRequest req) |
Copyright © 2009–2022 Norconex Inc.. All rights reserved.