com.cerner.bunsen.stu3.codes

Class ConceptMaps

java.lang.Object

com.cerner.bunsen.spark.codes.base.AbstractConceptMaps<org.hl7.fhir.dstu3.model.ConceptMap,ConceptMaps>

com.cerner.bunsen.stu3.codes.ConceptMaps

public class ConceptMaps
extends AbstractConceptMaps<org.hl7.fhir.dstu3.model.ConceptMap,ConceptMaps>

An immutable collection of FHIR ConceptMaps. This class is used to import concept map content, explore it, and persist it to a database.

Field Summary

Fields inherited from class com.cerner.bunsen.spark.codes.base.AbstractConceptMaps

CONCEPT_MAP_TABLE, conceptMapRowConverter, conceptMaps, fhirVersion, MAPPING_DATABASE, MAPPING_ENCODER, MAPPING_TABLE, mappings, members, spark, TABLE_NAME_PATTERN, URL_AND_VERSION_ENCODER

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ConceptMaps(org.apache.spark.sql.SparkSession spark, org.apache.spark.sql.Dataset<UrlAndVersion> members, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> conceptMaps, org.apache.spark.sql.Dataset<Mapping> mappings)

Method Summary

Modifier and Type	Method and Description
protected void	addToConceptMap(org.hl7.fhir.dstu3.model.ConceptMap map, org.apache.spark.sql.Dataset<Mapping> mappings) Adds the given mappings to the concept map.
org.apache.spark.broadcast.Broadcast<BroadcastableMappings>	broadcast(Map<String,String> conceptMapUriToVersion) Broadcast mappings stored in the given conceptMaps instance that match the given conceptMapUris.
static List<Mapping>	expandMappings(org.hl7.fhir.dstu3.model.ConceptMap map) Given a concept map, returns a list of mapping records it contains.
static SparkRowConverter	getConceptMapConverter() Returns the encoder for concept maps.
static ConceptMaps	getDefault(org.apache.spark.sql.SparkSession spark) Returns the collection of concept maps from the default database and tables.
static ConceptMaps	getEmpty(org.apache.spark.sql.SparkSession spark) Returns an empty ConceptMaps instance.
static ConceptMaps	getFromDatabase(org.apache.spark.sql.SparkSession spark, String databaseName) Returns the collection of concept maps from the tables in the given database.
static org.apache.spark.sql.Encoder<Mapping>	getMappingEncoder() Returns the encoder for mappings.
protected ConceptMaps	newInstance(org.apache.spark.sql.SparkSession spark, org.apache.spark.sql.Dataset<UrlAndVersion> members, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> conceptMaps, org.apache.spark.sql.Dataset<Mapping> mappings) Returns a new instance of this ConceptMaps type with the given parameters.
ConceptMaps	withConceptMaps(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> conceptMaps) Returns a new ConceptMaps instance that includes the given maps.

Methods inherited from class com.cerner.bunsen.spark.codes.base.AbstractConceptMaps

broadcast, getConceptMap, getLatestMappings, getLatestVersions, getLatestVersions, getMappings, getMappings, getMappings, getMaps, getUrlAndVersionEncoder, getUrlAndVersions, hasDuplicateUrlAndVersions, withConceptMaps, withConceptMaps, withConceptMaps, withDisjointMapsFromDirectory, withDisjointMapsFromDirectory, withExpandedMap, withMapsFromDirectory, writeToDatabase, writeToTables

Methods inherited from class java.lang.Object

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

Constructor Detail

ConceptMaps

protected ConceptMaps(org.apache.spark.sql.SparkSession spark,
                      org.apache.spark.sql.Dataset<UrlAndVersion> members,
                      org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> conceptMaps,
                      org.apache.spark.sql.Dataset<Mapping> mappings)

Method Detail

getMappingEncoder

public static org.apache.spark.sql.Encoder<Mapping> getMappingEncoder()

Returns the encoder for mappings.

Returns:

an encoder for mappings.

getConceptMapConverter

public static SparkRowConverter getConceptMapConverter()

Returns the encoder for concept maps.

Returns:

an encoder for concept maps.

newInstance

protected ConceptMaps newInstance(org.apache.spark.sql.SparkSession spark,
                                  org.apache.spark.sql.Dataset<UrlAndVersion> members,
                                  org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> conceptMaps,
                                  org.apache.spark.sql.Dataset<Mapping> mappings)

Description copied from class: AbstractConceptMaps

Returns a new instance of this ConceptMaps type with the given parameters.

Specified by:

newInstance in class AbstractConceptMaps<org.hl7.fhir.dstu3.model.ConceptMap,ConceptMaps>

Parameters:

spark - the spark session

members - Concept map URL and version details

conceptMaps - the concept maps to include

mappings - the mappings themselves

Returns:

a new ConceptMaps instance.

getDefault

public static ConceptMaps getDefault(org.apache.spark.sql.SparkSession spark)

Returns the collection of concept maps from the default database and tables.

Parameters:

spark - the spark session

Returns:

a ConceptMaps instance.

getFromDatabase

public static ConceptMaps getFromDatabase(org.apache.spark.sql.SparkSession spark,
                                          String databaseName)

Returns the collection of concept maps from the tables in the given database.

Parameters:

spark - the spark session

databaseName - name of the database containing the conceptmaps and mappings tables.

Returns:

a ConceptMaps instance.

getEmpty

public static ConceptMaps getEmpty(org.apache.spark.sql.SparkSession spark)

Returns an empty ConceptMaps instance.

Parameters:

spark - the spark session

Returns:

an empty ConceptMaps instance.

addToConceptMap

protected void addToConceptMap(org.hl7.fhir.dstu3.model.ConceptMap map,
                               org.apache.spark.sql.Dataset<Mapping> mappings)

Description copied from class: AbstractConceptMaps

Adds the given mappings to the concept map.

Specified by:

addToConceptMap in class AbstractConceptMaps<org.hl7.fhir.dstu3.model.ConceptMap,ConceptMaps>

Parameters:

map - the concept map

mappings - the mappings to add

expandMappings

public static List<Mapping> expandMappings(org.hl7.fhir.dstu3.model.ConceptMap map)

Given a concept map, returns a list of mapping records it contains.

Parameters:

map - a concept map

Returns:

a list of Mapping records.

withConceptMaps

public ConceptMaps withConceptMaps(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> conceptMaps)

Description copied from class: AbstractConceptMaps

Returns a new ConceptMaps instance that includes the given maps.

Specified by:

withConceptMaps in class AbstractConceptMaps<org.hl7.fhir.dstu3.model.ConceptMap,ConceptMaps>

Parameters:

conceptMaps - concept maps to add to the returned collection.

Returns:

a new ConceptMaps instance with the values added.

broadcast

public org.apache.spark.broadcast.Broadcast<BroadcastableMappings> broadcast(Map<String,String> conceptMapUriToVersion)

Description copied from class: AbstractConceptMaps

Broadcast mappings stored in the given conceptMaps instance that match the given conceptMapUris.

Specified by:

broadcast in class AbstractConceptMaps<org.hl7.fhir.dstu3.model.ConceptMap,ConceptMaps>

Parameters:

conceptMapUriToVersion - map of the concept map URIs to broadcast to their versions.

Returns:

a broadcast variable containing a mappings object usable in UDFs.