public interface TestBigQueryOptions extends org.apache.beam.sdk.testing.TestPipelineOptions, BigQueryOptions, org.apache.beam.sdk.extensions.gcp.options.GcpOptions
TestPipelineOptions
for TestBigQuery
.org.apache.beam.sdk.testing.TestPipelineOptions.AlwaysPassMatcher, org.apache.beam.sdk.testing.TestPipelineOptions.AlwaysPassMatcherFactory
org.apache.beam.sdk.extensions.gcp.options.GcpOptions.DefaultProjectFactory, org.apache.beam.sdk.extensions.gcp.options.GcpOptions.EnableStreamingEngineFactory, org.apache.beam.sdk.extensions.gcp.options.GcpOptions.GcpOAuthScopesFactory, org.apache.beam.sdk.extensions.gcp.options.GcpOptions.GcpTempLocationFactory, org.apache.beam.sdk.extensions.gcp.options.GcpOptions.GcpUserCredentialsFactory
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
BIGQUERY_EARLY_ROLLOUT_REGION |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getBigQueryLocation() |
java.lang.String |
getTargetDataset() |
void |
setBigQueryLocation(java.lang.String location) |
void |
setTargetDataset(java.lang.String value) |
getOnCreateMatcher, getOnSuccessMatcher, getTempRoot, getTestTimeoutSeconds, isBlockOnRun, setBlockOnRun, setOnCreateMatcher, setOnSuccessMatcher, setTempRoot, setTestTimeoutSeconds
getBigQueryProject, getBqStreamingApiLoggingFrequencySec, getEnableBundling, getHTTPWriteTimeout, getInsertBundleParallelism, getMaxBufferingDurationMilliSec, getMaxStreamingBatchSize, getMaxStreamingRowsToBatch, getNumStorageWriteApiStreamAppendClients, getNumStorageWriteApiStreams, getNumStreamingKeys, getStorageApiAppendThresholdBytes, getStorageApiAppendThresholdRecordCount, getStorageWriteApiMaxRequestSize, getStorageWriteApiTriggeringFrequencySec, getStorageWriteMaxInflightBytes, getStorageWriteMaxInflightRequests, getTempDatasetId, getUseStorageApiConnectionPool, getUseStorageWriteApi, getUseStorageWriteApiAtLeastOnce, setBigQueryProject, setBqStreamingApiLoggingFrequencySec, setEnableBundling, setHTTPWriteTimeout, setInsertBundleParallelism, setMaxBufferingDurationMilliSec, setMaxStreamingBatchSize, setMaxStreamingRowsToBatch, setNumStorageWriteApiStreamAppendClients, setNumStorageWriteApiStreams, setNumStreamingKeys, setStorageApiAppendThresholdBytes, setStorageApiAppendThresholdRecordCount, setStorageWriteApiMaxRequestSize, setStorageWriteApiTriggeringFrequencySec, setStorageWriteMaxInflightBytes, setStorageWriteMaxInflightRequests, setTempDatasetId, setUseStorageApiConnectionPool, setUseStorageWriteApi, setUseStorageWriteApiAtLeastOnce
getCredentialFactoryClass, getDataflowKmsKey, getGcpCredential, getGcpOauthScopes, getGcpTempLocation, getImpersonateServiceAccount, getProject, getWorkerRegion, getWorkerZone, getZone, isEnableStreamingEngine, setCredentialFactoryClass, setDataflowKmsKey, setEnableStreamingEngine, setGcpCredential, setGcpOauthScopes, setGcpTempLocation, setImpersonateServiceAccount, setProject, setWorkerRegion, setWorkerZone, setZone
getGoogleApiTrace, setGoogleApiTrace
static final java.lang.String BIGQUERY_EARLY_ROLLOUT_REGION
@Default.String(value="integ_test") java.lang.String getTargetDataset()
void setTargetDataset(java.lang.String value)
@Default.String(value="") java.lang.String getBigQueryLocation()
void setBigQueryLocation(java.lang.String location)