com.cerner.bunsen.codes.broadcast

Class BroadcastableMappings

java.lang.Object

com.cerner.bunsen.codes.broadcast.BroadcastableMappings

All Implemented Interfaces:

Serializable

public class BroadcastableMappings
extends Object
implements Serializable

Support to broadcast a collection of concept maps to map data transformations.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
static org.apache.spark.broadcast.Broadcast<BroadcastableMappings>	broadcast(ConceptMaps conceptMaps, Map<String,String> conceptMapUriToVersion) Broadcast mappings stored in the given conceptMaps instance that match the given conceptMapUris.
static org.apache.spark.broadcast.Broadcast<BroadcastableMappings>	broadcast(ConceptMaps conceptMaps, Set<String> conceptMapUris, boolean includeExperimental) Broadcast mappings stored in the given conceptMaps instance that match the given conceptMapUris.
static org.apache.spark.broadcast.Broadcast<BroadcastableMappings>	broadcast(org.apache.spark.sql.SparkSession spark, List<org.hl7.fhir.dstu3.model.ConceptMap> conceptMaps) Broadcasts the given set of concept maps.
BroadcastableConceptMap	getBroadcastConceptMap(String conceptMapUri) Returns the broadcastable concept map for the concept map with the given URI.

Methods inherited from class java.lang.Object

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

Method Detail

broadcast

public static org.apache.spark.broadcast.Broadcast<BroadcastableMappings> broadcast(org.apache.spark.sql.SparkSession spark,
                                                                                    List<org.hl7.fhir.dstu3.model.ConceptMap> conceptMaps)

Broadcasts the given set of concept maps.

Parameters:

spark - the spark session.

conceptMaps - the FHIR ConceptMaps to broadcast

Returns:

a broadcast variable containing a mappings object usable in UDFs.

broadcast

public static org.apache.spark.broadcast.Broadcast<BroadcastableMappings> broadcast(ConceptMaps conceptMaps,
                                                                                    Set<String> conceptMapUris,
                                                                                    boolean includeExperimental)

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

Parameters:

conceptMaps - the ConceptMaps instance with the content to broadcast

conceptMapUris - the URIs to broadcast.

includeExperimental - flag to include experimental map versions in the broadcast.

Returns:

a broadcast variable containing a mappings object usable in UDFs.

broadcast

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

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

Parameters:

conceptMaps - the ConceptMaps instance with the content to broadcast

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

Returns:

a broadcast variable containing a mappings object usable in UDFs.

getBroadcastConceptMap

public BroadcastableConceptMap getBroadcastConceptMap(String conceptMapUri)

Returns the broadcastable concept map for the concept map with the given URI.

Parameters:

conceptMapUri - URI of the concept map

Returns:

the broadcastable concept map.