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

Class FhirIO.Export.ExportResourcesFn

java.lang.Object

org.apache.beam.sdk.transforms.DoFn<String,String>

org.apache.beam.sdk.io.gcp.healthcare.FhirIO.Export.ExportResourcesFn

All Implemented Interfaces:

Serializable, HasDisplayData

Enclosing class:

FhirIO.Export

public static class FhirIO.Export.ExportResourcesFn
extends DoFn<String,String>

A function that schedules an export operation and monitors the status.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.sdk.transforms.DoFn

DoFn.AlwaysFetched, DoFn.BoundedPerElement, DoFn.BundleFinalizer, DoFn.Element, DoFn.FieldAccess, DoFn.FinishBundle, DoFn.FinishBundleContext, DoFn.GetInitialRestriction, DoFn.GetInitialWatermarkEstimatorState, DoFn.GetRestrictionCoder, DoFn.GetSize, DoFn.GetWatermarkEstimatorStateCoder, DoFn.Key, DoFn.MultiOutputReceiver, DoFn.NewTracker, DoFn.NewWatermarkEstimator, DoFn.OnTimer, DoFn.OnTimerContext, DoFn.OnTimerFamily, DoFn.OnWindowExpiration, DoFn.OnWindowExpirationContext, DoFn.OutputReceiver<T>, DoFn.ProcessContext, DoFn.ProcessContinuation, DoFn.ProcessElement, DoFn.RequiresStableInput, DoFn.RequiresTimeSortedInput, DoFn.Restriction, DoFn.Setup, DoFn.SideInput, DoFn.SplitRestriction, DoFn.StartBundle, DoFn.StartBundleContext, DoFn.StateId, DoFn.Teardown, DoFn.TimerFamily, DoFn.TimerId, DoFn.Timestamp, DoFn.TruncateRestriction, DoFn.UnboundedPerElement, DoFn.WatermarkEstimatorState, DoFn.WindowedContext

Constructor Summary

Constructors

Constructor	Description
ExportResourcesFn(ValueProvider<String> exportUri)

Method Summary

Modifier and Type	Method	Description
void	exportResources(DoFn<String,String>.ProcessContext context)
void	initClient()

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

getAllowedTimestampSkew, getInputTypeDescriptor, getOutputTypeDescriptor, populateDisplayData, prepareForProcessing

Methods inherited from class java.lang.Object

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

Constructor Details

ExportResourcesFn

public ExportResourcesFn(ValueProvider<String> exportUri)

Method Details

initClient

@Setup
public void initClient()
                throws IOException

Throws:

IOException

exportResources

@ProcessElement
public void exportResources(DoFn<String,String>.ProcessContext context)
                     throws IOException,
InterruptedException

Throws:

IOException

InterruptedException