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

Class FhirIO.Write

java.lang.Object

org.apache.beam.sdk.transforms.PTransform<PCollection<java.lang.String>,FhirIO.Write.AbstractResult>

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

All Implemented Interfaces:

java.io.Serializable, HasDisplayData

Direct Known Subclasses:

FhirIO.Import

Enclosing class:

FhirIO

public abstract static class FhirIO.Write
extends PTransform<PCollection<java.lang.String>,FhirIO.Write.AbstractResult>

The type Write.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FhirIO.Write.AbstractResult
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.

Fields inherited from class org.apache.beam.sdk.transforms.PTransform

name, resourceHints

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.AbstractResult	expand(PCollection<java.lang.String> input) Override this method to specify how this PTransform should be expanded on the given InputT.
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 org.apache.beam.sdk.transforms.PTransform

compose, compose, getAdditionalInputs, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setResourceHints, toString, validate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, 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.AbstractResult expand(PCollection<java.lang.String> input)

Description copied from class: PTransform

Override this method to specify how this PTransform should be expanded on the given InputT.

NOTE: This method should not be called directly. Instead apply the PTransform should be applied to the InputT using the apply method.

Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).

Specified by:

expand in class PTransform<PCollection<java.lang.String>,FhirIO.Write.AbstractResult>