public class QueuedDocument extends Object
Modifier and Type | Field and Description |
---|---|
static String |
_rcsid |
protected String[] |
binNames
The binnames for the document, according to the connector
|
protected DocumentDescription |
documentDescription
The document description.
|
protected Map<String,DocumentIngestStatusSet> |
lastIngestedStatus
The last ingested status, null meaning "never ingested".
|
protected boolean |
wasProcessed
This flag indicates whether the document has been processed or not.
|
Constructor and Description |
---|
QueuedDocument(DocumentDescription documentDescription,
Map<String,DocumentIngestStatusSet> lastIngestedStatus,
String[] binNames)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
boolean |
anyLastIngestedRecords()
Return true if there are *any* last ingested records.
|
String[] |
getBinNames()
Get the bin names for this document
|
DocumentDescription |
getDocumentDescription()
Get the document description.
|
DocumentIngestStatusSet |
getLastIngestedStatus(String outputConnectionName)
Get the last ingested status.
|
void |
setProcessed()
Note that the document was processed in some way.
|
boolean |
wasProcessed()
Check if document has been processed yet.
|
public static final String _rcsid
protected final DocumentDescription documentDescription
protected final Map<String,DocumentIngestStatusSet> lastIngestedStatus
protected final String[] binNames
protected boolean wasProcessed
public QueuedDocument(DocumentDescription documentDescription, Map<String,DocumentIngestStatusSet> lastIngestedStatus, String[] binNames)
documentDescription
- is the document description.lastIngestedStatus
- is the document's last ingested status.binNames
- are the bins associated with the document.public DocumentDescription getDocumentDescription()
public DocumentIngestStatusSet getLastIngestedStatus(String outputConnectionName)
outputConnectionName
- is the name of the output connection.public boolean anyLastIngestedRecords()
public String[] getBinNames()
public boolean wasProcessed()
public void setProcessed()