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

Class FhirIO.Deidentify.DeidentifyFn

java.lang.Object

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

org.apache.beam.sdk.io.gcp.healthcare.FhirIO.Deidentify.DeidentifyFn

All Implemented Interfaces:

Serializable, HasDisplayData

Enclosing class:

FhirIO.Deidentify

public static class FhirIO.Deidentify.DeidentifyFn
extends DoFn<String,String>

A function that schedules a deidentify 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
DeidentifyFn(ValueProvider<String> destinationFhirStore, ValueProvider<DeidentifyConfig> deidConfig)

Method Summary

Modifier and Type	Method	Description
void	deidentify(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

DeidentifyFn

public DeidentifyFn(ValueProvider<String> destinationFhirStore,
 ValueProvider<DeidentifyConfig> deidConfig)

Method Details

initClient

@Setup
public void initClient()
                throws IOException

Throws:

IOException

deidentify

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

Throws:

IOException

InterruptedException