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

Class HttpHealthcareApiClient

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, HealthcareApiClient

public class HttpHealthcareApiClient
extends java.lang.Object
implements HealthcareApiClient, java.io.Serializable

A client that talks to the Cloud Healthcare API through HTTP requests. This client is created mainly to encapsulate the unserializable dependencies, since most generated classes are not serializable in the HTTP client.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HttpHealthcareApiClient.AuthenticatedRetryInitializer
static class	HttpHealthcareApiClient.HealthcareHttpException Wraps HttpResponse in an exception with a statusCode field for use with HealthcareIOError.
static class	HttpHealthcareApiClient.HL7v2MessagePages

Constructor Summary

Constructors

Constructor and Description
HttpHealthcareApiClient() Instantiates a new Http healthcare api client.
HttpHealthcareApiClient(com.google.api.services.healthcare.v1beta1.CloudHealthcare client) Instantiates a new Http healthcare api client.

Method Summary

Modifier and Type	Method and Description
com.google.api.services.healthcare.v1beta1.model.FhirStore	createFhirStore(java.lang.String dataset, java.lang.String name, java.lang.String version)
com.google.api.services.healthcare.v1beta1.model.FhirStore	createFhirStore(java.lang.String dataset, java.lang.String name, java.lang.String version, java.lang.String pubsubTopic)
com.google.api.services.healthcare.v1beta1.model.Message	createHL7v2Message(java.lang.String hl7v2Store, com.google.api.services.healthcare.v1beta1.model.Message msg) Create hl 7 v 2 message message.
com.google.api.services.healthcare.v1beta1.model.Hl7V2Store	createHL7v2Store(java.lang.String dataset, java.lang.String name) Create hl 7 v 2 store hl 7 v 2 store.
com.google.api.services.healthcare.v1beta1.model.Empty	deleteFhirStore(java.lang.String name)
com.google.api.services.healthcare.v1beta1.model.Empty	deleteHL7v2Message(java.lang.String msgName) Delete hl 7 v 2 message empty.
com.google.api.services.healthcare.v1beta1.model.Empty	deleteHL7v2Store(java.lang.String name) Delete hl 7 v 2 store empty.
com.google.api.services.healthcare.v1beta1.model.HttpBody	executeFhirBundle(java.lang.String fhirStore, java.lang.String bundle) Execute fhir bundle http body.
Instant	getEarliestHL7v2SendTime(java.lang.String hl7v2Store, java.lang.String filter) Gets earliest hl 7 v 2 send time.
com.google.api.services.healthcare.v1beta1.model.Message	getHL7v2Message(java.lang.String msgName) Gets HL7v2 message.
com.google.api.services.healthcare.v1beta1.model.Hl7V2Store	getHL7v2Store(java.lang.String storeName) Gets HL7v2 store.
JsonFactory	getJsonFactory()
Instant	getLatestHL7v2SendTime(java.lang.String hl7v2Store, java.lang.String filter)
com.google.api.services.healthcare.v1beta1.model.Operation	importFhirResource(java.lang.String fhirStore, java.lang.String gcsSourcePath, java.lang.String contentStructure)
com.google.api.services.healthcare.v1beta1.model.IngestMessageResponse	ingestHL7v2Message(java.lang.String hl7v2Store, com.google.api.services.healthcare.v1beta1.model.Message msg) Ingest hl 7 v 2 message ingest message response.
com.google.api.services.healthcare.v1beta1.model.ListMessagesResponse	makeHL7v2ListRequest(java.lang.String hl7v2Store, java.lang.String filter, java.lang.String orderBy, java.lang.String pageToken) Make hl 7 v 2 list request list messages response.
com.google.api.services.healthcare.v1beta1.model.ListMessagesResponse	makeSendTimeBoundHL7v2ListRequest(java.lang.String hl7v2Store, Instant start, Instant end, java.lang.String otherFilter, java.lang.String orderBy, java.lang.String pageToken) Make send time bound hl 7 v 2 list request.
com.google.api.services.healthcare.v1beta1.model.Operation	pollOperation(com.google.api.services.healthcare.v1beta1.model.Operation operation, java.lang.Long sleepMs)
com.google.api.services.healthcare.v1beta1.model.HttpBody	readFhirResource(java.lang.String resourceId) Read fhir resource http body.

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpHealthcareApiClient

public HttpHealthcareApiClient()
                        throws java.io.IOException

Instantiates a new Http healthcare api client.

Throws:

java.io.IOException - the io exception

HttpHealthcareApiClient

public HttpHealthcareApiClient(com.google.api.services.healthcare.v1beta1.CloudHealthcare client)
                        throws java.io.IOException

Instantiates a new Http healthcare api client.

Parameters:

client - the client

Throws:

java.io.IOException - the io exception

Method Detail

getJsonFactory

public JsonFactory getJsonFactory()

createHL7v2Store

public com.google.api.services.healthcare.v1beta1.model.Hl7V2Store createHL7v2Store(java.lang.String dataset,
                                                                                    java.lang.String name)
                                                                             throws java.io.IOException

Description copied from interface: HealthcareApiClient

Create hl 7 v 2 store hl 7 v 2 store.

Specified by:

createHL7v2Store in interface HealthcareApiClient

Parameters:

dataset - the dataset

name - the name

Returns:

the hl 7 v 2 store

Throws:

java.io.IOException - the io exception

createFhirStore

public com.google.api.services.healthcare.v1beta1.model.FhirStore createFhirStore(java.lang.String dataset,
                                                                                  java.lang.String name,
                                                                                  java.lang.String version)
                                                                           throws java.io.IOException

Specified by:

createFhirStore in interface HealthcareApiClient

Throws:

java.io.IOException

createFhirStore

public com.google.api.services.healthcare.v1beta1.model.FhirStore createFhirStore(java.lang.String dataset,
                                                                                  java.lang.String name,
                                                                                  java.lang.String version,
                                                                                  @Nullable
                                                                                  java.lang.String pubsubTopic)
                                                                           throws java.io.IOException

Specified by:

createFhirStore in interface HealthcareApiClient

Throws:

java.io.IOException

deleteHL7v2Store

public com.google.api.services.healthcare.v1beta1.model.Empty deleteHL7v2Store(java.lang.String name)
                                                                        throws java.io.IOException

Description copied from interface: HealthcareApiClient

Delete hl 7 v 2 store empty.

Specified by:

deleteHL7v2Store in interface HealthcareApiClient

Parameters:

name - the store

Returns:

the empty

Throws:

java.io.IOException - the io exception

deleteFhirStore

public com.google.api.services.healthcare.v1beta1.model.Empty deleteFhirStore(java.lang.String name)
                                                                       throws java.io.IOException

Specified by:

deleteFhirStore in interface HealthcareApiClient

Throws:

java.io.IOException

getEarliestHL7v2SendTime

public Instant getEarliestHL7v2SendTime(java.lang.String hl7v2Store,
                                        @Nullable
                                        java.lang.String filter)
                                 throws java.io.IOException

Description copied from interface: HealthcareApiClient

Gets earliest hl 7 v 2 send time.

Specified by:

getEarliestHL7v2SendTime in interface HealthcareApiClient

Parameters:

hl7v2Store - the hl 7 v 2 store

filter - the filter

Returns:

the earliest hl 7 v 2 send time

Throws:

java.io.IOException - the io exception

getLatestHL7v2SendTime

public Instant getLatestHL7v2SendTime(java.lang.String hl7v2Store,
                                      @Nullable
                                      java.lang.String filter)
                               throws java.io.IOException

Specified by:

getLatestHL7v2SendTime in interface HealthcareApiClient

Throws:

java.io.IOException

makeSendTimeBoundHL7v2ListRequest

public com.google.api.services.healthcare.v1beta1.model.ListMessagesResponse makeSendTimeBoundHL7v2ListRequest(java.lang.String hl7v2Store,
                                                                                                               Instant start,
                                                                                                               @Nullable
                                                                                                               Instant end,
                                                                                                               @Nullable
                                                                                                               java.lang.String otherFilter,
                                                                                                               @Nullable
                                                                                                               java.lang.String orderBy,
                                                                                                               @Nullable
                                                                                                               java.lang.String pageToken)
                                                                                                        throws java.io.IOException

Description copied from interface: HealthcareApiClient

Make send time bound hl 7 v 2 list request.

Specified by:

makeSendTimeBoundHL7v2ListRequest in interface HealthcareApiClient

Parameters:

hl7v2Store - the hl 7 v 2 store

start - the start

end - the end

otherFilter - the other filter

orderBy - the order by

pageToken - the page token

Returns:

the list messages response

Throws:

java.io.IOException - the io exception

makeHL7v2ListRequest

public com.google.api.services.healthcare.v1beta1.model.ListMessagesResponse makeHL7v2ListRequest(java.lang.String hl7v2Store,
                                                                                                  @Nullable
                                                                                                  java.lang.String filter,
                                                                                                  @Nullable
                                                                                                  java.lang.String orderBy,
                                                                                                  @Nullable
                                                                                                  java.lang.String pageToken)
                                                                                           throws java.io.IOException

Description copied from interface: HealthcareApiClient

Make hl 7 v 2 list request list messages response.

Specified by:

makeHL7v2ListRequest in interface HealthcareApiClient

Parameters:

hl7v2Store - the hl 7 v 2 store

filter - the filter

orderBy - the order by

pageToken - the page token

Returns:

the list messages response

Throws:

java.io.IOException - the io exception

getHL7v2Message

public com.google.api.services.healthcare.v1beta1.model.Message getHL7v2Message(java.lang.String msgName)
                                                                         throws java.io.IOException

Gets HL7v2 message.

Specified by:

getHL7v2Message in interface HealthcareApiClient

Parameters:

msgName - the msg name

Returns:

the message

Throws:

java.io.IOException - the io exception

java.text.ParseException - the parse exception

deleteHL7v2Message

public com.google.api.services.healthcare.v1beta1.model.Empty deleteHL7v2Message(java.lang.String msgName)
                                                                          throws java.io.IOException

Description copied from interface: HealthcareApiClient

Delete hl 7 v 2 message empty.

Specified by:

deleteHL7v2Message in interface HealthcareApiClient

Parameters:

msgName - the msg name

Returns:

the empty

Throws:

java.io.IOException - the io exception

getHL7v2Store

public com.google.api.services.healthcare.v1beta1.model.Hl7V2Store getHL7v2Store(java.lang.String storeName)
                                                                          throws java.io.IOException

Gets HL7v2 store.

Specified by:

getHL7v2Store in interface HealthcareApiClient

Parameters:

storeName - the store name

Returns:

the HL7v2 store

Throws:

java.io.IOException - the io exception

ingestHL7v2Message

public com.google.api.services.healthcare.v1beta1.model.IngestMessageResponse ingestHL7v2Message(java.lang.String hl7v2Store,
                                                                                                 com.google.api.services.healthcare.v1beta1.model.Message msg)
                                                                                          throws java.io.IOException

Description copied from interface: HealthcareApiClient

Ingest hl 7 v 2 message ingest message response.

Specified by:

ingestHL7v2Message in interface HealthcareApiClient

Parameters:

hl7v2Store - the hl 7 v 2 store

msg - the msg

Returns:

the ingest message response

Throws:

java.io.IOException - the io exception

createHL7v2Message

public com.google.api.services.healthcare.v1beta1.model.Message createHL7v2Message(java.lang.String hl7v2Store,
                                                                                   com.google.api.services.healthcare.v1beta1.model.Message msg)
                                                                            throws java.io.IOException

Description copied from interface: HealthcareApiClient

Create hl 7 v 2 message message.

Specified by:

createHL7v2Message in interface HealthcareApiClient

Parameters:

hl7v2Store - the hl 7 v 2 store

msg - the msg

Returns:

the message

Throws:

java.io.IOException - the io exception

importFhirResource

public com.google.api.services.healthcare.v1beta1.model.Operation importFhirResource(java.lang.String fhirStore,
                                                                                     java.lang.String gcsSourcePath,
                                                                                     @Nullable
                                                                                     java.lang.String contentStructure)
                                                                              throws java.io.IOException

Specified by:

importFhirResource in interface HealthcareApiClient

Throws:

java.io.IOException

pollOperation

public com.google.api.services.healthcare.v1beta1.model.Operation pollOperation(com.google.api.services.healthcare.v1beta1.model.Operation operation,
                                                                                java.lang.Long sleepMs)
                                                                         throws java.lang.InterruptedException,
                                                                                java.io.IOException

Specified by:

pollOperation in interface HealthcareApiClient

Throws:

java.lang.InterruptedException

java.io.IOException

executeFhirBundle

public com.google.api.services.healthcare.v1beta1.model.HttpBody executeFhirBundle(java.lang.String fhirStore,
                                                                                   java.lang.String bundle)
                                                                            throws java.io.IOException,
                                                                                   HttpHealthcareApiClient.HealthcareHttpException

Description copied from interface: HealthcareApiClient

Execute fhir bundle http body.

Specified by:

executeFhirBundle in interface HealthcareApiClient

Parameters:

fhirStore - the fhir store

bundle - the bundle

Returns:

the http body

Throws:

java.io.IOException - the io exception

HttpHealthcareApiClient.HealthcareHttpException

readFhirResource

public com.google.api.services.healthcare.v1beta1.model.HttpBody readFhirResource(java.lang.String resourceId)
                                                                           throws java.io.IOException

Description copied from interface: HealthcareApiClient

Read fhir resource http body.

Specified by:

readFhirResource in interface HealthcareApiClient

Parameters:

resourceId - the resource

Returns:

the http body

Throws:

java.io.IOException - the io exception