Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.options
Interface BlockingDataflowPipelineOptions
-
- All Superinterfaces:
- ApplicationNameOptions, BigQueryOptions, CloudDebuggerOptions, DataflowPipelineDebugOptions, DataflowPipelineOptions, DataflowPipelineWorkerPoolOptions, DataflowProfilingOptions, DataflowWorkerLoggingOptions, GcpOptions, GcsOptions, GoogleApiDebugOptions, HasDisplayData, PipelineOptions, StreamingOptions
- All Known Subinterfaces:
- TestDataflowPipelineOptions
public interface BlockingDataflowPipelineOptions extends DataflowPipelineOptions
Options that are used to configure theBlockingDataflowPipelineRunner
.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface and Description static class
BlockingDataflowPipelineOptions.StandardOutputFactory
Returns a default ofSystem.out
.-
Nested classes/interfaces inherited from interface com.google.cloud.dataflow.sdk.options.DataflowPipelineOptions
DataflowPipelineOptions.JobNameFactory
-
Nested classes/interfaces inherited from interface com.google.cloud.dataflow.sdk.options.DataflowPipelineDebugOptions
DataflowPipelineDebugOptions.DataflowClientFactory, DataflowPipelineDebugOptions.PathValidatorFactory, DataflowPipelineDebugOptions.StagerFactory
-
Nested classes/interfaces inherited from interface com.google.cloud.dataflow.sdk.options.DataflowPipelineWorkerPoolOptions
DataflowPipelineWorkerPoolOptions.AutoscalingAlgorithmType, DataflowPipelineWorkerPoolOptions.TeardownPolicy, DataflowPipelineWorkerPoolOptions.WorkerHarnessContainerImageFactory
-
Nested classes/interfaces inherited from interface com.google.cloud.dataflow.sdk.options.GcpOptions
GcpOptions.CredentialDirFactory, GcpOptions.DefaultProjectFactory, GcpOptions.GcpUserCredentialsFactory
-
Nested classes/interfaces inherited from interface com.google.cloud.dataflow.sdk.options.GoogleApiDebugOptions
GoogleApiDebugOptions.GoogleApiTracer
-
Nested classes/interfaces inherited from interface com.google.cloud.dataflow.sdk.options.PipelineOptions
PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled
-
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.DataflowWorkerLoggingOptions
DataflowWorkerLoggingOptions.Level, DataflowWorkerLoggingOptions.WorkerLogLevelOverrides
-
Nested classes/interfaces inherited from interface com.google.cloud.dataflow.sdk.options.DataflowProfilingOptions
DataflowProfilingOptions.DataflowProfilingAgentConfiguration
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method and Description PrintStream
getJobMessageOutput()
Output stream for job status messages.void
setJobMessageOutput(PrintStream value)
-
Methods inherited from interface com.google.cloud.dataflow.sdk.options.DataflowPipelineOptions
getJobName, getLabels, getProject, getServiceAccount, getStagingLocation, getUpdate, setJobName, setLabels, setProject, setServiceAccount, setStagingLocation, setUpdate
-
Methods inherited from interface com.google.cloud.dataflow.sdk.options.DataflowPipelineDebugOptions
getApiRootUrl, getDataflowClient, getDataflowEndpoint, getDataflowJobFile, getDumpHeapOnOOM, getExperiments, getNumberOfWorkerHarnessThreads, getOverrideWindmillBinary, getPathValidator, getPathValidatorClass, getPubsubRootUrl, getStager, getStagerClass, getTransformNameMapping, getWindmillServiceEndpoint, getWindmillServicePort, setApiRootUrl, setDataflowClient, setDataflowEndpoint, setDataflowJobFile, setDumpHeapOnOOM, setExperiments, setNumberOfWorkerHarnessThreads, setOverrideWindmillBinary, setPathValidator, setPathValidatorClass, setPubsubRootUrl, setStager, setStagerClass, setTransformNameMapping, setWindmillServiceEndpoint, setWindmillServicePort
-
Methods inherited from interface com.google.cloud.dataflow.sdk.options.DataflowPipelineWorkerPoolOptions
getAutoscalingAlgorithm, getDiskSizeGb, getFilesToStage, getMaxNumWorkers, getNetwork, getNumWorkers, getSubnetwork, getTeardownPolicy, getUsePublicIps, getWorkerDiskType, getWorkerHarnessContainerImage, getWorkerMachineType, getZone, setAutoscalingAlgorithm, setDiskSizeGb, setFilesToStage, setMaxNumWorkers, setNetwork, setNumWorkers, setSubnetwork, setTeardownPolicy, setUsePublicIps, setWorkerDiskType, setWorkerHarnessContainerImage, 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
getAuthorizationServerEncodedUrl, getCredentialDir, getCredentialFactoryClass, getCredentialId, getGcpCredential, getSecretsFile, getServiceAccountKeyfile, getServiceAccountName, getTokenServerUrl, setAuthorizationServerEncodedUrl, setCredentialDir, setCredentialFactoryClass, setCredentialId, setGcpCredential, setSecretsFile, setServiceAccountKeyfile, setServiceAccountName, setTokenServerUrl
-
Methods inherited from interface com.google.cloud.dataflow.sdk.options.GoogleApiDebugOptions
getGoogleApiTrace, setGoogleApiTrace
-
Methods inherited from interface com.google.cloud.dataflow.sdk.options.PipelineOptions
as, cloneAs, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, outputRuntimeOptions, setOptionsId, setRunner, setStableUniqueNames, setTempLocation
-
Methods inherited from interface com.google.cloud.dataflow.sdk.transforms.display.HasDisplayData
populateDisplayData
-
Methods inherited from interface com.google.cloud.dataflow.sdk.options.GcsOptions
getExecutorService, getGcsEndpoint, getGcsUploadBufferSizeBytes, getGcsUtil, setExecutorService, setGcsEndpoint, setGcsUploadBufferSizeBytes, setGcsUtil
-
Methods inherited from interface com.google.cloud.dataflow.sdk.options.CloudDebuggerOptions
getDebuggee, getEnableCloudDebugger, getMaxConditionCost, setDebuggee, setEnableCloudDebugger, setMaxConditionCost
-
Methods inherited from interface com.google.cloud.dataflow.sdk.options.DataflowWorkerLoggingOptions
getDefaultWorkerLogLevel, getWorkerLogLevelOverrides, setDefaultWorkerLogLevel, setWorkerLogLevelOverrides
-
Methods inherited from interface com.google.cloud.dataflow.sdk.options.DataflowProfilingOptions
getEnableProfilingAgent, getProfilingAgentConfiguration, getSaveProfilesToGcs, setEnableProfilingAgent, setProfilingAgentConfiguration, setSaveProfilesToGcs
-
-
-
-
Method Detail
-
getJobMessageOutput
@Hidden @Default.InstanceFactory(value=BlockingDataflowPipelineOptions.StandardOutputFactory.class) PrintStream getJobMessageOutput()
Output stream for job status messages.
-
setJobMessageOutput
void setJobMessageOutput(PrintStream value)
-
-