public static class HL7v2IO.Read extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<java.lang.String>,HL7v2IO.Read.Result>
These could be sourced from any PCollection
of String
s but the most popular
patterns would be PubsubIO.readStrings()
reading a subscription on an HL7v2 Store's
notification channel topic or using HL7v2IO.ListHL7v2Messages
to list HL7v2 message IDs with an
optional filter using Ingest write method. @see .
Modifier and Type | Class and Description |
---|---|
static class |
HL7v2IO.Read.FetchHL7v2Message
PTransform to fetch a message from an Google Cloud Healthcare HL7v2 store based on
msgID. |
static class |
HL7v2IO.Read.Result |
Modifier and Type | Field and Description |
---|---|
static org.apache.beam.sdk.values.TupleTag<HealthcareIOError<java.lang.String>> |
DEAD_LETTER
The tag for the deadletter output of HL7v2 Messages.
|
static org.apache.beam.sdk.values.TupleTag<HL7v2Message> |
OUT
The tag for the main output of HL7v2 Messages.
|
Constructor and Description |
---|
Read() |
Modifier and Type | Method and Description |
---|---|
HL7v2IO.Read.Result |
expand(org.apache.beam.sdk.values.PCollection<java.lang.String> input) |
public static final org.apache.beam.sdk.values.TupleTag<HL7v2Message> OUT
public static final org.apache.beam.sdk.values.TupleTag<HealthcareIOError<java.lang.String>> DEAD_LETTER
public HL7v2IO.Read.Result expand(org.apache.beam.sdk.values.PCollection<java.lang.String> input)
expand
in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<java.lang.String>,HL7v2IO.Read.Result>