public interface ExampleBigQueryTableOptions extends DataflowPipelineOptions
| Modifier and Type | Interface and Description |
|---|---|
static class |
ExampleBigQueryTableOptions.BigQueryTableFactory
Returns the job name as the default BigQuery table name.
|
DataflowPipelineOptions.JobNameFactoryDataflowPipelineDebugOptions.DataflowClientFactory, DataflowPipelineDebugOptions.PathValidatorFactory, DataflowPipelineDebugOptions.StagerFactoryDataflowPipelineWorkerPoolOptions.AutoscalingAlgorithmType, DataflowPipelineWorkerPoolOptions.TeardownPolicyGcpOptions.CredentialDirFactory, GcpOptions.DefaultProjectFactory, GcpOptions.GcpUserCredentialsFactoryGoogleApiDebugOptions.GoogleApiTracerPipelineOptions.CheckEnabledGcsOptions.ExecutorServiceFactoryDataflowWorkerLoggingOptions.Level, DataflowWorkerLoggingOptions.WorkerLogLevelOverridesDATAFLOW_STORAGE_LOCATION| Modifier and Type | Method and Description |
|---|---|
String |
getBigQueryDataset() |
com.google.api.services.bigquery.model.TableSchema |
getBigQuerySchema() |
String |
getBigQueryTable() |
void |
setBigQueryDataset(String dataset) |
void |
setBigQuerySchema(com.google.api.services.bigquery.model.TableSchema schema) |
void |
setBigQueryTable(String table) |
getJobName, getProject, getStagingLocation, getTempLocation, setJobName, setProject, setStagingLocation, setTempLocationgetApiRootUrl, getDataflowClient, getDataflowEndpoint, getDataflowJobFile, getExperiments, getOverrideWindmillBinary, getPathValidator, getPathValidatorClass, getPubsubRootUrl, getStager, getStagerClass, getTransformNameMapping, getUpdate, setApiRootUrl, setDataflowClient, setDataflowEndpoint, setDataflowJobFile, setExperiments, setOverrideWindmillBinary, setPathValidator, setPathValidatorClass, setPubsubRootUrl, setStager, setStagerClass, setTransformNameMapping, setUpdategetAutoscalingAlgorithm, getDiskSizeGb, getDiskSourceImage, getFilesToStage, getMaxNumWorkers, getNetwork, getNumWorkers, getTeardownPolicy, getWorkerDiskType, getWorkerMachineType, getZone, setAutoscalingAlgorithm, setDiskSizeGb, setDiskSourceImage, setFilesToStage, setMaxNumWorkers, setNetwork, setNumWorkers, setTeardownPolicy, setWorkerDiskType, setWorkerMachineType, setZonegetTempDatasetId, setTempDatasetIdisStreaming, setStreaminggetAppName, setAppNamegetCredentialDir, getCredentialFactoryClass, getCredentialId, getGcpCredential, getSecretsFile, getServiceAccountKeyfile, getServiceAccountName, setCredentialDir, setCredentialFactoryClass, setCredentialId, setGcpCredential, setSecretsFile, setServiceAccountKeyfile, setServiceAccountNamegetGoogleApiTrace, setGoogleApiTraceas, cloneAs, getRunner, getStableUniqueNames, setRunner, setStableUniqueNamesgetExecutorService, getGcsEndpoint, getGcsUtil, setExecutorService, setGcsEndpoint, setGcsUtilgetEnableCloudDebugger, setEnableCloudDebuggergetDefaultWorkerLogLevel, getWorkerLogLevelOverrides, setDefaultWorkerLogLevel, setWorkerLogLevelOverridesString getBigQueryDataset()
void setBigQueryDataset(String dataset)
String getBigQueryTable()
void setBigQueryTable(String table)
com.google.api.services.bigquery.model.TableSchema getBigQuerySchema()
void setBigQuerySchema(com.google.api.services.bigquery.model.TableSchema schema)