public interface BigQueryOptions extends ApplicationNameOptions, GcpOptions, PipelineOptions, StreamingOptions
GcpOptions.DefaultProjectFactory, GcpOptions.EnableStreamingEngineFactory, GcpOptions.GcpOAuthScopesFactory, GcpOptions.GcpTempLocationFactory, GcpOptions.GcpUserCredentialsFactory
GoogleApiDebugOptions.GoogleApiTracer
STREAMING_ENGINE_EXPERIMENT, WINDMILL_SERVICE_EXPERIMENT
getCredentialFactoryClass, getDataflowKmsKey, getGcpCredential, getGcpOauthScopes, getGcpTempLocation, getImpersonateServiceAccount, getProject, getWorkerRegion, getWorkerZone, getZone, isEnableStreamingEngine, setCredentialFactoryClass, setDataflowKmsKey, setEnableStreamingEngine, setGcpCredential, setGcpOauthScopes, setGcpTempLocation, setImpersonateServiceAccount, setProject, setWorkerRegion, setWorkerZone, setZone
getGoogleApiTrace, setGoogleApiTrace
getUpdateCompatibilityVersion, isStreaming, setStreaming, setUpdateCompatibilityVersion, updateCompatibilityVersionLessThan
getAppName, setAppName
@Default.String(value="bigquery.googleapis.com/cloud_dataflow") java.lang.String getTempDatasetId()
void setTempDatasetId(java.lang.String value)
@Default.Integer(value=900000) java.lang.Integer getHTTPWriteTimeout()
void setHTTPWriteTimeout(java.lang.Integer timeout)
@Default.Integer(value=3) java.lang.Integer getInsertBundleParallelism()
void setInsertBundleParallelism(java.lang.Integer parallelism)
@Default.Integer(value=50) java.lang.Integer getNumStreamingKeys()
void setNumStreamingKeys(java.lang.Integer value)
@Default.Long(value=500L) java.lang.Long getMaxStreamingRowsToBatch()
void setMaxStreamingRowsToBatch(java.lang.Long value)
@Default.Long(value=65536L) java.lang.Long getMaxStreamingBatchSize()
void setMaxStreamingBatchSize(java.lang.Long value)
@Default.Integer(value=180) java.lang.Integer getBqStreamingApiLoggingFrequencySec()
void setBqStreamingApiLoggingFrequencySec(java.lang.Integer value)
@Default.Boolean(value=false) java.lang.Boolean getUseStorageWriteApi()
void setUseStorageWriteApi(java.lang.Boolean value)
@Default.Boolean(value=false) java.lang.Boolean getUseStorageWriteApiAtLeastOnce()
void setUseStorageWriteApiAtLeastOnce(java.lang.Boolean value)
@Default.Integer(value=0) java.lang.Integer getNumStorageWriteApiStreams()
void setNumStorageWriteApiStreams(java.lang.Integer value)
@Default.Integer(value=1) java.lang.Integer getNumStorageWriteApiStreamAppendClients()
void setNumStorageWriteApiStreamAppendClients(java.lang.Integer value)
@Default.Integer(value=2) java.lang.Integer getMinConnectionPoolConnections()
void setMinConnectionPoolConnections(java.lang.Integer value)
@Default.Integer(value=20) java.lang.Integer getMaxConnectionPoolConnections()
void setMaxConnectionPoolConnections(java.lang.Integer value)
@Default.Long(value=1000L) java.lang.Long getStorageWriteMaxInflightRequests()
void setStorageWriteMaxInflightRequests(java.lang.Long value)
@Default.Long(value=104857600L) java.lang.Long getStorageWriteMaxInflightBytes()
void setStorageWriteMaxInflightBytes(java.lang.Long value)
@Default.Boolean(value=false) java.lang.Boolean getUseStorageApiConnectionPool()
void setUseStorageApiConnectionPool(java.lang.Boolean value)
java.lang.Integer getStorageWriteApiTriggeringFrequencySec()
void setStorageWriteApiTriggeringFrequencySec(java.lang.Integer value)
@Default.Integer(value=500) java.lang.Integer getStorageWriteApiMaxRetries()
void setStorageWriteApiMaxRetries(java.lang.Integer value)
@Default.Integer(value=0) java.lang.Integer getMaxBufferingDurationMilliSec()
void setMaxBufferingDurationMilliSec(java.lang.Integer value)
java.lang.String getBigQueryProject()
void setBigQueryProject(java.lang.String value)
@Default.Integer(value=2097152) java.lang.Integer getStorageApiAppendThresholdBytes()
void setStorageApiAppendThresholdBytes(java.lang.Integer value)
@Default.Integer(value=150000) java.lang.Integer getStorageApiAppendThresholdRecordCount()
void setStorageApiAppendThresholdRecordCount(java.lang.Integer value)
@Default.Long(value=10000000L) java.lang.Long getStorageWriteApiMaxRequestSize()
void setStorageWriteApiMaxRequestSize(java.lang.Long value)
@Default.Boolean(value=false) java.lang.Boolean getEnableStorageReadApiV2()
void setEnableStorageReadApiV2(java.lang.Boolean value)