public static class FhirIO.Read extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<java.lang.String>,FhirIO.Read.Result>
Modifier and Type | Class and Description |
---|---|
static class |
FhirIO.Read.Result
The type 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 Fhir Messages.
|
static org.apache.beam.sdk.values.TupleTag<java.lang.String> |
OUT
The tag for the main output of Fhir Messages.
|
Constructor and Description |
---|
Read()
Instantiates a new Read.
|
Modifier and Type | Method and Description |
---|---|
FhirIO.Read.Result |
expand(org.apache.beam.sdk.values.PCollection<java.lang.String> input) |
public static final org.apache.beam.sdk.values.TupleTag<java.lang.String> OUT
public static final org.apache.beam.sdk.values.TupleTag<HealthcareIOError<java.lang.String>> DEAD_LETTER
public FhirIO.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>,FhirIO.Read.Result>