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

Class FhirIO.Import

java.lang.Object

<any>

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

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

Enclosing class:

FhirIO

public static class FhirIO.Import
extends FhirIO.Write

Writes each bundle of elements to a new-line delimited JSON file on GCS and issues a fhirStores.import Request for that file. This is intended for batch use only to facilitate large backfills to empty FHIR stores and should not be used with unbounded PCollections. If your use case is streaming checkout using FhirIO.ExecuteBundles to more safely execute bundles as transactions which is safer practice for a use on a "live" FHIR store.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FhirIO.Import.ContentStructure The enum Content structure.

Nested classes/interfaces inherited from class org.apache.beam.sdk.io.gcp.healthcare.FhirIO.Write

FhirIO.Write.Result, FhirIO.Write.WriteMethod

Field Summary

Fields inherited from class org.apache.beam.sdk.io.gcp.healthcare.FhirIO.Write

FAILED_BODY, FAILED_FILES, SUCCESSFUL_BODY, TEMP_FILES

Method Summary

Modifier and Type	Method and Description
FhirIO.Write.Result	expand(PCollection<java.lang.String> input)

Methods inherited from class org.apache.beam.sdk.io.gcp.healthcare.FhirIO.Write

executeBundles, executeBundles, fhirStoresImport, fhirStoresImport, fhirStoresImport

Methods inherited from class java.lang.Object

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

Method Detail

expand

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

Overrides:

expand in class FhirIO.Write