org.apache.beam.sdk.io.gcp.healthcare

Class FhirIO.Write

java.lang.Object

<any>

org.apache.beam.sdk.io.gcp.healthcare.FhirIO.Write

Direct Known Subclasses:

FhirIO.ExecuteBundles, FhirIO.Import

Enclosing class:

FhirIO

public abstract static class FhirIO.Write
extends <any>

The type Write.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FhirIO.Write.Result The type Result.
static class	FhirIO.Write.WriteMethod The enum Write method.

Field Summary

Fields

Modifier and Type	Field and Description
static TupleTag<HealthcareIOError<java.lang.String>>	FAILED_BODY The tag for the failed writes to FHIR store.
static TupleTag<HealthcareIOError<java.lang.String>>	FAILED_FILES The tag for the files that failed to FHIR store.
static TupleTag<java.lang.String>	SUCCESSFUL_BODY The tag for successful writes to FHIR store.
static TupleTag<ResourceId>	TEMP_FILES The tag for temp files for import to FHIR store.

Constructor Summary

Constructors

Constructor and Description
Write()

Method Summary

Modifier and Type	Method and Description
static FhirIO.Write	executeBundles(java.lang.String fhirStore) Execute Bundle Method executes a batch of requests in batch or as a single transaction @see .
static FhirIO.Write	executeBundles(ValueProvider<java.lang.String> fhirStore) Execute Bundle Method executes a batch of requests in batch or as a single transaction @see .
FhirIO.Write.Result	expand(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) Import method for batch writing resources.
static FhirIO.Write	fhirStoresImport(ValueProvider<java.lang.String> fhirStore, ValueProvider<java.lang.String> gcsTempPath, ValueProvider<java.lang.String> gcsDeadLetterPath, FhirIO.Import.ContentStructure contentStructure)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SUCCESSFUL_BODY

public static final TupleTag<java.lang.String> SUCCESSFUL_BODY

The tag for successful writes to FHIR store.

FAILED_BODY

public static final TupleTag<HealthcareIOError<java.lang.String>> FAILED_BODY

The tag for the failed writes to FHIR store.

FAILED_FILES

public static final TupleTag<HealthcareIOError<java.lang.String>> FAILED_FILES

The tag for the files that failed to FHIR store.

TEMP_FILES

public static final TupleTag<ResourceId> TEMP_FILES

The tag for temp files for import to FHIR store.

Constructor Detail

Write

public Write()

Method Detail

fhirStoresImport

public static FhirIO.Write fhirStoresImport(java.lang.String fhirStore,
                                            java.lang.String gcsTempPath,
                                            java.lang.String gcsDeadLetterPath,
                                            FhirIO.Import.ContentStructure contentStructure)

Import method for batch writing resources. @see

Parameters:

fhirStore - the FHIR store

gcsTempPath - the gcs temp path

gcsDeadLetterPath - the gcs dead letter path

contentStructure - the content structure

Returns:

the write

fhirStoresImport

public static FhirIO.Write fhirStoresImport(java.lang.String fhirStore,
                                            java.lang.String gcsDeadLetterPath,
                                            FhirIO.Import.ContentStructure contentStructure)

fhirStoresImport

public static FhirIO.Write fhirStoresImport(ValueProvider<java.lang.String> fhirStore,
                                            ValueProvider<java.lang.String> gcsTempPath,
                                            ValueProvider<java.lang.String> gcsDeadLetterPath,
                                            FhirIO.Import.ContentStructure contentStructure)

executeBundles

public static FhirIO.Write executeBundles(java.lang.String fhirStore)

Execute Bundle Method executes a batch of requests in batch or as a single transaction @see .

Parameters:

fhirStore - the fhir store

Returns:

the write

executeBundles

public static FhirIO.Write executeBundles(ValueProvider<java.lang.String> fhirStore)

Execute Bundle Method executes a batch of requests in batch or as a single transaction @see .

Parameters:

fhirStore - the fhir store

Returns:

the write

expand

public FhirIO.Write.Result expand(PCollection<java.lang.String> input)