lumis.doui.bigdata

Class TabularSourceBigDataPersister<S extends TabularSource<?>>

java.lang.Object

lumis.doui.bigdata.TabularSourceBigDataPersister<S>

All Implemented Interfaces:

ISourceBigDataPersister<S>

Direct Known Subclasses:

ContentTableSourceBigDataPersister

@StableMinor(version="12.3",
             sinceVersion="10.0")
public class TabularSourceBigDataPersister<S extends TabularSource<?>>
extends Object
implements ISourceBigDataPersister<S>

Generic ISourceBigDataPersister for tabular sources.

Since:

8.1.0

Version:

$Revision: 23747 $ $Date: 2020-04-07 23:16:33 +0000 (Tue, 07 Apr 2020) $

Constructor Summary

Constructors

Constructor and Description
TabularSourceBigDataPersister()

Method Summary

Modifier and Type	Method and Description
void	addContextDocuments(String sourceId, String contextId) Adds all documents corresponding to the given source and context to the portal big data repository.
protected void	addDocumentPublications(StandardDocument standardDocument, S source, ISourceData data) Generates and adds the publications to be used as the value for StandardDocumentType#FIELD_PUBLICATIONS.
protected void	addDocumentPublications(StandardDocument standardDocument, S source, ISourceData row, Collection<String> serviceInstanceIds) Generates and adds the publications to be used as the value for StandardDocumentType#FIELD_PUBLICATIONS, for an row on a collection of service instances.
void	addDocuments(S source, Collection<? extends ISourceData> datas) Adds documents to the portal big data repository for the given source data entries.
void	addDocuments(S source, ISourceData... datas) Adds documents to the portal big data repository for the given source data entries.
protected void	addDocuments(S source, ISourceData data, IBigDataIndexer bigDataIndexer) Adds documents to the portal big data repository for the given source data.
void	deleteBigData(S source) Deletes all structure stored in the portal big data repository relative to a source.
void	deleteContextDocuments(String sourceId, String contextId) Deletes documents from the portal big data repository for the specified source in a context.
void	deleteDocuments(S source, Collection<String> itemIds) Deletes documents from the portal big data repository that corresponds to the data with the given primary key values.
void	deleteDocuments(S source, String... itemIds) Deletes documents from the portal big data repository that corresponds to the data with the given primary key values.
protected String	generateDocumentPublishedContextURL(S source, ISourceData row, String serviceInstanceId) Generates the URL For a published context to refer a row on a service instance.
protected Collection<? extends Document>	generateDocuments(S source, ISourceData data) Generates the documents to be stored for a given source data.
protected IDocumentTypeBuilder<? extends StandardDocumentType>	generateDocumentType(S source) Generates the document type definition for documents relative to the specified source. The default implementation generates a document type using as identifier the result of getDocumentTypeId(S) and this document type contains a field, with identifier of the result of getDocumentTypeFieldId(S), that holds the source fields' values.
protected double	getDocumentPopularity(StandardDocument document, S source, ISourceData data) Returns the popularity of the given document.
protected String	getDocumentTypeFieldId(S source) Returns the identifier to use for the document type source field
protected String	getDocumentTypeId(S source) Returns the identifier to use for the document type generated to the given source.
protected Collection<String>	getPublishedPrincipalIds(S source, ISourceData row) Returns the published principal identifiers to compose publications that will be added to StandardDocumentType#FIELD_PUBLICATIONS.
protected static Source<?>	getServiceSource(String sourceId, ISourceContext sourceContext) Returns the source of a service.
void	initBigData(S source) Initializes the big data repository with elements specifics to a source.
void	updateBigData(S source) Updates the big data repository according to a source.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TabularSourceBigDataPersister

public TabularSourceBigDataPersister()

Method Detail

generateDocumentType

protected IDocumentTypeBuilder<? extends StandardDocumentType> generateDocumentType(S source)

Generates the document type definition for documents relative to the specified source.
The default implementation generates a document type using as identifier the result of getDocumentTypeId(S) and this document type contains a field, with identifier of the result of getDocumentTypeFieldId(S), that holds the source fields' values.

Parameters:

source - the source.

Returns:

the document type.

Since:

8.1.0

See Also:

getDocumentTypeId(S), getDocumentTypeFieldId(S)

getDocumentTypeId

protected String getDocumentTypeId(S source)

Returns the identifier to use for the document type generated to the given source.

Parameters:

source - the source.

Returns:

the corresponding document type identifier.

Since:

8.1.0

See Also:

generateDocumentType(S)

getDocumentTypeFieldId

protected String getDocumentTypeFieldId(S source)

Returns the identifier to use for the document type source field

Parameters:

source - the source.

Returns:

the corresponding source field identifier.

Since:

8.2.0

initBigData

public void initBigData(S source)

Description copied from interface: ISourceBigDataPersister

Initializes the big data repository with elements specifics to a source.

This method is called at some moment between the service registration and its use, or when the source big data will be recreated (after ISourceBigDataPersister.deleteBigData(S) is called to delete anything related to the source).

This method will usually create the document types that ISourceBigDataPersister.addDocuments(S, lumis.doui.source.ISourceData...) for the source will use.

Specified by:

initBigData in interface ISourceBigDataPersister<S extends TabularSource<?>>

Parameters:

source - the source.

updateBigData

public void updateBigData(S source)

Description copied from interface: ISourceBigDataPersister

Updates the big data repository according to a source.

This method is called at some moment between the service registration and its use.

This method will usually update the document types for the source.

Specified by:

updateBigData in interface ISourceBigDataPersister<S extends TabularSource<?>>

Parameters:

source - the source.

deleteBigData

public void deleteBigData(S source)

Description copied from interface: ISourceBigDataPersister

Deletes all structure stored in the portal big data repository relative to a source.

This method is called when a source will cease to exist or when recreating the big data for a source.

This method must delete elements created by ISourceBigDataPersister.initBigData(S) and documents added by ISourceBigDataPersister.addDocuments(S, lumis.doui.source.ISourceData...).

This method will usually delete the document types created in ISourceBigDataPersister.initBigData(S) and used by ISourceBigDataPersister.addDocuments(S, lumis.doui.source.ISourceData...), which will remove related documents in cascade.

Specified by:

deleteBigData in interface ISourceBigDataPersister<S extends TabularSource<?>>

Parameters:

source - the source.

addContextDocuments

public void addContextDocuments(String sourceId,
                                String contextId)

Description copied from interface: ISourceBigDataPersister

Adds all documents corresponding to the given source and context to the portal big data repository.

This method is usually called when re-indexing a source after its documents have been deleted.

Specified by:

addContextDocuments in interface ISourceBigDataPersister<S extends TabularSource<?>>

Parameters:

sourceId - the source identifier.

contextId - the context identifier. Usually a service or service instance identifier.

deleteContextDocuments

public void deleteContextDocuments(String sourceId,
                                   String contextId)

Description copied from interface: ISourceBigDataPersister

Deletes documents from the portal big data repository for the specified source in a context.

Specified by:

deleteContextDocuments in interface ISourceBigDataPersister<S extends TabularSource<?>>

Parameters:

sourceId - the source identifier.

contextId - the context identifier.

getServiceSource

protected static Source<?> getServiceSource(String sourceId,
                                            ISourceContext sourceContext)

Returns the source of a service.

Parameters:

sourceId - the desired source identifier.

sourceContext - the source context to use to create the sources.

Returns:

the source.

Since:

10.0.0

addDocuments

public final void addDocuments(S source,
                               ISourceData... datas)

Adds documents to the portal big data repository for the given source data entries.

To override the documents generated for each data, override generateDocuments(TabularSource, ISourceData) instead of this method. If it is necessary to override this method, override addDocuments(TabularSource, Collection) instead, as the implementation of this method only delegates to it.

Specified by:

addDocuments in interface ISourceBigDataPersister<S extends TabularSource<?>>

Parameters:

source - the source.

datas - the source's data to be used to generate the documents.

addDocuments

public void addDocuments(S source,
                         Collection<? extends ISourceData> datas)

Adds documents to the portal big data repository for the given source data entries.

To override the documents generated for each data, override generateDocuments(TabularSource, ISourceData) instead of this method.

Specified by:

addDocuments in interface ISourceBigDataPersister<S extends TabularSource<?>>

Parameters:

source - the source.

datas - the source's data to be used to generate the documents.

addDocuments

protected void addDocuments(S source,
                            ISourceData data,
                            IBigDataIndexer bigDataIndexer)

Adds documents to the portal big data repository for the given source data.

Parameters:

source - the source.

data - the source's data to be used to generate the documents.

bigDataIndexer - the big data indexer to add the documents.

Since:

8.1.0

generateDocuments

protected Collection<? extends Document> generateDocuments(S source,
                                                           ISourceData data)

Generates the documents to be stored for a given source data.

The default implementations of addDocuments methods call this method to generate the documents to be added.

Parameters:

source - the source.

data - the source data.

Returns:

a collection of documents to be added for the given data.

Since:

8.1.0

See Also:

#generateDocumentPublications(TabularSource, ISourceData)

getDocumentPopularity

protected double getDocumentPopularity(StandardDocument document,
                                       S source,
                                       ISourceData data)

Returns the popularity of the given document. The returned value must be a positive finite number.
See IDocumentPopularityProvider.calculateDocumentPopularity(StandardDocument) for more information.

Parameters:

document - the document

source - source related to the given document

data - row of content

Returns:

the popularity of the given document

Since:

11.1.0

See Also:

IDocumentPopularityProvider.calculateDocumentPopularity(StandardDocument)

addDocumentPublications

protected void addDocumentPublications(StandardDocument standardDocument,
                                       S source,
                                       ISourceData data)

Generates and adds the publications to be used as the value for StandardDocumentType#FIELD_PUBLICATIONS.

This method is called by generateDocuments(TabularSource, ISourceData).

Parameters:

standardDocument - the document to add the publications.

source - the source the document is being generated for.

data - the source data the document is being generated for.

Since:

8.1.0

addDocumentPublications

protected void addDocumentPublications(StandardDocument standardDocument,
                                       S source,
                                       ISourceData row,
                                       Collection<String> serviceInstanceIds)

Generates and adds the publications to be used as the value for StandardDocumentType#FIELD_PUBLICATIONS, for an row on a collection of service instances.

This method is called by addDocumentPublications(StandardDocument, TabularSource, ISourceData).

Parameters:

standardDocument - the document to add the publications.

source - the source the document is being generated for.

row - the row being processed.

serviceInstanceIds - the service instance identifiers.

Since:

8.1.0

getPublishedPrincipalIds

protected Collection<String> getPublishedPrincipalIds(S source,
                                                      ISourceData row)

Returns the published principal identifiers to compose publications that will be added to StandardDocumentType#FIELD_PUBLICATIONS.

This method is called by addDocumentPublications(StandardDocument, TabularSource, ISourceData, Collection).

Parameters:

source - the source that the generated document belongs to.

row - the row being processed.

Returns:

published principal identifiers.

Since:

8.1.0

generateDocumentPublishedContextURL

protected String generateDocumentPublishedContextURL(S source,
                                                     ISourceData row,
                                                     String serviceInstanceId)

Generates the URL For a published context to refer a row on a service instance.

This method is called by #addDocumentPublications(StandardDocument, TabularSource, String, Collection).

This method may return null, if no URL is available for the given row. In this case, a publication will not be generated.

Parameters:

source - the source the document is being generated for.

row - the row being processed.

serviceInstanceId - the service instance identifier.

Returns:

the published context URL.

Since:

8.1.0

deleteDocuments

public final void deleteDocuments(S source,
                                  String... itemIds)

Description copied from interface: ISourceBigDataPersister

Deletes documents from the portal big data repository that corresponds to the data with the given primary key values.

Specified by:

deleteDocuments in interface ISourceBigDataPersister<S extends TabularSource<?>>

Parameters:

source - the source.

itemIds - the source data primary key values.

deleteDocuments

public void deleteDocuments(S source,
                            Collection<String> itemIds)

Description copied from interface: ISourceBigDataPersister

Deletes documents from the portal big data repository that corresponds to the data with the given primary key values.

Specified by:

deleteDocuments in interface ISourceBigDataPersister<S extends TabularSource<?>>

Parameters:

source - the source.

itemIds - the source data primary key values.