# Package Classes (0.14.0)

0.14.0 (latest) 0.13.0 0.12.0 0.11.0 0.10.0 0.9.0 0.8.17 0.7.0 0.6.2 0.5.5 0.4.1 0.3.1 0.2.0 0.1.5 Summary of entries of Classes for dataflow.

## Classes

### [FlexTemplatesServiceAsyncClient](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.flex_templates_service.FlexTemplatesServiceAsyncClient)

Provides a service for Flex templates.

### [FlexTemplatesServiceClient](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.flex_templates_service.FlexTemplatesServiceClient)

Provides a service for Flex templates.

### [JobsV1Beta3AsyncClient](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.jobs_v1_beta3.JobsV1Beta3AsyncClient)

Provides a method to create and modify Dataflow jobs.
A Job is a multi-stage computation graph run by the Dataflow
service.

### [JobsV1Beta3Client](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.jobs_v1_beta3.JobsV1Beta3Client)

Provides a method to create and modify Dataflow jobs.
A Job is a multi-stage computation graph run by the Dataflow
service.

### [AggregatedListJobsAsyncPager](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.jobs_v1_beta3.pagers.AggregatedListJobsAsyncPager)

A pager for iterating through `aggregated_list_jobs` requests.

This class thinly wraps an initial
[ListJobsResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListJobsResponse) object, and
provides an `__aiter__` method to iterate through its
`jobs` field.

If there are more pages, the `__aiter__` method will make additional
`AggregatedListJobs` requests and continue to iterate
through the `jobs` field on the
corresponding responses.

All the usual [ListJobsResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListJobsResponse)
attributes are available on the pager. If multiple requests are made, only
the most recent response is retained, and thus used for attribute lookup.

### [AggregatedListJobsPager](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.jobs_v1_beta3.pagers.AggregatedListJobsPager)

A pager for iterating through `aggregated_list_jobs` requests.

This class thinly wraps an initial
[ListJobsResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListJobsResponse) object, and
provides an `__iter__` method to iterate through its
`jobs` field.

If there are more pages, the `__iter__` method will make additional
`AggregatedListJobs` requests and continue to iterate
through the `jobs` field on the
corresponding responses.

All the usual [ListJobsResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListJobsResponse)
attributes are available on the pager. If multiple requests are made, only
the most recent response is retained, and thus used for attribute lookup.

### [ListJobsAsyncPager](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.jobs_v1_beta3.pagers.ListJobsAsyncPager)

A pager for iterating through `list_jobs` requests.

This class thinly wraps an initial
[ListJobsResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListJobsResponse) object, and
provides an `__aiter__` method to iterate through its
`jobs` field.

If there are more pages, the `__aiter__` method will make additional
`ListJobs` requests and continue to iterate
through the `jobs` field on the
corresponding responses.

All the usual [ListJobsResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListJobsResponse)
attributes are available on the pager. If multiple requests are made, only
the most recent response is retained, and thus used for attribute lookup.

### [ListJobsPager](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.jobs_v1_beta3.pagers.ListJobsPager)

A pager for iterating through `list_jobs` requests.

This class thinly wraps an initial
[ListJobsResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListJobsResponse) object, and
provides an `__iter__` method to iterate through its
`jobs` field.

If there are more pages, the `__iter__` method will make additional
`ListJobs` requests and continue to iterate
through the `jobs` field on the
corresponding responses.

All the usual [ListJobsResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListJobsResponse)
attributes are available on the pager. If multiple requests are made, only
the most recent response is retained, and thus used for attribute lookup.

### [MessagesV1Beta3AsyncClient](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.messages_v1_beta3.MessagesV1Beta3AsyncClient)

The Dataflow Messages API is used to monitor the progress of
Dataflow jobs.

### [MessagesV1Beta3Client](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.messages_v1_beta3.MessagesV1Beta3Client)

The Dataflow Messages API is used to monitor the progress of
Dataflow jobs.

### [ListJobMessagesAsyncPager](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.messages_v1_beta3.pagers.ListJobMessagesAsyncPager)

A pager for iterating through `list_job_messages` requests.

This class thinly wraps an initial
[ListJobMessagesResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListJobMessagesResponse) object, and
provides an `__aiter__` method to iterate through its
`job_messages` field.

If there are more pages, the `__aiter__` method will make additional
`ListJobMessages` requests and continue to iterate
through the `job_messages` field on the
corresponding responses.

All the usual [ListJobMessagesResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListJobMessagesResponse)
attributes are available on the pager. If multiple requests are made, only
the most recent response is retained, and thus used for attribute lookup.

### [ListJobMessagesPager](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.messages_v1_beta3.pagers.ListJobMessagesPager)

A pager for iterating through `list_job_messages` requests.

This class thinly wraps an initial
[ListJobMessagesResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListJobMessagesResponse) object, and
provides an `__iter__` method to iterate through its
`job_messages` field.

If there are more pages, the `__iter__` method will make additional
`ListJobMessages` requests and continue to iterate
through the `job_messages` field on the
corresponding responses.

All the usual [ListJobMessagesResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListJobMessagesResponse)
attributes are available on the pager. If multiple requests are made, only
the most recent response is retained, and thus used for attribute lookup.

### [MetricsV1Beta3AsyncClient](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.metrics_v1_beta3.MetricsV1Beta3AsyncClient)

The Dataflow Metrics API lets you monitor the progress of
Dataflow jobs.

### [MetricsV1Beta3Client](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.metrics_v1_beta3.MetricsV1Beta3Client)

The Dataflow Metrics API lets you monitor the progress of
Dataflow jobs.

### [GetJobExecutionDetailsAsyncPager](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.metrics_v1_beta3.pagers.GetJobExecutionDetailsAsyncPager)

A pager for iterating through `get_job_execution_details` requests.

This class thinly wraps an initial
[JobExecutionDetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.JobExecutionDetails) object, and
provides an `__aiter__` method to iterate through its
`stages` field.

If there are more pages, the `__aiter__` method will make additional
`GetJobExecutionDetails` requests and continue to iterate
through the `stages` field on the
corresponding responses.

All the usual [JobExecutionDetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.JobExecutionDetails)
attributes are available on the pager. If multiple requests are made, only
the most recent response is retained, and thus used for attribute lookup.

### [GetJobExecutionDetailsPager](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.metrics_v1_beta3.pagers.GetJobExecutionDetailsPager)

A pager for iterating through `get_job_execution_details` requests.

This class thinly wraps an initial
[JobExecutionDetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.JobExecutionDetails) object, and
provides an `__iter__` method to iterate through its
`stages` field.

If there are more pages, the `__iter__` method will make additional
`GetJobExecutionDetails` requests and continue to iterate
through the `stages` field on the
corresponding responses.

All the usual [JobExecutionDetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.JobExecutionDetails)
attributes are available on the pager. If multiple requests are made, only
the most recent response is retained, and thus used for attribute lookup.

### [GetStageExecutionDetailsAsyncPager](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.metrics_v1_beta3.pagers.GetStageExecutionDetailsAsyncPager)

A pager for iterating through `get_stage_execution_details` requests.

This class thinly wraps an initial
[StageExecutionDetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StageExecutionDetails) object, and
provides an `__aiter__` method to iterate through its
`workers` field.

If there are more pages, the `__aiter__` method will make additional
`GetStageExecutionDetails` requests and continue to iterate
through the `workers` field on the
corresponding responses.

All the usual [StageExecutionDetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StageExecutionDetails)
attributes are available on the pager. If multiple requests are made, only
the most recent response is retained, and thus used for attribute lookup.

### [GetStageExecutionDetailsPager](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.metrics_v1_beta3.pagers.GetStageExecutionDetailsPager)

A pager for iterating through `get_stage_execution_details` requests.

This class thinly wraps an initial
[StageExecutionDetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StageExecutionDetails) object, and
provides an `__iter__` method to iterate through its
`workers` field.

If there are more pages, the `__iter__` method will make additional
`GetStageExecutionDetails` requests and continue to iterate
through the `workers` field on the
corresponding responses.

All the usual [StageExecutionDetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StageExecutionDetails)
attributes are available on the pager. If multiple requests are made, only
the most recent response is retained, and thus used for attribute lookup.

### [SnapshotsV1Beta3AsyncClient](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.snapshots_v1_beta3.SnapshotsV1Beta3AsyncClient)

Provides methods to manage snapshots of Google Cloud Dataflow
jobs.

### [SnapshotsV1Beta3Client](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.snapshots_v1_beta3.SnapshotsV1Beta3Client)

Provides methods to manage snapshots of Google Cloud Dataflow
jobs.

### [TemplatesServiceAsyncClient](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.templates_service.TemplatesServiceAsyncClient)

Provides a method to create Cloud Dataflow jobs from
templates.

### [TemplatesServiceClient](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.templates_service.TemplatesServiceClient)

Provides a method to create Cloud Dataflow jobs from
templates.

### [AutoscalingAlgorithm](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.AutoscalingAlgorithm)

Specifies the algorithm used to determine the number of
worker processes to run at any given point in time, based on the
amount of data left to process, the number of workers, and how
quickly existing workers are processing data.

### [AutoscalingEvent](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.AutoscalingEvent)

A structured message reporting an autoscaling decision made
by the Dataflow service.

### [AutoscalingEventType](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.AutoscalingEvent.AutoscalingEventType)

Indicates the type of autoscaling event.

### [AutoscalingSettings](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.AutoscalingSettings)

Settings for WorkerPool autoscaling.

### [BigQueryIODetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.BigQueryIODetails)

Metadata for a BigQuery connector used by the job.

### [BigTableIODetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.BigTableIODetails)

Metadata for a Cloud Bigtable connector used by the job.

### [CheckActiveJobsRequest](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.CheckActiveJobsRequest)

Request to check is active jobs exists for a project

### [CheckActiveJobsResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.CheckActiveJobsResponse)

Response for CheckActiveJobsRequest.

### [ComputationTopology](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ComputationTopology)

All configuration data for a particular Computation.

### [ContainerSpec](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ContainerSpec)

Container Spec.

### [CreateJobFromTemplateRequest](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.CreateJobFromTemplateRequest)

A request to create a Cloud Dataflow job from a template.

.. _oneof: <https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields>

### [ParametersEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.CreateJobFromTemplateRequest.ParametersEntry)

The abstract base class for a message.

### [CreateJobRequest](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.CreateJobRequest)

Request to create a Cloud Dataflow job.

### [CustomSourceLocation](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.CustomSourceLocation)

Identifies the location of a custom souce.

### [DataDiskAssignment](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.DataDiskAssignment)

Data disk assignment for a given VM instance.

### [DataSamplingConfig](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.DataSamplingConfig)

Configuration options for sampling elements.

### [DataSamplingBehavior](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.DataSamplingConfig.DataSamplingBehavior)

The following enum defines what to sample for a running job.

### [DatastoreIODetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.DatastoreIODetails)

Metadata for a Datastore connector used by the job.

### [DebugOptions](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.DebugOptions)

Describes any options that have an effect on the debugging of
pipelines.

### [DefaultPackageSet](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.DefaultPackageSet)

The default set of packages to be staged on a pool of
workers.

### [DeleteSnapshotRequest](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.DeleteSnapshotRequest)

Request to delete a snapshot.

### [DeleteSnapshotResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.DeleteSnapshotResponse)

Response from deleting a snapshot.

### [Disk](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.Disk)

Describes the data disk used by a workflow job.

### [DisplayData](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.DisplayData)

Data provided with a pipeline or transform to provide
descriptive info.

This message has `oneof`_ fields (mutually exclusive fields).
For each oneof, at most one member field can be set at the same time.
Setting any member of the oneof automatically clears all other
members.

.. _oneof: <https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields>

### [DynamicTemplateLaunchParams](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.DynamicTemplateLaunchParams)

Parameters to pass when launching a dynamic template.

### [Environment](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.Environment)

Describes the environment in which a Dataflow Job runs.

### [ExecutionStageState](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ExecutionStageState)

A message describing the state of a particular execution
stage.

### [ExecutionStageSummary](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ExecutionStageSummary)

Description of the composing transforms, names/ids, and
input/outputs of a stage of execution. Some composing
transforms and sources may have been generated by the Dataflow
service during execution planning.

### [ComponentSource](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ExecutionStageSummary.ComponentSource)

Description of an interstitial value between transforms in an
execution stage.

### [ComponentTransform](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ExecutionStageSummary.ComponentTransform)

Description of a transform executed as part of an execution
stage.

### [StageSource](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ExecutionStageSummary.StageSource)

Description of an input or output of an execution stage.

### [ExecutionState](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ExecutionState)

The state of some component of job execution.

### [FailedLocation](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.FailedLocation)

Indicates which [regional endpoint](https://cloud.google.com/dataflow/docs/concepts/regional-endpoints)
failed to respond to a request for data.

### [FileIODetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.FileIODetails)

Metadata for a File connector used by the job.

### [FlexResourceSchedulingGoal](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.FlexResourceSchedulingGoal)

Specifies the resource to optimize for in Flexible Resource
Scheduling.

### [FlexTemplateRuntimeEnvironment](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.FlexTemplateRuntimeEnvironment)

The environment values to be set at runtime for flex
template.

.. _oneof: <https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields>

### [AdditionalUserLabelsEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.FlexTemplateRuntimeEnvironment.AdditionalUserLabelsEntry)

The abstract base class for a message.

### [GetJobExecutionDetailsRequest](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.GetJobExecutionDetailsRequest)

Request to get job execution details.

### [GetJobMetricsRequest](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.GetJobMetricsRequest)

Request to get job metrics.

### [GetJobRequest](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.GetJobRequest)

Request to get the state of a Cloud Dataflow job.

### [GetSnapshotRequest](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.GetSnapshotRequest)

Request to get information about a snapshot

### [GetStageExecutionDetailsRequest](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.GetStageExecutionDetailsRequest)

Request to get information about a particular execution stage
of a job. Currently only tracked for Batch jobs.

### [GetTemplateRequest](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.GetTemplateRequest)

A request to retrieve a Cloud Dataflow job template.

.. _oneof: <https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields>

### [TemplateView](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.GetTemplateRequest.TemplateView)

The various views of a template that may be retrieved.

### [GetTemplateResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.GetTemplateResponse)

The response to a GetTemplate request.

### [TemplateType](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.GetTemplateResponse.TemplateType)

Template Type.

### [HotKeyDebuggingInfo](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.HotKeyDebuggingInfo)

Information useful for debugging a hot key detection.

### [DetectedHotKeysEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.HotKeyDebuggingInfo.DetectedHotKeysEntry)

The abstract base class for a message.

### [HotKeyInfo](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.HotKeyDebuggingInfo.HotKeyInfo)

Information about a hot key.

### [InvalidTemplateParameters](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.InvalidTemplateParameters)

Used in the error_details field of a google.rpc.Status message, this
indicates problems with the template parameter.

### [ParameterViolation](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.InvalidTemplateParameters.ParameterViolation)

A specific template-parameter violation.

### [Job](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.Job)

Defines a job to be run by the Cloud Dataflow service. Do not
enter confidential information when you supply string values
using the API.

.. _oneof: <https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields>

### [LabelsEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.Job.LabelsEntry)

The abstract base class for a message.

### [TransformNameMappingEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.Job.TransformNameMappingEntry)

The abstract base class for a message.

### [JobExecutionDetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.JobExecutionDetails)

Information about the execution of a job.

### [JobExecutionInfo](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.JobExecutionInfo)

Additional information about how a Cloud Dataflow job will be
executed that isn't contained in the submitted job.

### [StagesEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.JobExecutionInfo.StagesEntry)

The abstract base class for a message.

### [JobExecutionStageInfo](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.JobExecutionStageInfo)

Contains information about how a particular
`google.dataflow.v1beta3.Step][google.dataflow.v1beta3.Step]` will be
executed.

### [JobMessage](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.JobMessage)

A particular message pertaining to a Dataflow job.

### [JobMessageImportance](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.JobMessageImportance)

Indicates the importance of the message.

### [JobMetadata](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.JobMetadata)

Metadata available primarily for filtering jobs. Will be
included in the ListJob response and Job SUMMARY view.

### [UserDisplayPropertiesEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.JobMetadata.UserDisplayPropertiesEntry)

The abstract base class for a message.

### [JobMetrics](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.JobMetrics)

JobMetrics contains a collection of metrics describing the detailed
progress of a Dataflow job. Metrics correspond to user-defined and
system-defined metrics in the job. For more information, see
[Dataflow job metrics](https://cloud.google.com/dataflow/docs/guides/using-monitoring-intf).

This resource captures only the most recent values of each metric;
time-series data can be queried for them (under the same metric
names) from Cloud Monitoring.

### [JobState](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.JobState)

Describes the overall state of a
`google.dataflow.v1beta3.Job][google.dataflow.v1beta3.Job]`.

### [JobType](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.JobType)

Specifies the processing model used by a
\[google.dataflow.v1beta3.Job\], which determines the way the Job is
managed by the Cloud Dataflow service (how workers are scheduled,
how inputs are sharded, etc).

### [JobView](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.JobView)

Selector for how much information is returned in Job
responses.

        Project ID, Job ID, job name, job type, job
        status, start/end time, and Cloud SDK version
        details.
    JOB_VIEW_ALL (2):
        Request all information available for this job. When the job
        is in `JOB_STATE_PENDING`, the job has been created but is
        not yet running, and not all job information is available.
        For complete job information, wait until the job in is
        `JOB_STATE_RUNNING`. For more information, see
        `JobState <https://cloud.google.com/dataflow/docs/reference/rest/v1b3/projects.jobs#jobstate>`__.
    JOB_VIEW_DESCRIPTION (3):
        Request summary info and limited job
        description data for steps, labels and
        environment.

### [KeyRangeDataDiskAssignment](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.KeyRangeDataDiskAssignment)

Data disk assignment information for a specific key-range of
a sharded computation.
Currently we only support UTF-8 character splits to simplify
encoding into JSON.

### [KeyRangeLocation](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.KeyRangeLocation)

Location information for a specific key-range of a sharded
computation. Currently we only support UTF-8 character splits to
simplify encoding into JSON.

### [KindType](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.KindType)

Type of transform or stage operation.

### [LaunchFlexTemplateParameter](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.LaunchFlexTemplateParameter)

Launch FlexTemplate Parameter.

This message has `oneof`_ fields (mutually exclusive fields).
For each oneof, at most one member field can be set at the same time.
Setting any member of the oneof automatically clears all other
members.

.. _oneof: <https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields>

### [LaunchOptionsEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.LaunchFlexTemplateParameter.LaunchOptionsEntry)

The abstract base class for a message.

### [ParametersEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.LaunchFlexTemplateParameter.ParametersEntry)

The abstract base class for a message.

### [TransformNameMappingsEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.LaunchFlexTemplateParameter.TransformNameMappingsEntry)

The abstract base class for a message.

### [LaunchFlexTemplateRequest](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.LaunchFlexTemplateRequest)

A request to launch a Cloud Dataflow job from a FlexTemplate.

### [LaunchFlexTemplateResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.LaunchFlexTemplateResponse)

Response to the request to launch a job from Flex Template.

### [LaunchTemplateParameters](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.LaunchTemplateParameters)

Parameters to provide to the template being launched. Note that the
[metadata in the pipeline code](https://cloud.google.com/dataflow/docs/guides/templates/creating-templates#metadata)
determines which runtime parameters are valid.

### [ParametersEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.LaunchTemplateParameters.ParametersEntry)

The abstract base class for a message.

### [TransformNameMappingEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.LaunchTemplateParameters.TransformNameMappingEntry)

The abstract base class for a message.

### [LaunchTemplateRequest](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.LaunchTemplateRequest)

A request to launch a template.

This message has `oneof`_ fields (mutually exclusive fields).
For each oneof, at most one member field can be set at the same time.
Setting any member of the oneof automatically clears all other
members.

.. _oneof: <https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields>

### [LaunchTemplateResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.LaunchTemplateResponse)

Response to the request to launch a template.

### [ListJobMessagesRequest](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListJobMessagesRequest)

Request to list job messages. Up to max_results messages will be
returned in the time range specified starting with the oldest
messages first. If no time range is specified the results with start
with the oldest message.

### [ListJobMessagesResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListJobMessagesResponse)

Response to a request to list job messages.

### [ListJobsRequest](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListJobsRequest)

Request to list Cloud Dataflow jobs.

.. _oneof: <https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields>

### [Filter](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListJobsRequest.Filter)

This field filters out and returns jobs in the specified job
state. The order of data returned is determined by the filter
used, and is subject to change.

### [ListJobsResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListJobsResponse)

Response to a request to list Cloud Dataflow jobs in a
project. This might be a partial response, depending on the page
size in the ListJobsRequest. However, if the project does not
have any jobs, an instance of ListJobsResponse is not returned
and the requests's response body is empty {}.

### [ListSnapshotsRequest](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListSnapshotsRequest)

Request to list snapshots.

### [ListSnapshotsResponse](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ListSnapshotsResponse)

List of snapshots.

### [MetricStructuredName](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.MetricStructuredName)

Identifies a metric, by describing the source which generated
the metric.

### [ContextEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.MetricStructuredName.ContextEntry)

The abstract base class for a message.

### [MetricUpdate](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.MetricUpdate)

Describes the state of a metric.

### [MountedDataDisk](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.MountedDataDisk)

Describes mounted data disk.

### [Package](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.Package)

The packages that must be installed in order for a worker to
run the steps of the Cloud Dataflow job that will be assigned to
its worker pool.

This is the mechanism by which the Cloud Dataflow SDK causes
code to be loaded onto the workers. For example, the Cloud
Dataflow Java SDK might use this to install jars containing the
user's code and all of the various dependencies (libraries, data
files, etc.) required in order for that code to run.

### [ParameterMetadata](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ParameterMetadata)

Metadata for a specific parameter.

### [CustomMetadataEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ParameterMetadata.CustomMetadataEntry)

The abstract base class for a message.

### [ParameterMetadataEnumOption](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ParameterMetadataEnumOption)

ParameterMetadataEnumOption specifies the option shown in the
enum form.

### [ParameterType](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ParameterType)

ParameterType specifies what kind of input we need for this
parameter.

### [PipelineDescription](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.PipelineDescription)

A descriptive representation of submitted pipeline as well as
the executed form. This data is provided by the Dataflow
service for ease of visualizing the pipeline and interpreting
Dataflow provided metrics.

### [ProgressTimeseries](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ProgressTimeseries)

Information about the progress of some component of job
execution.

### [Point](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ProgressTimeseries.Point)

A point in the timeseries.

### [PubSubIODetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.PubSubIODetails)

Metadata for a Pub/Sub connector used by the job.

### [PubsubLocation](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.PubsubLocation)

Identifies a pubsub location to use for transferring data
into or out of a streaming Dataflow job.

### [PubsubSnapshotMetadata](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.PubsubSnapshotMetadata)

Represents a Pubsub snapshot.

### [RuntimeEnvironment](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.RuntimeEnvironment)

The environment values to set at runtime.

.. _oneof: <https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields>

### [AdditionalUserLabelsEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.RuntimeEnvironment.AdditionalUserLabelsEntry)

The abstract base class for a message.

### [RuntimeMetadata](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.RuntimeMetadata)

RuntimeMetadata describing a runtime environment.

### [RuntimeUpdatableParams](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.RuntimeUpdatableParams)

Additional job parameters that can only be updated during
runtime using the projects.jobs.update method. These fields have
no effect when specified during job creation.

.. _oneof: <https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields>

### [SDKInfo](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.SDKInfo)

SDK Information.

### [Language](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.SDKInfo.Language)

SDK Language.

### [SdkBug](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.SdkBug)

A bug found in the Dataflow SDK.

### [Severity](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.SdkBug.Severity)

Indicates the severity of the bug. Other severities may be
added to this list in the future.

### [Type](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.SdkBug.Type)

Nature of the issue, ordered from least severe to most. Other
bug types may be added to this list in the future.

### [SdkHarnessContainerImage](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.SdkHarnessContainerImage)

Defines an SDK harness container for executing Dataflow
pipelines.

### [SdkVersion](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.SdkVersion)

The version of the SDK used to run the job.

### [SdkSupportStatus](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.SdkVersion.SdkSupportStatus)

The support status of the SDK used to run the job.

### [ServiceResources](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ServiceResources)

Resources used by the Dataflow Service to run the job.

### [ShuffleMode](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.ShuffleMode)

Specifies the shuffle mode used by a \[google.dataflow.v1beta3.Job\],
which determines the approach data is shuffled during processing.
More details in:
<https://cloud.google.com/dataflow/docs/guides/deploying-a-pipeline#dataflow-shuffle>

### [Snapshot](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.Snapshot)

Represents a snapshot of a job.

### [SnapshotJobRequest](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.SnapshotJobRequest)

Request to create a snapshot of a job.

### [SnapshotState](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.SnapshotState)

Snapshot state.

### [SpannerIODetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.SpannerIODetails)

Metadata for a Spanner connector used by the job.

### [StageExecutionDetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StageExecutionDetails)

Information about the workers and work items within a stage.

### [StageSummary](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StageSummary)

Information about a particular execution stage of a job.

### [StateFamilyConfig](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StateFamilyConfig)

State family configuration.

### [Step](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.Step)

Defines a particular step within a Cloud Dataflow job.

A job consists of multiple steps, each of which performs some
specific operation as part of the overall job. Data is typically
passed from one step to another as part of the job.

**Note:** The properties of this object are not stable and might
change.

Here's an example of a sequence of steps which together implement a
Map-Reduce job:

- Read a collection of data from some source, parsing the
  collection's elements.

- Validate the elements.

- Apply a user-defined function to map each element to some value
  and extract an element-specific key value.

- Group elements with the same key into a single element with that
  key, transforming a multiply-keyed collection into a
  uniquely-keyed collection.

- Write the elements out to some data sink.

Note that the Cloud Dataflow service may be used to run many
different types of jobs, not just Map-Reduce.

### [Straggler](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.Straggler)

Information for a straggler.

This message has `oneof`_ fields (mutually exclusive fields).
For each oneof, at most one member field can be set at the same time.
Setting any member of the oneof automatically clears all other
members.

.. _oneof: <https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields>

### [StragglerInfo](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StragglerInfo)

Information useful for straggler identification and
debugging.

### [CausesEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StragglerInfo.CausesEntry)

The abstract base class for a message.

### [StragglerDebuggingInfo](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StragglerInfo.StragglerDebuggingInfo)

Information useful for debugging a straggler. Each type will
provide specialized debugging information relevant for a
particular cause. The StragglerDebuggingInfo will be 1:1 mapping
to the StragglerCause enum.

.. _oneof: <https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields>

### [StragglerSummary](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StragglerSummary)

Summarized straggler identification details.

### [StragglerCauseCountEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StragglerSummary.StragglerCauseCountEntry)

The abstract base class for a message.

### [StreamLocation](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StreamLocation)

Describes a stream of data, either as input to be processed
or as output of a streaming Dataflow job.

This message has `oneof`_ fields (mutually exclusive fields).
For each oneof, at most one member field can be set at the same time.
Setting any member of the oneof automatically clears all other
members.

.. _oneof: <https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields>

### [StreamingApplianceSnapshotConfig](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StreamingApplianceSnapshotConfig)

Streaming appliance snapshot configuration.

### [StreamingComputationRanges](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StreamingComputationRanges)

Describes full or partial data disk assignment information of
the computation ranges.

### [StreamingMode](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StreamingMode)

Specifies the Streaming Engine message processing guarantees.
Reduces cost and latency but might result in duplicate messages
written to storage. Designed to run simple mapping streaming ETL
jobs at the lowest cost. For example, Change Data Capture (CDC) to
BigQuery is a canonical use case. For more information, see `Set the
pipeline streaming
mode <https://cloud.google.com/dataflow/docs/guides/streaming-modes>`__.

### [StreamingSideInputLocation](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StreamingSideInputLocation)

Identifies the location of a streaming side input.

### [StreamingStageLocation](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StreamingStageLocation)

Identifies the location of a streaming computation stage, for
stage-to-stage communication.

### [StreamingStragglerInfo](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StreamingStragglerInfo)

Information useful for streaming straggler identification and
debugging.

### [StructuredMessage](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StructuredMessage)

A rich message format, including a human readable string, a
key for identifying the message, and structured data associated
with the message for programmatic consumption.

### [Parameter](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.StructuredMessage.Parameter)

Structured data associated with this message.

### [TaskRunnerSettings](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.TaskRunnerSettings)

Taskrunner configuration settings.

### [TeardownPolicy](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.TeardownPolicy)

Specifies what happens to a resource when a Cloud Dataflow
`google.dataflow.v1beta3.Job][google.dataflow.v1beta3.Job]` has
completed.

### [TemplateMetadata](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.TemplateMetadata)

Metadata describing a template.

### [TopologyConfig](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.TopologyConfig)

Global topology of the streaming Dataflow job, including all
computations and their sharded locations.

### [UserStageToComputationNameMapEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.TopologyConfig.UserStageToComputationNameMapEntry)

The abstract base class for a message.

### [TransformSummary](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.TransformSummary)

Description of the type, names/ids, and input/outputs for a
transform.

### [UpdateJobRequest](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.UpdateJobRequest)

Request to update a Cloud Dataflow job.

.. _oneof: <https://proto-plus-python.readthedocs.io/en/stable/fields.html#oneofs-mutually-exclusive-fields>

### [WorkItemDetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.WorkItemDetails)

Information about an individual work item execution.

### [WorkerDetails](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.WorkerDetails)

Information about a worker

### [WorkerIPAddressConfiguration](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.WorkerIPAddressConfiguration)

Specifies how to allocate IP addresses to worker machines. You can
also use `pipeline
options <https://cloud.google.com/dataflow/docs/reference/pipeline-options#security_and_networking>`__
to specify whether Dataflow workers use external IP addresses.

### [WorkerPool](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.WorkerPool)

Describes one particular pool of Cloud Dataflow workers to be
instantiated by the Cloud Dataflow service in order to perform
the computations required by a job. Note that a workflow job
may use multiple pools, in order to match the various
computational requirements of the various stages of the job.

### [MetadataEntry](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.WorkerPool.MetadataEntry)

The abstract base class for a message.

### [WorkerSettings](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.types.WorkerSettings)

Provides data to pass through to the worker harness.

## Modules

### [pagers](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.jobs_v1_beta3.pagers)

API documentation for `dataflow_v1beta3.services.jobs_v1_beta3.pagers` module.

### [pagers](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.messages_v1_beta3.pagers)

API documentation for `dataflow_v1beta3.services.messages_v1_beta3.pagers` module.

### [pagers](https://docs.cloud.google.com/python/docs/reference/dataflow/latest/google.cloud.dataflow_v1beta3.services.metrics_v1_beta3.pagers)

API documentation for `dataflow_v1beta3.services.metrics_v1_beta3.pagers` module.