Package | Description |
---|---|
com.attivio.platform.transformer.ingest.util | |
com.attivio.sdk.client |
Interfaces for client side AIE development.
|
com.attivio.sdk.client.trigger |
Copyright 2016 Attivio Inc., All rights reserved.
|
com.attivio.sdk.esb | |
com.attivio.sdk.ingest | |
com.attivio.sdk.security | |
com.attivio.sdk.server.component.ingest |
Interfaces for all ingest related transformers and associated dependencies of those transformers.
|
com.attivio.sdk.server.component.reduce | |
com.attivio.sdk.service | |
com.attivio.sdk.test | |
com.attivio.sdk.util | |
com.sample.module |
Modifier and Type | Method and Description |
---|---|
static Collection<String> |
TransformerUtils.getAllOrSpecificFieldList(IngestDocument doc,
Collection<String> input)
Returns a specific list of input field names or all fields in the document if the input list is null or empty.
|
static <T> boolean |
TransformerUtils.mapFieldValues(IngestDocument doc,
FieldValueCreatingTransformer<T> trans)
Applies a FieldValueCreatingTransformer to the given IngestDocument.
|
static void |
TransformerUtils.mapFieldValues(IngestDocument doc,
Map<String,String> fieldMapping,
AdvancedFieldValueMapper mapper)
Map each document based on the fieldMapping using the supplied
AdvancedFieldValueMapper . |
static void |
TransformerUtils.mapFieldValues(IngestDocument doc,
Map<String,String> fieldMapping,
AdvancedFieldValueMapper mapper,
NewFieldCreator newFieldCreator)
Map each document based on the fieldMapping using the supplied
FieldValueMapper . |
static void |
TransformerUtils.mapFieldValues(IngestDocument doc,
Map<String,String> fieldMapping,
FieldValueMapper mapper)
Map each document based on the fieldMapping using the supplied
FieldValueMapper . |
static void |
TransformerUtils.mapFieldValues(IngestDocument doc,
Map<String,String> fieldMapping,
FieldValueMapper mapper,
NewFieldCreator newFieldCreator)
Map each document based on the fieldMapping using the supplied
FieldValueMapper . |
static void |
TransformerUtils.modifyFieldValues(IngestDocument doc,
Iterable<String> input,
AdvancedFieldValueModifier handler)
Iterates over all fields in
input , passing the field values for each to the modifier . |
static void |
TransformerUtils.modifyFieldValues(IngestDocument doc,
Iterable<String> input,
FieldValueModifier modifier)
Iterates over all fields in
input , passing the field values for each to the modifier . |
static <T> boolean |
TransformerUtils.processDocument(IngestDocument doc,
FieldValueCreatingTransformer<T> transformer)
A processDocument utility method for FieldValueCreatingTransformer, because that class doesn't have one.
|
Modifier and Type | Method and Description |
---|---|
IngestDocument |
DocumentStoreApi.retrieve(String namespace,
String docId) |
IngestDocument |
DocumentStoreApi.storeAndUpdate(String namespace,
IngestDocument doc,
List<String> filterFields,
boolean storeContentPointers)
Stores the document in
namespace , creating indexes which allow equality filtering on the list of fields provided. |
Modifier and Type | Method and Description |
---|---|
List<IngestDocument> |
ConnectorControlApi.debugConnector(String connectorName,
int numDocs)
A method to help with debugging connectors.
|
Iterable<IngestDocument> |
DocumentStoreApi.filteredRetrieve(String namespace,
Map<String,String> filters)
Finds and returns the documents matching the provided equality filters.
|
Modifier and Type | Method and Description |
---|---|
void |
DocumentOutputClient.feed(IngestDocument... docs)
Send
docs to AIE. |
void |
IngestClient.feed(IngestDocument doc,
AttivioAcl acl)
Feeds the document with its ACL to AIE.
|
void |
DocumentStoreApi.store(String namespace,
IngestDocument doc,
List<String> filterFields,
boolean storeContentPointers)
Stores the document in
namespace , creating indexes which allow equality filtering on the list of fields provided. |
IngestDocument |
DocumentStoreApi.storeAndUpdate(String namespace,
IngestDocument doc,
List<String> filterFields,
boolean storeContentPointers)
Stores the document in
namespace , creating indexes which allow equality filtering on the list of fields provided. |
Modifier and Type | Method and Description |
---|---|
void |
DocumentOutputClient.feed(Iterable<IngestDocument> docs)
Send
docs to AIE. |
Modifier and Type | Method and Description |
---|---|
IngestDocument |
TriggerApi.process(String dictionaryName,
IngestDocument document,
boolean published)
Process
document according to dictionaryName . |
Modifier and Type | Method and Description |
---|---|
IngestDocument |
TriggerApi.process(String dictionaryName,
IngestDocument document,
boolean published)
Process
document according to dictionaryName . |
Modifier and Type | Method and Description |
---|---|
void |
ProcessingResult.completed(IngestDocument doc) |
void |
ProcessingResult.debug(IngestDocument doc,
String msg) |
void |
ProcessingResult.drop(IngestDocument doc) |
void |
ProcessingResult.drop(IngestDocument doc,
ErrorCode errorCode) |
void |
ProcessingResult.drop(IngestDocument doc,
String msg) |
void |
ProcessingResult.drop(IngestDocument doc,
Throwable t) |
void |
ProcessingResult.error(IngestDocument doc,
Throwable e,
String msg) |
void |
ProcessingResult.fail(IngestDocument doc) |
void |
ProcessingResult.fail(IngestDocument doc,
ErrorCode errorCode,
Throwable e) |
void |
ProcessingResult.fail(IngestDocument doc,
ErrorCode defaultErrorCode,
Throwable e,
String msg) |
void |
ProcessingResult.fail(IngestDocument doc,
String msg) |
void |
ProcessingResult.fail(IngestDocument doc,
Throwable e) |
void |
ProcessingResult.lost(IngestDocument doc) |
void |
ProcessingResult.notHandled(IngestDocument doc) |
void |
ProcessingResult.setCurrentDocument(IngestDocument currentDocument)
Convenience function to set the current document context.
|
void |
ProcessingResult.warn(IngestDocument doc,
ErrorCode errorCode,
String msg,
Object... args) |
void |
ProcessingResult.warn(IngestDocument doc,
ErrorCode defaultErrorCode,
Throwable e,
String msg) |
void |
ProcessingResult.warn(IngestDocument doc,
Throwable e) |
void |
ProcessingResult.warn(IngestDocument doc,
Throwable e,
String msg,
Object... args) |
Constructor and Description |
---|
DocData(IngestDocument doc) |
Modifier and Type | Method and Description |
---|---|
IngestDocument |
IngestDocument.clone() |
protected IngestDocument |
DocumentList.clone(IngestDocument tmp) |
IngestDocument |
BulkUpdate.getDocument()
Get the template document for this bulk update.
|
IngestDocument |
DocumentList.getDocument(String id)
Gets a document from this list by document ID.
|
Modifier and Type | Method and Description |
---|---|
protected IngestDocument |
DocumentList.clone(IngestDocument tmp) |
void |
IngestDocument.importFields(IngestDocument doc)
Import all fields into this document.
|
Modifier and Type | Method and Description |
---|---|
void |
SecurityFeeder.feed(IngestDocument doc,
AttivioAcl acl)
Sends
doc to the document receiver with the given ACL. |
Modifier and Type | Method and Description |
---|---|
void |
ProcessingFeedbackHandler.debug(IngestDocument doc,
String message,
Object... args)
Return a debug message result to the client about the processing results of the current document.
|
void |
ProcessingFeedbackHandler.drop(IngestDocument ingestDocument)
Report a dropped document
|
void |
ProcessingFeedbackHandler.error(IngestDocument doc,
Exception e,
String message,
Object... args)
Report an error to the client about the processing results of the current document.
|
void |
ProcessingFeedbackHandler.fail(IngestDocument doc,
ErrorCode code,
Throwable e) |
void |
HandlesDocumentTimeout.handleDocumentTimeout(IngestDocument doc,
long timeoutPeriod,
Exception ex)
Method called when a timeout occurs.
|
void |
MultiOutputDocumentTransformer.process(IngestDocument doc,
DocumentOutputClient out)
Generates documents and messages from a single input document.
|
void |
ChildDocumentPostProcessor.processChildDocument(IngestDocument parent,
IngestDocument child)
Modify the parent and/or child document adding messages to the result as appropriate.
|
boolean |
DocumentModifyingTransformer.processDocument(IngestDocument doc)
Processes a single
IngestDocument . |
void |
ProcessingFeedbackDocumentTagger.tag(String stageName,
ProcessingFeedbackDocumentTagger.ProcessingResultLevel level,
IngestDocument doc,
Exception e,
String message,
Object... args) |
void |
ProcessingFeedbackHandler.warn(IngestDocument doc,
ErrorCode code,
Throwable e) |
void |
ProcessingFeedbackHandler.warn(IngestDocument doc,
Exception e,
String message,
Object... args)
Warn the client about the processing results of the current document.
|
Modifier and Type | Method and Description |
---|---|
IngestDocument |
ReducingTransformer.reduce(String keyValue,
Iterator<IngestDocument> documents)
Reduces a set of IngestDocument(s) based on key
|
Modifier and Type | Method and Description |
---|---|
IngestDocument |
ReducingTransformer.reduce(String keyValue,
Iterator<IngestDocument> documents)
Reduces a set of IngestDocument(s) based on key
|
Modifier and Type | Method and Description |
---|---|
IngestDocument |
MockDocumentStore.retrieve(String collection,
String docId) |
IngestDocument |
MockDocumentStore.storeAndUpdate(String namespace,
IngestDocument doc,
List<String> filterFields,
boolean storeContentPointers)
Stores the document in
namespace , creating indexes which allow equality filtering on the list of fields provided. |
Modifier and Type | Method and Description |
---|---|
Iterable<IngestDocument> |
MockDocumentStore.filteredRetrieve(String collection,
Map<String,String> filterVals)
Finds and returns the documents matching the provided equality filters.
|
Modifier and Type | Method and Description |
---|---|
void |
MockDocumentStore.store(String namespace,
IngestDocument doc,
List<String> filterFields,
boolean storeContentPointers)
Stores the document in
namespace , creating indexes which allow equality filtering on the list of fields provided. |
IngestDocument |
MockDocumentStore.storeAndUpdate(String namespace,
IngestDocument doc,
List<String> filterFields,
boolean storeContentPointers)
Stores the document in
namespace , creating indexes which allow equality filtering on the list of fields provided. |
Constructor and Description |
---|
MockAuditDetail(UUID clientId,
IngestDocument doc,
ProcessingResultCode code) |
Modifier and Type | Method and Description |
---|---|
IngestDocument |
MockIngestClient.getDocumentWithId(String docId) |
Modifier and Type | Method and Description |
---|---|
List<IngestDocument> |
MockIngestClient.getDocumentList() |
Modifier and Type | Method and Description |
---|---|
static void |
DocumentAssert.assertFieldValue(IngestDocument doc,
String field,
Object value)
check a doc value.
|
static void |
DocumentAssert.assertFieldValueContains(IngestDocument doc,
String field,
String value) |
static void |
DocumentAssert.assertFieldValueList(IngestDocument doc,
String field,
Object... values)
Assert that a document has the specified values for a field
|
static <T> void |
DocumentAssert.assertFieldValueSet(IngestDocument doc,
String field,
T... values) |
static IngestFieldValue |
DocumentAssert.assertSingleValue(IngestDocument doc,
String field) |
static IngestFieldValue |
DocumentAssert.assertSingleValueOrNull(IngestDocument doc,
String field) |
void |
MockProcessingFeedbackHandler.debug(IngestDocument doc,
String message,
Object... args) |
void |
MockProcessingFeedbackHandler.drop(IngestDocument doc)
Report a dropped document
|
void |
MockProcessingFeedbackHandler.error(IngestDocument doc,
Exception e,
String message,
Object... args) |
void |
MockProcessingFeedbackHandler.fail(IngestDocument doc,
ErrorCode code,
Throwable e) |
void |
MockIngestClient.feed(IngestDocument... docs) |
void |
MockIngestClient.feed(IngestDocument doc,
AttivioAcl acl) |
void |
MockProcessingFeedbackHandler.warn(IngestDocument doc,
ErrorCode code,
Throwable e) |
void |
MockProcessingFeedbackHandler.warn(IngestDocument doc,
Exception e,
String message,
Object... args) |
Modifier and Type | Method and Description |
---|---|
void |
MockIngestClient.feed(Iterable<IngestDocument> docs) |
Modifier and Type | Method and Description |
---|---|
IngestFieldValue |
AdvancedFieldValueMapperWrapper.createMappedValue(IngestDocument doc,
IngestField f,
IngestFieldValue fv) |
IngestFieldValue |
AdvancedFieldValueMapper.createMappedValue(IngestDocument doc,
IngestField f,
IngestFieldValue fv)
Process a single field value and returns the new value.
|
void |
AdvancedFieldValueModifier.modifyFieldValue(IngestDocument doc,
IngestField f,
IngestFieldValue fv)
Modify a single field value in place.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SampleDocumentModifyingTransformer.processDocument(IngestDocument doc) |
Copyright © 2018 Attivio, Inc. All Rights Reserved.
PATENT NOTICE: Attivio, Inc. Software Related Patents. With respect to the Attivio software product(s) being used, the following patents apply: Querying Joined Data Within A Search Engine Index: United States Patent No.(s): 8,073,840. Ordered Processing of Groups of Messages: U.S. Patent No.(s) 8,495,656. Signal processing approach to sentiment analysis for entities in documents: U.S. Patent No.(s) 8,725,494. Other U.S. and International Patents Pending.