Package org.apache.beam.sdk.io.gcp.healthcare
package org.apache.beam.sdk.io.gcp.healthcare
Provides an API for reading from and writing to Google Cloud Datastore over different
versions of the Cloud Datastore Client libraries.
-
ClassDescriptionThe DicomIO connectors allows Beam pipelines to make calls to the Dicom API of the Google Cloud Healthcare API (https://cloud.google.com/healthcare/docs/how-tos#dicom-guide).This class makes a call to the retrieve metadata endpoint (https://cloud.google.com/healthcare/docs/how-tos/dicomweb#retrieving_metadata).FhirBundleParameter represents a FHIR bundle in JSON format to be executed on a FHIR store.
FhirIOprovides an API for reading and writing resources to Google Cloud Healthcare Fhir API.Deidentify FHIR resources from a FHIR store to a destination FHIR store.A function that schedules a deidentify operation and monitors the status.The type Execute bundles.ExecuteBundlesResult contains both successfully executed bundles and information help debugging failed executions (eg metadata invalid input: '&' error msgs).Export FHIR resources from a FHIR store to new line delimited json files on GCS or BigQuery.A function that schedules an export operation and monitors the status.Writes each bundle of elements to a new-line delimited JSON file on GCS and issues a fhirStores.import Request for that file.The enum Content structure.The type Read.The type Result.The type Search.The type Write.The type Result.The enum Write method.The type FhirIOPatientEverything for querying a FHIR Patient resource's compartment.PatientEverythingParameter defines required attributes for a FHIR GetPatientEverything request inFhirIOPatientEverything.The Result for aFhirIOPatientEverythingrequest.FhirSearchParameter represents the query parameters for a FHIR search request, used as a parameter forFhirIO.Search.FhirSearchParameterCoder is the coder forFhirSearchParameter, which takes a coder for type T.Defines a client to communicate with the GCP HCLS API (version v1).Class for capturing errors on IO operations on Google Cloud Healthcare APIs resources.Convenience transform to write dead-letterHealthcareIOErrors to BigQueryTableRows.HL7v2IOprovides an API for reading from and writing to Google Cloud Healthcare HL7v2 API.The type Read that reads HL7v2 message contents given a PCollection ofHL7v2ReadParameter.PTransformto fetch a message from an Google Cloud Healthcare HL7v2 store based on msgID.DoFn for fetching messages from the HL7v2 store with error handling.The type Result includesPCollectionofHL7v2ReadResponseobjects for successfully read results andPCollectionofHealthcareIOErrorobjects for failed reads.List HL7v2 messages in HL7v2 Stores with optional filter.The type Read that reads HL7v2 message contents given a PCollection of message IDs strings.PTransformto fetch a message from an Google Cloud Healthcare HL7v2 store based on msgID.DoFn for fetching messages from the HL7v2 store with error handling.The type Result includesPCollectionofHL7v2Messageobjects for successfully read results andPCollectionofHealthcareIOErrorobjects for failed reads.The type Write that writes the given PCollection of HL7v2 messages.The enum Write method.The type HL7v2 message to wrap theMessagemodel.HL7v2ReadParameter represents the read parameters for a HL7v2 read request, used as the input type forHL7v2IO.HL7v2Read.HL7v2ReadResponse represents the response format for a HL7v2 read request, used as the output type ofHL7v2IO.HL7v2Read.Coder forHL7v2ReadResponse.A client that talks to the Cloud Healthcare API through HTTP requests.The type FhirResourcePagesIterator for methods which return paged output.WrapsHttpResponsein an exception with a statusCode field for use withHealthcareIOError.The type Hl7v2 message id pages iterator.