Package fr.becpg.repo.batch

Class WorkProviderFactory.BatchWorkProvider<T>

java.lang.Object

fr.becpg.repo.batch.WorkProviderFactory.BatchWorkProvider<T>

All Implemented Interfaces:

org.alfresco.repo.batch.BatchProcessWorkProvider<T>

Direct Known Subclasses:

WorkProviderFactory.QueryBuilderWorkProvider, WorkProviderFactory.SourceAssocsWorkProvider

Enclosing class:

WorkProviderFactory

private static class WorkProviderFactory.BatchWorkProvider<T>
extends Object
implements org.alfresco.repo.batch.BatchProcessWorkProvider<T>

Field Summary

Fields

Modifier and Type	Field	Description
private int	currentCount
private int	maxResults
protected Deque<T>	pendingItems
protected int	pullIndex
protected int	pullSize
private int	pushSize
protected int	totalEstimatedSize
protected org.alfresco.service.transaction.TransactionService	transactionService

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BatchWorkProvider(List<T> pendingItems, int pullSize, int pushSize, int maxResults)
protected	BatchWorkProvider(org.alfresco.service.transaction.TransactionService transactionService, int pullSize, int pushSize, int maxResults)

Method Summary

Modifier and Type	Method	Description
private boolean	canPushMoreItems(Collection<T> pushedItems)
List<T>	collect()
private void	collectPushedItems(Collection<T> pushedItems)
Collection<T>	getNextWork()
int	getTotalEstimatedWorkSize()
long	getTotalEstimatedWorkSizeLong()
protected List<T>	pullItems()

Methods inherited from class java.lang.Object

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

Field Details

pendingItems

protected Deque<T> pendingItems

transactionService

protected org.alfresco.service.transaction.TransactionService transactionService

pullSize

protected int pullSize

pushSize

private int pushSize

maxResults

private int maxResults

currentCount

private int currentCount

totalEstimatedSize

protected int totalEstimatedSize

pullIndex

protected int pullIndex

Constructor Details

BatchWorkProvider

protected BatchWorkProvider(List<T> pendingItems,
 int pullSize,
 int pushSize,
 int maxResults)

BatchWorkProvider

protected BatchWorkProvider(org.alfresco.service.transaction.TransactionService transactionService,
 int pullSize,
 int pushSize,
 int maxResults)

Method Details

getTotalEstimatedWorkSize

public int getTotalEstimatedWorkSize()

Specified by:

getTotalEstimatedWorkSize in interface org.alfresco.repo.batch.BatchProcessWorkProvider<T>

getTotalEstimatedWorkSizeLong

public long getTotalEstimatedWorkSizeLong()

Specified by:

getTotalEstimatedWorkSizeLong in interface org.alfresco.repo.batch.BatchProcessWorkProvider<T>

getNextWork

public Collection<T> getNextWork()

Specified by:

getNextWork in interface org.alfresco.repo.batch.BatchProcessWorkProvider<T>

collect

public List<T> collect()

collectPushedItems

private void collectPushedItems(Collection<T> pushedItems)

canPushMoreItems

private boolean canPushMoreItems(Collection<T> pushedItems)

pullItems

protected List<T> pullItems()