Package com.atlassian.jira.issue.util.streamingretrievers

Class StreamingWorklogDTORetriever

java.lang.Object

com.atlassian.jira.issue.util.streamingretrievers.BaseStreamingRetriever<Long,String,WorklogDTO>

com.atlassian.jira.issue.util.streamingretrievers.StreamingWorklogDTORetriever

@ParametersAreNonnullByDefault
@ReturnValuesAreNonnullByDefault
public class StreamingWorklogDTORetriever
extends BaseStreamingRetriever<Long,String,WorklogDTO>

Constructor Summary

Constructors

Constructor	Description
StreamingWorklogDTORetriever(QueryDslAccessor qdslAccessor, DatabaseAccessor dbAccessor)

Method Summary

Modifier and Type	Method	Description
protected List<WorklogDTO>	getEntitiesBatchByIds(List<Long> idsBatch)	The implementation should return the entities based on provided ids list
protected List<Long>	getEntityIds(String bodySubstring)	The implementation should return all the ids of entities which will be then returned in batches
Stream<List<WorklogDTO>>	stream(String bodySubstring, int batchSize)	Returns stream of batches ActionDTOs whose bodies contain specified text Note that the returned entities are sorted by the id of the issue they belong to

Methods inherited from class java.lang.Object

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

Constructor Details

StreamingWorklogDTORetriever

public StreamingWorklogDTORetriever(QueryDslAccessor qdslAccessor,
 DatabaseAccessor dbAccessor)

Method Details

stream

public Stream<List<WorklogDTO>> stream(String bodySubstring,
 int batchSize)

Description copied from class: BaseStreamingRetriever

Returns stream of batches ActionDTOs whose bodies contain specified text Note that the returned entities are sorted by the id of the issue they belong to

Overrides:

stream in class BaseStreamingRetriever<Long,String,WorklogDTO>

Parameters:

bodySubstring - parameter for the query returning entity ids from the database

batchSize - size of single entity batch to be returned

Returns:

stream containing WorklogDTO batches sorted by their issue id

See Also:

• Note that the returned entities are sorted by the id of the issue they belong to

getEntityIds

protected List<Long> getEntityIds(String bodySubstring)

Description copied from class: BaseStreamingRetriever

The implementation should return all the ids of entities which will be then returned in batches

Specified by:

getEntityIds in class BaseStreamingRetriever<Long,String,WorklogDTO>

Parameters:

bodySubstring - the parameter which is used to find the entities

getEntitiesBatchByIds

protected List<WorklogDTO> getEntitiesBatchByIds(List<Long> idsBatch)

Description copied from class: BaseStreamingRetriever

The implementation should return the entities based on provided ids list

Specified by:

getEntitiesBatchByIds in class BaseStreamingRetriever<Long,String,WorklogDTO>

Parameters:

idsBatch - the batch of ids for the entities to be returned