com.google.cloud.dataflow.sdk.options

Interface BlockingDataflowPipelineOptions

All Superinterfaces:

ApplicationNameOptions, BigQueryOptions, CloudDebuggerOptions, DataflowPipelineDebugOptions, DataflowPipelineOptions, DataflowPipelineWorkerPoolOptions, GcpOptions, GcsOptions, PipelineOptions, StreamingOptions

All Known Subinterfaces:

TestDataflowPipelineOptions

public interface BlockingDataflowPipelineOptions
extends DataflowPipelineOptions

Options which are used to configure the BlockingDataflowPipelineRunner.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	BlockingDataflowPipelineOptions.StandardOutputFactory Returns a default of System.out.

Nested classes/interfaces inherited from interface com.google.cloud.dataflow.sdk.options.DataflowPipelineOptions

DataflowPipelineOptions.DataflowClientFactory, DataflowPipelineOptions.JobNameFactory

Nested classes/interfaces inherited from interface com.google.cloud.dataflow.sdk.options.DataflowPipelineWorkerPoolOptions

DataflowPipelineWorkerPoolOptions.AutoscalingAlgorithmType, DataflowPipelineWorkerPoolOptions.ClusterManagerApiType, DataflowPipelineWorkerPoolOptions.TeardownPolicy

Nested classes/interfaces inherited from interface com.google.cloud.dataflow.sdk.options.GcpOptions

GcpOptions.CredentialDirFactory, GcpOptions.GcpUserCredentialsFactory

Nested classes/interfaces inherited from interface com.google.cloud.dataflow.sdk.options.GcsOptions

GcsOptions.ExecutorServiceFactory

Nested classes/interfaces inherited from interface com.google.cloud.dataflow.sdk.options.CloudDebuggerOptions

CloudDebuggerOptions.DebuggerConfig

Method Summary

Methods

Modifier and Type	Method and Description
java.io.PrintStream	getJobMessageOutput() Output stream for job status messages.
void	setJobMessageOutput(java.io.PrintStream value)

Methods inherited from interface com.google.cloud.dataflow.sdk.options.DataflowPipelineOptions

getDataflowClient, getJobName, getStagingLocation, getTempLocation, setDataflowClient, setJobName, setStagingLocation, setTempLocation

Methods inherited from interface com.google.cloud.dataflow.sdk.options.DataflowPipelineDebugOptions

getApiRootUrl, getDataflowEndpoint, getDataflowJobFile, getExperiments, setApiRootUrl, setDataflowEndpoint, setDataflowJobFile, setExperiments

Methods inherited from interface com.google.cloud.dataflow.sdk.options.DataflowPipelineWorkerPoolOptions

getAutoscalingAlgorithm, getClusterManagerApi, getDiskSizeGb, getDiskSourceImage, getFilesToStage, getMachineType, getMaxNumWorkers, getNumWorkers, getTeardownPolicy, getWorkerMachineType, getZone, setAutoscalingAlgorithm, setClusterManagerApi, setDiskSizeGb, setDiskSourceImage, setFilesToStage, setMachineType, setMaxNumWorkers, setNumWorkers, setTeardownPolicy, setWorkerMachineType, setZone

Methods inherited from interface com.google.cloud.dataflow.sdk.options.BigQueryOptions

getTempDatasetId, setTempDatasetId

Methods inherited from interface com.google.cloud.dataflow.sdk.options.StreamingOptions

isStreaming, setStreaming

Methods inherited from interface com.google.cloud.dataflow.sdk.options.ApplicationNameOptions

getAppName, setAppName

Methods inherited from interface com.google.cloud.dataflow.sdk.options.GcpOptions

getCredentialDir, getCredentialId, getGCloudPath, getGcpCredential, getProject, getSecretsFile, getServiceAccountKeyfile, getServiceAccountName, setCredentialDir, setCredentialId, setGCloudPath, setGcpCredential, setProject, setSecretsFile, setServiceAccountKeyfile, setServiceAccountName

Methods inherited from interface com.google.cloud.dataflow.sdk.options.PipelineOptions

as, getRunner, setRunner

Methods inherited from interface com.google.cloud.dataflow.sdk.options.GcsOptions

getExecutorService, getGcsUtil, setExecutorService, setGcsUtil

Methods inherited from interface com.google.cloud.dataflow.sdk.options.CloudDebuggerOptions

getCdbgVersion, setCdbgVersion

Method Detail

getJobMessageOutput

java.io.PrintStream getJobMessageOutput()

Output stream for job status messages.

setJobMessageOutput

void setJobMessageOutput(java.io.PrintStream value)