Package ca.uhn.fhir.batch2.coordinator

Class DefaultJobPartitionProvider

java.lang.Object

ca.uhn.fhir.batch2.coordinator.DefaultJobPartitionProvider

All Implemented Interfaces:

IJobPartitionProvider

public class DefaultJobPartitionProvider
extends Object
implements IJobPartitionProvider

Default implementation which provides the PartitionedUrl list for a certain operation request.

Field Summary

Fields

Modifier and Type	Field	Description
protected ca.uhn.fhir.context.FhirContext	myFhirContext
protected final IRequestPartitionHelperSvc	myRequestPartitionHelper

Constructor Summary

Constructors

Constructor	Description
DefaultJobPartitionProvider(ca.uhn.fhir.context.FhirContext theFhirContext, IRequestPartitionHelperSvc theRequestPartitionHelperSvc, ca.uhn.fhir.jpa.searchparam.MatchUrlService theMatchUrlService)
DefaultJobPartitionProvider(IRequestPartitionHelperSvc theRequestPartitionHelperSvc)

Method Summary

Modifier and Type	Method	Description
List<ca.uhn.fhir.interceptor.model.RequestPartitionId>	getAllPartitions()
List<PartitionedUrl>	getPartitionedUrls(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails, List<String> theUrls)	Provides the list of PartitionedUrl to run job steps against, based on the request that initiates the job and the urls that it's configured with.
List<ca.uhn.fhir.interceptor.model.RequestPartitionId>	getPartitions(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails, String theOperation)	Provides the list of partitions to run job steps against, based on the request that initiates the job.

Methods inherited from class java.lang.Object

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

Field Details

myRequestPartitionHelper

protected final IRequestPartitionHelperSvc myRequestPartitionHelper

myFhirContext

protected ca.uhn.fhir.context.FhirContext myFhirContext

Constructor Details

DefaultJobPartitionProvider

public DefaultJobPartitionProvider(IRequestPartitionHelperSvc theRequestPartitionHelperSvc)

DefaultJobPartitionProvider

public DefaultJobPartitionProvider(ca.uhn.fhir.context.FhirContext theFhirContext,
 IRequestPartitionHelperSvc theRequestPartitionHelperSvc,
 ca.uhn.fhir.jpa.searchparam.MatchUrlService theMatchUrlService)

Method Details

getPartitions

public List<ca.uhn.fhir.interceptor.model.RequestPartitionId> getPartitions(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails,
 String theOperation)

Description copied from interface: IJobPartitionProvider

Provides the list of partitions to run job steps against, based on the request that initiates the job.

Specified by:

getPartitions in interface IJobPartitionProvider

Parameters:

theRequestDetails - the requestDetails

theOperation - the operation being run which corresponds to the job

Returns:

the list of partitions

getPartitionedUrls

public List<PartitionedUrl> getPartitionedUrls(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails,
 List<String> theUrls)

Description copied from interface: IJobPartitionProvider

Provides the list of PartitionedUrl to run job steps against, based on the request that initiates the job and the urls that it's configured with.

Specified by:

getPartitionedUrls in interface IJobPartitionProvider

Parameters:

theRequestDetails - the requestDetails

theUrls - the urls to run the job against

Returns:

the list of PartitionedUrl

getAllPartitions

public List<ca.uhn.fhir.interceptor.model.RequestPartitionId> getAllPartitions()