public static class HL7v2IO.HL7v2Read extends PTransform<PCollection<HL7v2ReadParameter>,HL7v2IO.HL7v2Read.Result>
HL7v2ReadParameter
.Modifier and Type | Class and Description |
---|---|
static class |
HL7v2IO.HL7v2Read.FetchHL7v2Message
PTransform to fetch a message from an Google Cloud Healthcare HL7v2 store based on
msgID. |
static class |
HL7v2IO.HL7v2Read.Result
The type Result includes
PCollection of HL7v2ReadResponse objects for
successfully read results and PCollection of HealthcareIOError objects for
failed reads. |
Modifier and Type | Field and Description |
---|---|
static TupleTag<HealthcareIOError<HL7v2ReadParameter>> |
DEAD_LETTER
The tag for the deadletter output of HL7v2 read responses.
|
static TupleTag<HL7v2ReadResponse> |
OUT
The tag for the main output of HL7v2 read responses.
|
annotations, displayData, name, resourceHints
Constructor and Description |
---|
HL7v2Read() |
Modifier and Type | Method and Description |
---|---|
HL7v2IO.HL7v2Read.Result |
expand(PCollection<HL7v2ReadParameter> input)
Override this method to specify how this
PTransform should be expanded on the given
InputT . |
addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setDisplayData, setResourceHints, toString, validate, validate
public static final TupleTag<HL7v2ReadResponse> OUT
public static final TupleTag<HealthcareIOError<HL7v2ReadParameter>> DEAD_LETTER
public HL7v2IO.HL7v2Read.Result expand(PCollection<HL7v2ReadParameter> input)
PTransform
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).
expand
in class PTransform<PCollection<HL7v2ReadParameter>,HL7v2IO.HL7v2Read.Result>