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
org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT> formatFunction
org.apache.beam.vendor.guava.v26_0_jre.com.google.common.cache.Cache<K,V> destinationDescriptorCache
BigQueryServices bqServices
BigQueryServices.DatasetService datasetService
org.apache.beam.sdk.metrics.Counter flushOperationsSent
org.apache.beam.sdk.metrics.Counter flushOperationsSucceeded
org.apache.beam.sdk.metrics.Counter flushOperationsFailed
org.apache.beam.sdk.metrics.Counter flushOperationsAlreadyExists
org.apache.beam.sdk.metrics.Counter flushOperationsInvalidArgument
org.apache.beam.sdk.metrics.Distribution flushLatencyDistribution
org.apache.beam.sdk.metrics.Counter finalizeOperationsSent
org.apache.beam.sdk.metrics.Counter finalizeOperationsSucceeded
org.apache.beam.sdk.metrics.Counter finalizeOperationsFailed
org.apache.beam.sdk.coders.Coder<T> destinationCoder
org.apache.beam.sdk.coders.Coder<T> elementCoder
org.apache.beam.sdk.io.gcp.bigquery.StorageApiDynamicDestinations<T,DestinationT> dynamicDestinations
BigQueryIO.Write.CreateDisposition createDisposition
java.lang.String kmsKey
org.joda.time.Duration triggeringFrequency
BigQueryServices bqServices
int numShards
org.apache.beam.sdk.io.gcp.bigquery.StorageApiDynamicDestinations<T,DestinationT> dynamicDestinations
BigQueryIO.Write.CreateDisposition createDisposition
java.lang.String kmsKey
BigQueryServices bqServices
org.apache.beam.sdk.coders.Coder<T> destinationCoder
BigQueryServices.DatasetService datasetServiceInternal
org.apache.beam.sdk.io.gcp.bigquery.StorageApiDynamicDestinations<T,DestinationT> dynamicDestinations
BigQueryIO.Write.CreateDisposition createDisposition
java.lang.String kmsKey
BigQueryServices bqServices
org.apache.beam.sdk.coders.Coder<T> destinationCoder
BigQueryServices.DatasetService datasetService
BigQueryServices bigQueryServices
BigQueryIO.Write.CreateDisposition createDisposition
DynamicDestinations<T,DestinationT> dynamicDestinations
InsertRetryPolicy retryPolicy
boolean extendedErrorInfo
boolean skipInvalidRows
boolean ignoreUnknownValues
boolean ignoreInsertIds
boolean autoSharding
java.lang.String kmsKey
org.apache.beam.sdk.coders.Coder<T> elementCoder
org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT> toTableRow
org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT> toFailsafeTableRow
BigQueryServices bigQueryServices
InsertRetryPolicy retryPolicy
boolean extendedErrorInfo
boolean skipInvalidRows
boolean ignoreUnknownValues
boolean ignoreInsertIds
boolean autoSharding
org.apache.beam.sdk.coders.Coder<T> elementCoder
org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT> toTableRow
org.apache.beam.sdk.transforms.SerializableFunction<InputT,OutputT> toFailsafeTableRow
java.lang.String tableSpec
java.lang.String tableDescription
java.lang.String jsonTimePartitioning
java.lang.String jsonClustering
org.apache.beam.sdk.coders.Coder<T> destinationCoder
java.util.Map<K,V> columnFamilyMapping
java.util.Map<K,V> columnFamilyMapping
org.apache.beam.sdk.io.gcp.bigtable.CellValueParser cellValueParser
org.apache.beam.sdk.io.gcp.bigtable.BigtableConfig bigtableConfig
org.apache.beam.sdk.schemas.Schema schema
org.apache.beam.sdk.schemas.Schema schema
java.util.Map<K,V> columnsMapping
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.options.ValueProvider<T> fhirStore
org.apache.beam.sdk.coders.NullableCoder<T> originalCoder
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
PubsubUnboundedSink sink
PubsubUnboundedSource source
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