org.apache.beam.sdk.io.gcp.bigquery

Interface BigQueryOptions

All Superinterfaces:

ApplicationNameOptions, GcpOptions, GoogleApiDebugOptions, HasDisplayData, PipelineOptions, StreamingOptions

All Known Subinterfaces:

DataflowPipelineOptions, DataflowWorkerHarnessOptions, TestBigQueryOptions, TestDataflowPipelineOptions

public interface BigQueryOptions
extends ApplicationNameOptions, GcpOptions, PipelineOptions, StreamingOptions

Properties needed when using Google BigQuery with the Apache Beam SDK.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

GcpOptions.DefaultProjectFactory, GcpOptions.EnableStreamingEngineFactory, GcpOptions.GcpOAuthScopesFactory, GcpOptions.GcpTempLocationFactory, GcpOptions.GcpUserCredentialsFactory

Nested classes/interfaces inherited from interface org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions

GoogleApiDebugOptions.GoogleApiTracer

Field Summary

Fields inherited from interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

STREAMING_ENGINE_EXPERIMENT, WINDMILL_SERVICE_EXPERIMENT

Method Summary

Modifier and Type	Method and Description
java.lang.String	getBigQueryProject()
java.lang.Integer	getBqStreamingApiLoggingFrequencySec()
java.lang.Integer	getHTTPWriteTimeout()
java.lang.Integer	getInsertBundleParallelism()
java.lang.Integer	getMaxBufferingDurationMilliSec()
java.lang.Long	getMaxStreamingBatchSize()
java.lang.Long	getMaxStreamingRowsToBatch()
java.lang.Integer	getNumStorageWriteApiStreamAppendClients()
java.lang.Integer	getNumStorageWriteApiStreams()
java.lang.Integer	getNumStreamingKeys()
java.lang.Integer	getSchemaUpdateRetries()
java.lang.Integer	getStorageApiAppendThresholdBytes()
java.lang.Integer	getStorageApiAppendThresholdRecordCount()
java.lang.Integer	getStorageWriteApiTriggeringFrequencySec()
java.lang.String	getTempDatasetId()
java.lang.Boolean	getUseStorageApiConnectionPool()
java.lang.Boolean	getUseStorageWriteApi()
java.lang.Boolean	getUseStorageWriteApiAtLeastOnce()
void	setBigQueryProject(java.lang.String value)
void	setBqStreamingApiLoggingFrequencySec(java.lang.Integer value)
void	setHTTPWriteTimeout(java.lang.Integer timeout)
void	setInsertBundleParallelism(java.lang.Integer parallelism)
void	setMaxBufferingDurationMilliSec(java.lang.Integer value)
void	setMaxStreamingBatchSize(java.lang.Long value)
void	setMaxStreamingRowsToBatch(java.lang.Long value)
void	setNumStorageWriteApiStreamAppendClients(java.lang.Integer value)
void	setNumStorageWriteApiStreams(java.lang.Integer value)
void	setNumStreamingKeys(java.lang.Integer value)
void	setSchemaUpdateRetries(java.lang.Integer value)
void	setStorageApiAppendThresholdBytes(java.lang.Integer value)
void	setStorageApiAppendThresholdRecordCount(java.lang.Integer value)
void	setStorageWriteApiTriggeringFrequencySec(java.lang.Integer value)
void	setTempDatasetId(java.lang.String value)
void	setUseStorageApiConnectionPool(java.lang.Boolean value)
void	setUseStorageWriteApi(java.lang.Boolean value)
void	setUseStorageWriteApiAtLeastOnce(java.lang.Boolean value)

Methods inherited from interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

getCredentialFactoryClass, getDataflowKmsKey, getGcpCredential, getGcpOauthScopes, getGcpTempLocation, getImpersonateServiceAccount, getProject, getWorkerRegion, getWorkerZone, getZone, isEnableStreamingEngine, setCredentialFactoryClass, setDataflowKmsKey, setEnableStreamingEngine, setGcpCredential, setGcpOauthScopes, setGcpTempLocation, setImpersonateServiceAccount, setProject, setWorkerRegion, setWorkerZone, setZone

Methods inherited from interface org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions

getGoogleApiTrace, setGoogleApiTrace

Methods inherited from interface org.apache.beam.sdk.options.StreamingOptions

isStreaming, setStreaming

Methods inherited from interface org.apache.beam.sdk.options.ApplicationNameOptions

getAppName, setAppName

Method Detail

getTempDatasetId

@Default.String(value="bigquery.googleapis.com/cloud_dataflow")
java.lang.String getTempDatasetId()

setTempDatasetId

void setTempDatasetId(java.lang.String value)

getHTTPWriteTimeout

@Default.Integer(value=900000)
java.lang.Integer getHTTPWriteTimeout()

setHTTPWriteTimeout

void setHTTPWriteTimeout(java.lang.Integer timeout)

getInsertBundleParallelism

@Default.Integer(value=3)
java.lang.Integer getInsertBundleParallelism()

setInsertBundleParallelism

void setInsertBundleParallelism(java.lang.Integer parallelism)

getNumStreamingKeys

@Default.Integer(value=50)
java.lang.Integer getNumStreamingKeys()

setNumStreamingKeys

void setNumStreamingKeys(java.lang.Integer value)

getMaxStreamingRowsToBatch

@Default.Long(value=500L)
java.lang.Long getMaxStreamingRowsToBatch()

setMaxStreamingRowsToBatch

void setMaxStreamingRowsToBatch(java.lang.Long value)

getMaxStreamingBatchSize

@Default.Long(value=65536L)
java.lang.Long getMaxStreamingBatchSize()

setMaxStreamingBatchSize

void setMaxStreamingBatchSize(java.lang.Long value)

getBqStreamingApiLoggingFrequencySec

@Default.Integer(value=180)
java.lang.Integer getBqStreamingApiLoggingFrequencySec()

setBqStreamingApiLoggingFrequencySec

void setBqStreamingApiLoggingFrequencySec(java.lang.Integer value)

getUseStorageWriteApi

@Default.Boolean(value=false)
java.lang.Boolean getUseStorageWriteApi()

setUseStorageWriteApi

void setUseStorageWriteApi(java.lang.Boolean value)

getUseStorageWriteApiAtLeastOnce

@Default.Boolean(value=false)
java.lang.Boolean getUseStorageWriteApiAtLeastOnce()

setUseStorageWriteApiAtLeastOnce

void setUseStorageWriteApiAtLeastOnce(java.lang.Boolean value)

getNumStorageWriteApiStreams

@Default.Integer(value=0)
java.lang.Integer getNumStorageWriteApiStreams()

setNumStorageWriteApiStreams

void setNumStorageWriteApiStreams(java.lang.Integer value)

getNumStorageWriteApiStreamAppendClients

@Default.Integer(value=1)
java.lang.Integer getNumStorageWriteApiStreamAppendClients()

setNumStorageWriteApiStreamAppendClients

void setNumStorageWriteApiStreamAppendClients(java.lang.Integer value)

getUseStorageApiConnectionPool

@Default.Boolean(value=false)
java.lang.Boolean getUseStorageApiConnectionPool()

setUseStorageApiConnectionPool

void setUseStorageApiConnectionPool(java.lang.Boolean value)

getStorageWriteApiTriggeringFrequencySec

java.lang.Integer getStorageWriteApiTriggeringFrequencySec()

setStorageWriteApiTriggeringFrequencySec

void setStorageWriteApiTriggeringFrequencySec(java.lang.Integer value)

getMaxBufferingDurationMilliSec

@Default.Integer(value=0)
java.lang.Integer getMaxBufferingDurationMilliSec()

setMaxBufferingDurationMilliSec

void setMaxBufferingDurationMilliSec(java.lang.Integer value)

getBigQueryProject

java.lang.String getBigQueryProject()

setBigQueryProject

void setBigQueryProject(java.lang.String value)

getSchemaUpdateRetries

@Default.Integer(value=2)
java.lang.Integer getSchemaUpdateRetries()

setSchemaUpdateRetries

void setSchemaUpdateRetries(java.lang.Integer value)

getStorageApiAppendThresholdBytes

@Default.Integer(value=2097152)
java.lang.Integer getStorageApiAppendThresholdBytes()

setStorageApiAppendThresholdBytes

void setStorageApiAppendThresholdBytes(java.lang.Integer value)

getStorageApiAppendThresholdRecordCount

@Default.Integer(value=150000)
java.lang.Integer getStorageApiAppendThresholdRecordCount()

setStorageApiAppendThresholdRecordCount

void setStorageApiAppendThresholdRecordCount(java.lang.Integer value)