public abstract static class FhirIO.Write extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<java.lang.String>,FhirIO.Write.Result>
Modifier and Type | Class and Description |
---|---|
static class |
FhirIO.Write.Result
The type Result.
|
static class |
FhirIO.Write.WriteMethod
The enum Write method.
|
Modifier and Type | Field and Description |
---|---|
static org.apache.beam.sdk.values.TupleTag<HealthcareIOError<java.lang.String>> |
FAILED_BODY
The tag for the failed writes to FHIR store.
|
static org.apache.beam.sdk.values.TupleTag<HealthcareIOError<java.lang.String>> |
FAILED_FILES
The tag for the files that failed to FHIR store.
|
static org.apache.beam.sdk.values.TupleTag<java.lang.String> |
SUCCESSFUL_BODY
The tag for successful writes to FHIR store.
|
static org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.io.fs.ResourceId> |
TEMP_FILES
The tag for temp files for import to FHIR store.
|
Constructor and Description |
---|
Write() |
Modifier and Type | Method and Description |
---|---|
static FhirIO.Write |
executeBundles(java.lang.String fhirStore)
|
static FhirIO.Write |
executeBundles(org.apache.beam.sdk.options.ValueProvider<java.lang.String> fhirStore)
Execute bundles write.
|
FhirIO.Write.Result |
expand(org.apache.beam.sdk.values.PCollection<java.lang.String> input) |
static FhirIO.Write |
fhirStoresImport(java.lang.String fhirStore,
java.lang.String gcsDeadLetterPath,
FhirIO.Import.ContentStructure contentStructure) |
static FhirIO.Write |
fhirStoresImport(java.lang.String fhirStore,
java.lang.String gcsTempPath,
java.lang.String gcsDeadLetterPath,
FhirIO.Import.ContentStructure contentStructure)
Create Method creates a single FHIR resource.
|
static FhirIO.Write |
fhirStoresImport(org.apache.beam.sdk.options.ValueProvider<java.lang.String> fhirStore,
org.apache.beam.sdk.options.ValueProvider<java.lang.String> gcsTempPath,
org.apache.beam.sdk.options.ValueProvider<java.lang.String> gcsDeadLetterPath,
FhirIO.Import.ContentStructure contentStructure) |
public static final org.apache.beam.sdk.values.TupleTag<java.lang.String> SUCCESSFUL_BODY
public static final org.apache.beam.sdk.values.TupleTag<HealthcareIOError<java.lang.String>> FAILED_BODY
public static final org.apache.beam.sdk.values.TupleTag<HealthcareIOError<java.lang.String>> FAILED_FILES
public static final org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.io.fs.ResourceId> TEMP_FILES
public static FhirIO.Write fhirStoresImport(java.lang.String fhirStore, java.lang.String gcsTempPath, java.lang.String gcsDeadLetterPath, FhirIO.Import.ContentStructure contentStructure)
fhirStore
- the hl 7 v 2 storegcsTempPath
- the gcs temp pathgcsDeadLetterPath
- the gcs dead letter pathcontentStructure
- the content structurepublic static FhirIO.Write fhirStoresImport(java.lang.String fhirStore, java.lang.String gcsDeadLetterPath, FhirIO.Import.ContentStructure contentStructure)
public static FhirIO.Write fhirStoresImport(org.apache.beam.sdk.options.ValueProvider<java.lang.String> fhirStore, org.apache.beam.sdk.options.ValueProvider<java.lang.String> gcsTempPath, org.apache.beam.sdk.options.ValueProvider<java.lang.String> gcsDeadLetterPath, FhirIO.Import.ContentStructure contentStructure)
public static FhirIO.Write executeBundles(java.lang.String fhirStore)
fhirStore
- the fhir storepublic static FhirIO.Write executeBundles(org.apache.beam.sdk.options.ValueProvider<java.lang.String> fhirStore)
fhirStore
- the fhir storepublic FhirIO.Write.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.Write.Result>