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.ClusterManagerApiType, DataflowPipelineWorkerPoolOptions.TeardownPolicyGcpOptions.CredentialDirFactory, GcpOptions.GcpUserCredentialsFactoryGoogleApiDebugOptions.GoogleApiTracerGcsOptions.ExecutorServiceFactoryCloudDebuggerOptions.DebuggerConfigDataflowWorkerLoggingOptions.Level, DataflowWorkerLoggingOptions.WorkerLogLevelOverride| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
getBigQueryDataset() |
TableSchema |
getBigQuerySchema() |
java.lang.String |
getBigQueryTable() |
void |
setBigQueryDataset(java.lang.String dataset) |
void |
setBigQuerySchema(TableSchema schema) |
void |
setBigQueryTable(java.lang.String table) |
getJobName, getStagingLocation, getTempLocation, setJobName, setStagingLocation, setTempLocationgetApiRootUrl, getDataflowClient, getDataflowEndpoint, getDataflowJobFile, getExperiments, getPathValidator, getPathValidatorClass, getStager, getStagerClass, setApiRootUrl, setDataflowClient, setDataflowEndpoint, setDataflowJobFile, setExperiments, setPathValidator, setPathValidatorClass, setStager, setStagerClassgetAutoscalingAlgorithm, getClusterManagerApi, getDiskSizeGb, getDiskSourceImage, getFilesToStage, getMaxNumWorkers, getNumWorkers, getTeardownPolicy, getWorkerDiskType, getWorkerMachineType, getWorkerPoolType, getZone, setAutoscalingAlgorithm, setClusterManagerApi, setDiskSizeGb, setDiskSourceImage, setFilesToStage, setMaxNumWorkers, setNumWorkers, setTeardownPolicy, setWorkerDiskType, setWorkerMachineType, setWorkerPoolType, setZonegetTempDatasetId, setTempDatasetIdisStreaming, setStreaminggetAppName, setAppNamegetCredentialDir, getCredentialFactoryClass, getCredentialId, getGCloudPath, getGcpCredential, getProject, getSecretsFile, getServiceAccountKeyfile, getServiceAccountName, setCredentialDir, setCredentialFactoryClass, setCredentialId, setGCloudPath, setGcpCredential, setProject, setSecretsFile, setServiceAccountKeyfile, setServiceAccountNamegetGoogleApiTrace, setGoogleApiTraceas, cloneAs, getRunner, setRunnergetExecutorService, getGcsUtil, setExecutorService, setGcsUtilgetCdbgVersion, setCdbgVersiongetDefaultWorkerLogLevel, getWorkerLogLevelOverrides, setDefaultWorkerLogLevel, setWorkerLogLevelOverridesjava.lang.String getBigQueryDataset()
void setBigQueryDataset(java.lang.String dataset)
java.lang.String getBigQueryTable()
void setBigQueryTable(java.lang.String table)
TableSchema getBigQuerySchema()
void setBigQuerySchema(TableSchema schema)