Package fr.gouv.vitam.worker.core.plugin

Class ScrollSpliteratorHelper

java.lang.Object

fr.gouv.vitam.worker.core.plugin.ScrollSpliteratorHelper

public class ScrollSpliteratorHelper
extends Object

ScrollSpliteratorHelper class

Constructor Summary

Constructors

Constructor	Description
ScrollSpliteratorHelper()

Method Summary

Modifier and Type	Method	Description
static boolean	checkNumberOfResultQuery(ItemStatus itemStatus, long total)	Check number of result
static ScrollSpliterator<com.fasterxml.jackson.databind.JsonNode>	createObjectGroupScrollSplitIterator(MetaDataClient client, SelectMultiQuery selectMultiQuery)	Create objectGroups ScrollSpliterator from a query that can iterate millions of objectsGroups with default bachSize
static ScrollSpliterator<com.fasterxml.jackson.databind.JsonNode>	createObjectGroupScrollSplitIterator(MetaDataClient client, SelectMultiQuery selectMultiQuery, int bachSize)	Create objectGroups ScrollSpliterator from a query that can iterate millions of objectsGroups with given bachSize
static ScrollSpliterator<com.fasterxml.jackson.databind.JsonNode>	createUnitScrollSplitIterator(MetaDataClient client, SelectMultiQuery selectMultiQuery)	Create units ScrollSpliterator from a query that can iterate millions of units
static ScrollSpliterator<com.fasterxml.jackson.databind.JsonNode>	createUnitScrollSplitIterator(MetaDataClient client, SelectMultiQuery selectMultiQuery, int bachSize)	Create units ScrollSpliterator from a query that can iterate millions of units with given bachSize
static ScrollSpliterator<com.fasterxml.jackson.databind.JsonNode>	getUnitsScrollSpliterator(SelectMultiQuery request, MetaDataClient client)
static ScrollSpliterator<com.fasterxml.jackson.databind.JsonNode>	getUnitWithInheritedRulesScrollSpliterator(SelectMultiQuery request, MetaDataClient client)

Methods inherited from class java.lang.Object

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

Constructor Details

ScrollSpliteratorHelper

public ScrollSpliteratorHelper()

Method Details

createUnitScrollSplitIterator

public static ScrollSpliterator<com.fasterxml.jackson.databind.JsonNode> createUnitScrollSplitIterator(MetaDataClient client,
 SelectMultiQuery selectMultiQuery)

Create units ScrollSpliterator from a query that can iterate millions of units

Parameters:

client - metadataClient

selectMultiQuery - query

Returns:

the ScrollSpliterator

createUnitScrollSplitIterator

public static ScrollSpliterator<com.fasterxml.jackson.databind.JsonNode> createUnitScrollSplitIterator(MetaDataClient client,
 SelectMultiQuery selectMultiQuery,
 int bachSize)

Create units ScrollSpliterator from a query that can iterate millions of units with given bachSize

Parameters:

client - metadataClient

selectMultiQuery - query

bachSize - bachSize

Returns:

the ScrollSpliterator

createObjectGroupScrollSplitIterator

public static ScrollSpliterator<com.fasterxml.jackson.databind.JsonNode> createObjectGroupScrollSplitIterator(MetaDataClient client,
 SelectMultiQuery selectMultiQuery,
 int bachSize)

Create objectGroups ScrollSpliterator from a query that can iterate millions of objectsGroups with given bachSize

Parameters:

client - metadataClient

selectMultiQuery - query

bachSize - bachSize

Returns:

the ScrollSpliterator

createObjectGroupScrollSplitIterator

public static ScrollSpliterator<com.fasterxml.jackson.databind.JsonNode> createObjectGroupScrollSplitIterator(MetaDataClient client,
 SelectMultiQuery selectMultiQuery)

Create objectGroups ScrollSpliterator from a query that can iterate millions of objectsGroups with default bachSize

Parameters:

client - metadataClient

selectMultiQuery - query

Returns:

the ScrollSpliterator

getUnitWithInheritedRulesScrollSpliterator

public static ScrollSpliterator<com.fasterxml.jackson.databind.JsonNode> getUnitWithInheritedRulesScrollSpliterator(SelectMultiQuery request,
 MetaDataClient client)

getUnitsScrollSpliterator

public static ScrollSpliterator<com.fasterxml.jackson.databind.JsonNode> getUnitsScrollSpliterator(SelectMultiQuery request,
 MetaDataClient client)

checkNumberOfResultQuery

public static boolean checkNumberOfResultQuery(ItemStatus itemStatus,
 long total)

Check number of result

Parameters:

itemStatus - itemStatus

total - total of elements

Returns:

boolean