com.attivio.sdk.ingest

Class DocumentList

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractList<E>

java.util.ArrayList<T>

com.attivio.sdk.esb.AbstractListMessage<IngestDocument>

com.attivio.sdk.ingest.DocumentList

All Implemented Interfaces:

GroupedMessage, PersistsThroughCycles, PlatformMessage, IndexMessage, Serializable, Cloneable, Iterable<IngestDocument>, Collection<IngestDocument>, List<IngestDocument>, RandomAccess

public class DocumentList
extends AbstractListMessage<IngestDocument>
implements Iterable<IngestDocument>, IndexMessage, PersistsThroughCycles, GroupedMessage

The basic container for a collection of IngestDocuments.

See Also:

Serialized Form

Field Summary

Fields inherited from class java.util.AbstractList

modCount

Fields inherited from interface com.attivio.sdk.esb.PlatformMessage

DEFAULT_MAX_LOG_LENGTH, MESSAGE_DROPPED, MESSAGE_SEND_TIME_PROP, PROP_MAX_LOG_LENGTH

Constructor Summary

Constructors

Constructor and Description
DocumentList() The default constructor
DocumentList(int size) Creates an empty document list, with pre-allocated space for size documents.
DocumentList(UUID cid, String... workFlows) Constructor with a client ID and a list of workflows.
DocumentList(UUID cid, WorkflowQueue workFlows) Constructor with a client ID and a workflow queue.

Method Summary

Modifier and Type	Method and Description
void	addMessageToGroup(GroupedMessage msg) Adds msg to the group.
DocumentList	clone() Clones a message.
protected IngestDocument	clone(IngestDocument tmp)
boolean	containsDocument(String docID) Determines if this list contains a given document based on docID.
boolean	equals(Object other)
IngestDocument	getDocument(String id) Gets a document from this list by document ID.
long	getEstimatedSize()
GroupedMessageId	getGroupedMessageId()
List<String>	getIds() Returns a new unmodifiable list of all document ID's in this DocumentList.
int	getSize() Gets the size of the list.
int	hashCode()
void	setGroupedMessageId(GroupedMessageId groupedMessageId) Sets the GroupedMessageId for this message.

Methods inherited from class com.attivio.sdk.esb.AbstractListMessage

addMessageHistory, addMessageHistory, getClientId, getMessageHistory, getMessageId, getMetadata, getProperty, getWorkflowQueue, getWorkflowQueue, isRedelivered, removeProperty, setClientId, setMessageId, setProperty, setRedelivered, setWorkflowQueue, setWorkflowQueue, toMessageString, toString, toStringDetailed

Methods inherited from class java.util.ArrayList

add, add, addAll, addAll, clear, contains, ensureCapacity, forEach, get, indexOf, isEmpty, iterator, lastIndexOf, listIterator, listIterator, remove, remove, removeAll, removeIf, removeRange, replaceAll, retainAll, set, size, sort, spliterator, subList, toArray, toArray, trimToSize

Methods inherited from class java.util.AbstractCollection

containsAll

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Methods inherited from interface com.attivio.sdk.esb.PlatformMessage

addMessageHistory, addMessageHistory, getClientId, getMessageHistory, getMessageId, getMetadata, getProperty, getWorkflowQueue, getWorkflowQueue, isRedelivered, removeProperty, setClientId, setMessageId, setProperty, setRedelivered, setWorkflowQueue, setWorkflowQueue, toMessageString

Methods inherited from interface java.util.List

containsAll

Methods inherited from interface java.util.Collection

parallelStream, stream

Constructor Detail

DocumentList

public DocumentList()

The default constructor

DocumentList

public DocumentList(int size)

Creates an empty document list, with pre-allocated space for size documents.

DocumentList

public DocumentList(UUID cid,
                    String... workFlows)

Constructor with a client ID and a list of workflows.

Parameters:

cid - the client ID

workFlows - the list of workflows

DocumentList

public DocumentList(UUID cid,
                    WorkflowQueue workFlows)

Constructor with a client ID and a workflow queue.

Parameters:

cid - the client ID

workFlows - the workflow queue

Method Detail

containsDocument

public boolean containsDocument(String docID)

Determines if this list contains a given document based on docID.

Parameters:

docID - the document ID

Returns:

true if the list contains the document with the specified ID

getDocument

public IngestDocument getDocument(String id)

Gets a document from this list by document ID.

Parameters:

id - the ID to look for

Returns:

the document or null if not in this list

getSize

public int getSize()

Gets the size of the list.

hashCode

public int hashCode()

Specified by:

hashCode in interface Collection<IngestDocument>

Specified by:

hashCode in interface List<IngestDocument>

Overrides:

hashCode in class AbstractListMessage<IngestDocument>

equals

public boolean equals(Object other)

Specified by:

equals in interface Collection<IngestDocument>

Specified by:

equals in interface List<IngestDocument>

Overrides:

equals in class AbstractListMessage<IngestDocument>

clone

public DocumentList clone()

Clones a message. The message ID is not cloned.

Specified by:

clone in interface PlatformMessage

Specified by:

clone in interface IndexMessage

Overrides:

clone in class AbstractListMessage<IngestDocument>

Returns:

the cloned index message

getIds

public List<String> getIds()

Returns a new unmodifiable list of all document ID's in this DocumentList.

getGroupedMessageId

public GroupedMessageId getGroupedMessageId()

Specified by:

getGroupedMessageId in interface GroupedMessage

Returns:

the GroupedMessageId for this message

setGroupedMessageId

public void setGroupedMessageId(GroupedMessageId groupedMessageId)

Description copied from interface: GroupedMessage

Sets the GroupedMessageId for this message. This method should normally be used only for the first message in the group with subsequent messages being added to the group via GroupedMessage.addMessageToGroup(GroupedMessage).

Specified by:

setGroupedMessageId in interface GroupedMessage

addMessageToGroup

public void addMessageToGroup(GroupedMessage msg)

Description copied from interface: GroupedMessage

Adds msg to the group. For ordering purposes, msg will appear after this.

Specified by:

addMessageToGroup in interface GroupedMessage

clone

protected IngestDocument clone(IngestDocument tmp)

Specified by:

clone in class AbstractListMessage<IngestDocument>

getEstimatedSize

public long getEstimatedSize()

Specified by:

getEstimatedSize in interface PlatformMessage

Overrides:

getEstimatedSize in class AbstractListMessage<IngestDocument>