com.atlassian.jira.issue.util.streamingretrievers

Class StreamingGenericConfigurationDTORetriever

java.lang.Object

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

com.atlassian.jira.issue.util.streamingretrievers.StreamingGenericConfigurationDTORetriever

@ParametersAreNonnullByDefault
 @ReturnValuesAreNonnullByDefault
public class StreamingGenericConfigurationDTORetriever
extends BaseStreamingRetriever<Long,String,GenericConfigurationDTO>

Constructor Summary

Constructors

Constructor and Description
StreamingGenericConfigurationDTORetriever(QueryDslAccessor qdslAccessor, DatabaseAccessor dbAccessor)

Method Summary

Modifier and Type	Method and Description
static com.querydsl.sql.SQLQuery<?>	getBaseQuery(DbConnection connection, DatabaseAccessor dbAccessor, String descriptionSubstring)
protected List<GenericConfigurationDTO>	getEntitiesBatchByIds(List<Long> idsBatch) The implementation should return the entities based on provided ids list
protected List<Long>	getEntityIds(String descriptionSubstring) The implementation should return all the ids of entities which will be then returned in batches
java.util.stream.Stream<List<GenericConfigurationDTO>>	stream(String descriptionSubstring, 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 Detail

StreamingGenericConfigurationDTORetriever

public StreamingGenericConfigurationDTORetriever(QueryDslAccessor qdslAccessor,
                                                 DatabaseAccessor dbAccessor)

Method Detail

stream

public java.util.stream.Stream<List<GenericConfigurationDTO>> stream(String descriptionSubstring,
                                                                     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,GenericConfigurationDTO>

Parameters:

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

batchSize - size of single entity batch to be returned

Returns:

stream containing ProjectDTO batches sorted by their project 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 descriptionSubstring)

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,GenericConfigurationDTO>

Parameters:

descriptionSubstring - the parameter which is used to find the entities

getEntitiesBatchByIds

protected List<GenericConfigurationDTO> 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,GenericConfigurationDTO>

Parameters:

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

getBaseQuery

public static com.querydsl.sql.SQLQuery<?> getBaseQuery(DbConnection connection,
                                                        DatabaseAccessor dbAccessor,
                                                        String descriptionSubstring)