com.google.cloud.dataflow.sdk.options

Interface BlockingDataflowPipelineOptions

All Superinterfaces:

ApplicationNameOptions, BigQueryOptions, 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.AutoscalingAlgorithmTypeFactory, DataflowPipelineWorkerPoolOptions.ClusterManagerApiType, DataflowPipelineWorkerPoolOptions.ClusterManagerApiTypeFactory

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

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, getWorkerMachineType, getZone, setAutoscalingAlgorithm, setClusterManagerApi, setDiskSizeGb, setDiskSourceImage, setFilesToStage, setMachineType, setMaxNumWorkers, setNumWorkers, 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

Method Detail

getJobMessageOutput

java.io.PrintStream getJobMessageOutput()

Output stream for job status messages.

setJobMessageOutput

void setJobMessageOutput(java.io.PrintStream value)