Package org.apache.beam.sdk.io.gcp.healthcare

Class HL7v2IO.Read.FetchHL7v2Message

java.lang.Object

org.apache.beam.sdk.transforms.PTransform<PCollection<String>,HL7v2IO.Read.Result>

org.apache.beam.sdk.io.gcp.healthcare.HL7v2IO.Read.FetchHL7v2Message

All Implemented Interfaces:

Serializable, HasDisplayData

Enclosing class:

HL7v2IO.Read

public static class HL7v2IO.Read.FetchHL7v2Message
extends PTransform<PCollection<String>,HL7v2IO.Read.Result>

PTransform to fetch a message from an Google Cloud Healthcare HL7v2 store based on msgID.

This DoFn consumes a PCollection of notifications Strings from the HL7v2 store, and fetches the actual HL7v2Message object based on the id in the notification and will output a PCollectionTuple which contains the output and dead-letter PCollection.

The PCollectionTuple output will contain the following PCollection:

• HL7v2IO.Read.OUT - Contains all PCollection records successfully read from the HL7v2 store.
• HL7v2IO.Read.DEAD_LETTER - Contains all PCollection of HealthcareIOError message IDs which failed to be fetched from the HL7v2 store, with error message and stacktrace.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	HL7v2IO.Read.FetchHL7v2Message.HL7v2MessageGetFn	DoFn for fetching messages from the HL7v2 store with error handling.

Field Summary

Fields inherited from class org.apache.beam.sdk.transforms.PTransform

annotations, displayData, name, resourceHints

Constructor Summary

Constructors

Constructor	Description
FetchHL7v2Message()	Instantiates a new Fetch HL7v2 message DoFn.

Method Summary

Modifier and Type	Method	Description
HL7v2IO.Read.Result	expand(PCollection<String> msgIds)	Override this method to specify how this PTransform should be expanded on the given InputT.

Methods inherited from class org.apache.beam.sdk.transforms.PTransform

addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setDisplayData, setResourceHints, toString, validate, validate

Methods inherited from class java.lang.Object

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

Constructor Details

FetchHL7v2Message

public FetchHL7v2Message()

Instantiates a new Fetch HL7v2 message DoFn.

Method Details

expand

public HL7v2IO.Read.Result expand(PCollection<String> msgIds)

Description copied from class: PTransform

Override this method to specify how this PTransform should be expanded on the given InputT.

NOTE: This method should not be called directly. Instead apply the PTransform should be applied to the InputT using the apply method.

Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).

Specified by:

expand in class PTransform<PCollection<String>,HL7v2IO.Read.Result>