com.google.cloud.dataflow.examples

Interface WindowedWordCount.Options

All Superinterfaces:

ApplicationNameOptions, BigQueryOptions, CloudDebuggerOptions, DataflowExampleOptions, DataflowExampleUtils.DataflowExampleUtilsOptions, DataflowPipelineDebugOptions, DataflowPipelineOptions, DataflowPipelineWorkerPoolOptions, DataflowProfilingOptions, DataflowWorkerLoggingOptions, ExampleBigQueryTableOptions, ExamplePubsubTopicOptions, GcpOptions, GcsOptions, GoogleApiDebugOptions, PipelineOptions, StreamingOptions, WordCount.WordCountOptions

Enclosing class:

WindowedWordCount

public static interface WindowedWordCount.Options
extends WordCount.WordCountOptions, DataflowExampleUtils.DataflowExampleUtilsOptions

Options supported by WindowedWordCount.

Inherits standard example configuration options, which allow specification of the BigQuery table and the PubSub topic, as well as the WordCount.WordCountOptions support for specification of the input file.

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.cloud.dataflow.examples.WordCount.WordCountOptions

WordCount.WordCountOptions.OutputFactory

Nested classes/interfaces inherited from interface com.google.cloud.dataflow.examples.common.ExamplePubsubTopicOptions

ExamplePubsubTopicOptions.PubsubTopicFactory

Nested classes/interfaces inherited from interface com.google.cloud.dataflow.examples.common.ExampleBigQueryTableOptions

ExampleBigQueryTableOptions.BigQueryTableFactory

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

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

Field Summary

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

DATAFLOW_STORAGE_LOCATION

Method Summary

Modifier and Type	Method and Description
Integer	getWindowSize()
boolean	isUnbounded()
void	setUnbounded(boolean value)
void	setWindowSize(Integer value)

Methods inherited from interface com.google.cloud.dataflow.examples.WordCount.WordCountOptions

getInputFile, getOutput, setInputFile, setOutput

Methods inherited from interface com.google.cloud.dataflow.examples.common.DataflowExampleOptions

getKeepJobsRunning, setKeepJobsRunning

Methods inherited from interface com.google.cloud.dataflow.examples.common.ExamplePubsubTopicOptions

getInjectorNumWorkers, getPubsubTopic, setInjectorNumWorkers, setPubsubTopic

Methods inherited from interface com.google.cloud.dataflow.examples.common.ExampleBigQueryTableOptions

getBigQueryDataset, getBigQuerySchema, getBigQueryTable, setBigQueryDataset, setBigQuerySchema, setBigQueryTable

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

getJobName, getProject, getStagingLocation, getTempLocation, setJobName, setProject, setStagingLocation, setTempLocation

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

getApiRootUrl, getDataflowClient, getDataflowEndpoint, getDataflowJobFile, getExperiments, getNumberOfWorkerHarnessThreads, getOverrideWindmillBinary, getPathValidator, getPathValidatorClass, getPubsubRootUrl, getStager, getStagerClass, getTransformNameMapping, getUpdate, setApiRootUrl, setDataflowClient, setDataflowEndpoint, setDataflowJobFile, setExperiments, setNumberOfWorkerHarnessThreads, setOverrideWindmillBinary, setPathValidator, setPathValidatorClass, setPubsubRootUrl, setStager, setStagerClass, setTransformNameMapping, setUpdate

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

getAutoscalingAlgorithm, getDiskSizeGb, getFilesToStage, getMaxNumWorkers, getNetwork, getNumWorkers, getTeardownPolicy, getWorkerDiskType, getWorkerMachineType, getZone, setAutoscalingAlgorithm, setDiskSizeGb, setFilesToStage, setMaxNumWorkers, setNetwork, setNumWorkers, setTeardownPolicy, setWorkerDiskType, 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.GcsOptions

getExecutorService, getGcsEndpoint, getGcsUploadBufferSizeBytes, getGcsUtil, setExecutorService, setGcsEndpoint, setGcsUploadBufferSizeBytes, setGcsUtil

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

getEnableCloudDebugger, setEnableCloudDebugger

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, setEnableProfilingAgent, setProfilingAgentConfiguration

Method Detail

getWindowSize

@Default.Integer(value=1)
Integer getWindowSize()

setWindowSize

void setWindowSize(Integer value)

isUnbounded

boolean isUnbounded()

setUnbounded

void setUnbounded(boolean value)