BigQueryIO.TypedRead<T> inner
private void readObject(java.io.ObjectInputStream in) throws java.lang.ClassNotFoundException, java.io.IOException
java.lang.ClassNotFoundException
java.io.IOException
java.lang.String stepUuid
org.apache.beam.sdk.options.ValueProvider<T> queryProvider
java.lang.Boolean flattenResults
java.lang.Boolean useLegacySql
BigQueryIO.TypedRead.QueryPriority priority
java.lang.String location
java.lang.String queryTempDataset
java.lang.String kmsKey
com.google.cloud.bigquery.storage.v1.ReadSession readSession
com.google.cloud.bigquery.storage.v1.ReadStream readStream
java.lang.String jsonTableSchema
org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT> parseFn
org.apache.beam.sdk.coders.Coder<T> outputCoder
BigQueryServices bqServices
private void readObject(java.io.ObjectInputStream in) throws java.lang.ClassNotFoundException, java.io.IOException
java.lang.ClassNotFoundException
java.io.IOException
org.apache.beam.sdk.options.ValueProvider<T> tableReferenceProvider
BigQueryIO.Write.CreateDisposition createDisposition
BigQueryServices bqServices
DynamicDestinations<T,DestinationT> dynamicDestinations
java.lang.String kmsKey
DynamicDestinations<T,DestinationT> dynamicDestinations
org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT> formatFunction
BigQueryServices bigQueryServices
BigQueryIO.Write.CreateDisposition createDisposition
DynamicDestinations<T,DestinationT> dynamicDestinations
InsertRetryPolicy retryPolicy
boolean extendedErrorInfo
boolean skipInvalidRows
boolean ignoreUnknownValues
boolean ignoreInsertIds
java.lang.String kmsKey
org.apache.beam.sdk.coders.Coder<T> elementCoder
org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT> toTableRow
BigQueryServices bigQueryServices
InsertRetryPolicy retryPolicy
boolean extendedErrorInfo
boolean skipInvalidRows
boolean ignoreUnknownValues
boolean ignoreInsertIds
org.apache.beam.sdk.coders.Coder<T> elementCoder
org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT> toTableRow
java.lang.String tableSpec
java.lang.String tableDescription
java.lang.String jsonTimePartitioning
java.lang.String jsonClustering
org.apache.beam.sdk.coders.Coder<T> destinationCoder
org.apache.beam.sdk.io.gcp.bigtable.BigtableConfig bigtableConfig
org.apache.beam.sdk.schemas.Schema dataSchema
java.lang.String location
java.lang.String kind
java.lang.String projectId
java.lang.String keyField
org.apache.beam.sdk.schemas.Schema schema
java.lang.String keyField
java.util.function.Supplier<T> keySupplier
java.lang.String kind
java.lang.String keyField
org.apache.beam.sdk.options.ValueProvider<T> sourceFhirStore
org.apache.beam.sdk.options.ValueProvider<T> destinationFhirStore
org.apache.beam.sdk.options.ValueProvider<T> deidConfig
HealthcareApiClient client
org.apache.beam.sdk.options.ValueProvider<T> destinationFhirStore
java.lang.String deidConfigJson
org.apache.beam.sdk.options.ValueProvider<T> fhirStore
org.apache.beam.sdk.options.ValueProvider<T> fhirStore
org.apache.beam.sdk.options.ValueProvider<T> exportGcsUriPrefix
HealthcareApiClient client
org.apache.beam.sdk.options.ValueProvider<T> exportGcsUriPrefix
org.apache.beam.sdk.options.ValueProvider<T> fhirStore
org.apache.beam.sdk.options.ValueProvider<T> deadLetterGcsPath
FhirIO.Import.ContentStructure contentStructure
org.apache.beam.sdk.options.ValueProvider<T> tempGcsPath
org.apache.beam.sdk.coders.Coder<T> originalCoder
org.apache.beam.sdk.options.ValueProvider<T> hl7v2Stores
org.apache.beam.sdk.options.ValueProvider<T> filter
org.joda.time.Duration initialSplitDuration
org.apache.beam.sdk.metrics.Counter failedMessageGets
org.apache.beam.sdk.metrics.Counter successfulHL7v2MessageGets
HealthcareApiClient client
int statusCode
java.lang.String projectId
java.lang.String projectId
java.lang.String subscriptionName
java.lang.String path
org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubSubscription.Type type
java.lang.String project
java.lang.String subscription
org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubTopic.Type type
java.lang.String project
java.lang.String topic
int maxPublishBatchByteSize
int maxPublishBatchSize
PubsubClient.PubsubClientFactory pubsubFactory
org.apache.beam.sdk.options.ValueProvider<T> topic
java.lang.String timestampAttribute
java.lang.String idAttribute
int numShards
int publishBatchSize
int publishBatchBytes
org.joda.time.Duration maxLatency
org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSink.RecordIdMethod recordIdMethod
PubsubUnboundedSink.idAttribute
is non-null).com.google.api.client.util.Clock clock
PubsubClient.PubsubClientFactory pubsubFactory
org.apache.beam.sdk.options.ValueProvider<T> project
PubsubUnboundedSource.topic
was given.org.apache.beam.sdk.options.ValueProvider<T> topic
PubsubUnboundedSource.subscription
must be given. Otherwise
PubsubUnboundedSource.subscription
must be null.org.apache.beam.sdk.options.ValueProvider<T> subscription
PubsubUnboundedSource.topic
must be given. Otherwise
PubsubUnboundedSource.topic
must be null.
If no subscription is given a random one will be created when the transorm is applied. This field will be update with that subscription's path. The created subscription is never deleted.
java.lang.String timestampAttribute
java.lang.String idAttribute
boolean needsAttributes
boolean needsMessageId
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableList<E> mutations
SpannerIO.Write spec
java.lang.String expectedChecksum
java.lang.String actualChecksum
BigqueryClient bigqueryClient
BigQueryServices.JobService jobService
BigQueryServices.DatasetService datasetService
BigQueryServices.StorageClient storageClient
java.util.List<E> items
java.util.Map<K,V> insertErrors
int numFailuresExpected
int numFailures
FakeDatasetService datasetService