public static class FhirIO.ExecuteBundles extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<FhirBundleParameter>,FhirIO.ExecuteBundlesResult>
Modifier and Type | Field and Description |
---|---|
static org.apache.beam.sdk.values.TupleTag<HealthcareIOError<FhirBundleParameter>> |
FAILED_BUNDLES
The TupleTag used for bundles that failed to be executed for any reason.
|
static org.apache.beam.sdk.values.TupleTag<FhirBundleResponse> |
SUCCESSFUL_BUNDLES
The TupleTag used for bundles that were executed successfully.
|
Constructor and Description |
---|
ExecuteBundles(java.lang.String fhirStore) |
ExecuteBundles(org.apache.beam.sdk.options.ValueProvider<java.lang.String> fhirStore)
Instantiates a new Execute bundles.
|
Modifier and Type | Method and Description |
---|---|
FhirIO.ExecuteBundlesResult |
expand(org.apache.beam.sdk.values.PCollection<FhirBundleParameter> input) |
org.apache.beam.sdk.options.ValueProvider<java.lang.String> |
getFhirStore() |
addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setResourceHints, toString, validate, validate
public static final org.apache.beam.sdk.values.TupleTag<FhirBundleResponse> SUCCESSFUL_BUNDLES
public static final org.apache.beam.sdk.values.TupleTag<HealthcareIOError<FhirBundleParameter>> FAILED_BUNDLES
public ExecuteBundles(org.apache.beam.sdk.options.ValueProvider<java.lang.String> fhirStore)
fhirStore
- the fhir storepublic ExecuteBundles(java.lang.String fhirStore)
public org.apache.beam.sdk.options.ValueProvider<java.lang.String> getFhirStore()
public FhirIO.ExecuteBundlesResult expand(org.apache.beam.sdk.values.PCollection<FhirBundleParameter> input)
expand
in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<FhirBundleParameter>,FhirIO.ExecuteBundlesResult>