Dataflow V1beta3 API - Class Google::Cloud::Dataflow::V1beta3::RuntimeUpdatableParams (v0.13.0)

Reference documentation and code samples for the Dataflow V1beta3 API class Google::Cloud::Dataflow::V1beta3::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.

Inherits

  • Object

Extended By

  • Google::Protobuf::MessageExts::ClassMethods

Includes

  • Google::Protobuf::MessageExts

Methods

#max_num_workers

def max_num_workers() -> ::Integer
Returns
  • (::Integer) — The maximum number of workers to cap autoscaling at. This field is currently only supported for Streaming Engine jobs.

#max_num_workers=

def max_num_workers=(value) -> ::Integer
Parameter
  • value (::Integer) — The maximum number of workers to cap autoscaling at. This field is currently only supported for Streaming Engine jobs.
Returns
  • (::Integer) — The maximum number of workers to cap autoscaling at. This field is currently only supported for Streaming Engine jobs.

#min_num_workers

def min_num_workers() -> ::Integer
Returns
  • (::Integer) — The minimum number of workers to scale down to. This field is currently only supported for Streaming Engine jobs.

#min_num_workers=

def min_num_workers=(value) -> ::Integer
Parameter
  • value (::Integer) — The minimum number of workers to scale down to. This field is currently only supported for Streaming Engine jobs.
Returns
  • (::Integer) — The minimum number of workers to scale down to. This field is currently only supported for Streaming Engine jobs.

#worker_utilization_hint

def worker_utilization_hint() -> ::Float
Returns
  • (::Float) — Target worker utilization, compared against the aggregate utilization of the worker pool by autoscaler, to determine upscaling and downscaling when absent other constraints such as backlog. For more information, see Update an existing pipeline.

#worker_utilization_hint=

def worker_utilization_hint=(value) -> ::Float
Parameter
  • value (::Float) — Target worker utilization, compared against the aggregate utilization of the worker pool by autoscaler, to determine upscaling and downscaling when absent other constraints such as backlog. For more information, see Update an existing pipeline.
Returns
  • (::Float) — Target worker utilization, compared against the aggregate utilization of the worker pool by autoscaler, to determine upscaling and downscaling when absent other constraints such as backlog. For more information, see Update an existing pipeline.