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

Class FhirIO.Write

java.lang.Object

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

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

All Implemented Interfaces:

Serializable, HasDisplayData

Direct Known Subclasses:

FhirIO.Import

Enclosing class:

FhirIO

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

The type Write.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

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

Field Summary

Fields

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

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

annotations, displayData, name, resourceHints

Constructor Summary

Constructors

Constructor	Description
Write()

Method Summary

Modifier and Type	Method	Description
static FhirIO.Write	executeBundles(String fhirStore)	Execute Bundle Method executes a batch of requests in batch or as a single transaction @see .
static FhirIO.Write	executeBundles(ValueProvider<String> fhirStore)	Execute Bundle Method executes a batch of requests in batch or as a single transaction @see .
FhirIO.Write.AbstractResult	expand(PCollection<String> input)	Override this method to specify how this PTransform should be expanded on the given InputT.
static FhirIO.Write	fhirStoresImport(String fhirStore, String gcsTempPath, String gcsDeadLetterPath, @Nullable FhirIO.Import.ContentStructure contentStructure)	Import method for batch writing resources.
static FhirIO.Write	fhirStoresImport(String fhirStore, String gcsDeadLetterPath, @Nullable FhirIO.Import.ContentStructure contentStructure)
static FhirIO.Write	fhirStoresImport(ValueProvider<String> fhirStore, ValueProvider<String> gcsTempPath, ValueProvider<String> gcsDeadLetterPath, @Nullable FhirIO.Import.ContentStructure contentStructure)

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

addAnnotation, compose, compose, getAdditionalInputs, getAnnotations, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setDisplayData, setResourceHints, toString, validate, validate

Methods inherited from class java.lang.Object

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

Field Details

SUCCESSFUL_BODY

public static final TupleTag<String> SUCCESSFUL_BODY

The tag for successful writes to FHIR store.

FAILED_BODY

public static final TupleTag<HealthcareIOError<String>> FAILED_BODY

The tag for the failed writes to FHIR store.

FAILED_FILES

public static final TupleTag<HealthcareIOError<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 Details

Write

public Write()

Method Details

fhirStoresImport

public static FhirIO.Write fhirStoresImport(String fhirStore,
 String gcsTempPath,
 String gcsDeadLetterPath,
 @Nullable 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(String fhirStore,
 String gcsDeadLetterPath,
 @Nullable FhirIO.Import.ContentStructure contentStructure)

fhirStoresImport

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

executeBundles

public static FhirIO.Write executeBundles(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<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<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<String>,FhirIO.Write.AbstractResult>