Package types (0.8.14)

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.

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

Settings for WorkerPool autoscaling.

Metadata for a BigQuery connector used by the job.

Metadata for a Cloud Bigtable connector used by the job.

Request to check is active jobs exists for a project

Response for CheckActiveJobsRequest.

All configuration data for a particular Computation.

Container Spec.

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

Request to create a Cloud Dataflow job.

Identifies the location of a custom souce.

Data disk assignment for a given VM instance.

Metadata for a Datastore connector used by the job.

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

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

Request to delete a snapshot.

Response from deleting a snapshot.

Describes the data disk used by a workflow job.

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

Params which should be passed when launching a dynamic template.

Describes the environment in which a Dataflow Job runs.

A message describing the state of a particular execution stage.

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.

The state of some component of job execution.

Indicates which regional endpoint failed to respond to a request for data.

Metadata for a File connector used by the job.

Specifies the resource to optimize for in Flexible Resource Scheduling.

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

Request to get job execution details.

Request to get job metrics.

Request to get the state of a Cloud Dataflow job.

Request to get information about a snapshot

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

A request to retrieve a Cloud Dataflow job template.

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

The response to a GetTemplate request.

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

Defines a job to be run by the Cloud Dataflow service.

Information about the execution of a job.

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

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

A particular message pertaining to a Dataflow job.

Indicates the importance of the message.

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

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.

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.

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

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).

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.
JOB_VIEW_DESCRIPTION (3):
    Request summary info and limited job
    description data for steps, labels and
    environment.

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.

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

Type of transform or stage operation.

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

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

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

Parameters to provide to the template being launched.

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

Response to the request to launch a template.

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.

Response to a request to list job messages.

Request to list Cloud Dataflow jobs.

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 {}.

Request to list snapshots.

List of snapshots.

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

Describes the state of a metric.

Describes mounted data disk.

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.

Metadata for a specific parameter.

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

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.

Information about the progress of some component of job execution.

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

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

Represents a Pubsub snapshot.

The environment values to set at runtime.

RuntimeMetadata describing a runtime environment.

SDK Information.

Defines a SDK harness container for executing Dataflow pipelines.

The version of the SDK used to run the job.

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

Represents a snapshot of a job.

Request to create a snapshot of a job.

Snapshot state.

Metadata for a Spanner connector used by the job.

Information about the workers and work items within a stage.

Information about a particular execution stage of a job.

State family configuration.

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.

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.

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

Streaming appliance snapshot configuration.

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

Identifies the location of a streaming side input.

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

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.

Taskrunner configuration settings.

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

Metadata describing a template.

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

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

Request to update a Cloud Dataflow job.

Information about an individual work item execution.

Information about a worker

Specifies how IP addresses should be allocated to the worker machines.

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.

Provides data to pass through to the worker harness.