honeymoose
/
hapi-fhir
mirror of https://github.com/hapifhir/hapi-fhir.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Hotter docs

This commit is contained in:
Tadgh 2021-03-26 16:00:06 -04:00
parent bee33f763a
commit a3fbd3e1a1
3 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hapi-fhir-jpaserver-base/src/main/java/ca/uhn/fhir/jpa/bulk/job/BulkExportJobConfig.java
View File

@ -161,8 +161,6 @@ public class BulkExportJobConfig {
return myStepBuilderFactory.get("groupBulkExportGenerateResourceFilesStep") return myStepBuilderFactory.get("groupBulkExportGenerateResourceFilesStep")
.<List<ResourcePersistentId>, List<IBaseResource>> chunk(CHUNK_SIZE) //1000 resources per generated file, as the reader returns 10 resources at a time. .<List<ResourcePersistentId>, List<IBaseResource>> chunk(CHUNK_SIZE) //1000 resources per generated file, as the reader returns 10 resources at a time.
.reader(groupBulkItemReader()) .reader(groupBulkItemReader())
// .processor(myPidToIBaseResourceProcessor)
// .processor(myGoldenResourceAnnotatingProcessor)
.processor(inflateResourceThenAnnotateWithGoldenResourceProcessor()) .processor(inflateResourceThenAnnotateWithGoldenResourceProcessor())
.writer(resourceToFileWriter()) .writer(resourceToFileWriter())
.listener(bulkExportGenerateResourceFilesStepListener()) .listener(bulkExportGenerateResourceFilesStepListener())

4
hapi-fhir-jpaserver-base/src/main/java/ca/uhn/fhir/jpa/bulk/job/GroupBulkItemReader.java
View File

@ -237,10 +237,6 @@ public class GroupBulkItemReader extends BaseBulkItemReader implements ItemReade
return expandedIds; return expandedIds;
} }
private void populateMdmResourceCacheIfNeeded(Map<Long, Set<Long>> goldenResourceToSourcePidMap) {
}
private void queryResourceTypeWithReferencesToPatients(Set<ResourcePersistentId> myReadPids, List<String> idChunk) { private void queryResourceTypeWithReferencesToPatients(Set<ResourcePersistentId> myReadPids, List<String> idChunk) {
//Build SP map //Build SP map
//First, inject the _typeFilters and _since from the export job //First, inject the _typeFilters and _since from the export job

7
hapi-fhir-jpaserver-base/src/main/java/ca/uhn/fhir/jpa/dao/mdm/MdmExpansionCacheSvc.java
View File

@ -21,6 +21,13 @@ public class MdmExpansionCacheSvc {
private final ConcurrentHashMap<String, String> mySourceToGoldenIdCache = new ConcurrentHashMap<>(); private final ConcurrentHashMap<String, String> mySourceToGoldenIdCache = new ConcurrentHashMap<>();
/**
* Lookup a given resource's golden resource ID in the cache. Note that if you pass this function the resource ID of a
* golden resource, it will just return itself.
*
* @param theSourceId the resource ID of the source resource ,e.g. PAT123
* @return the resource ID of the associated golden resource.
*/
public String getGoldenResourceId(String theSourceId) { public String getGoldenResourceId(String theSourceId) {
ourLog.debug(buildLogMessage("About to lookup cached resource ID " + theSourceId)); ourLog.debug(buildLogMessage("About to lookup cached resource ID " + theSourceId));
String goldenResourceId = mySourceToGoldenIdCache.get(theSourceId); String goldenResourceId = mySourceToGoldenIdCache.get(theSourceId);