NAME

Google::Dataflow::V1beta3::Jobs::Job - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::Job->new(
    id => $value,
);

FIELDS

  • id

    Type: String

  • project_id

    Type: String

  • name

    Type: String

  • type

    Type: Enum (.google.dataflow.v1beta3.JobType)

  • environment

    Type: Message (.google.dataflow.v1beta3.Environment)

  • steps

    Type: Message (.google.dataflow.v1beta3.Step)

  • steps_location

    Type: String

  • current_state

    Type: Enum (.google.dataflow.v1beta3.JobState)

  • current_state_time

    Type: Message (.google.protobuf.Timestamp)

  • requested_state

    Type: Enum (.google.dataflow.v1beta3.JobState)

  • execution_info

    Type: Message (.google.dataflow.v1beta3.JobExecutionInfo)

  • create_time

    Type: Message (.google.protobuf.Timestamp)

  • replace_job_id

    Type: String

  • transform_name_mapping

    Type: Message (.google.dataflow.v1beta3.Job.TransformNameMappingEntry)

  • client_request_id

    Type: String

  • replaced_by_job_id

    Type: String

  • temp_files

    Type: String

  • labels

    Type: Message (.google.dataflow.v1beta3.Job.LabelsEntry)

  • location

    Type: String

  • pipeline_description

    Type: Message (.google.dataflow.v1beta3.PipelineDescription)

  • stage_states

    Type: Message (.google.dataflow.v1beta3.ExecutionStageState)

  • job_metadata

    Type: Message (.google.dataflow.v1beta3.JobMetadata)

  • start_time

    Type: Message (.google.protobuf.Timestamp)

  • created_from_snapshot_id

    Type: String

  • satisfies_pzs

    Type: Bool

  • runtime_updatable_params

    Type: Message (.google.dataflow.v1beta3.RuntimeUpdatableParams)

  • satisfies_pzi

    Type: Bool

  • service_resources

    Type: Message (.google.dataflow.v1beta3.ServiceResources)

  • pausable

    Type: Bool

NAME

Google::Dataflow::V1beta3::Jobs::ServiceResources - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::ServiceResources->new(
    zones => $value,
);

FIELDS

  • zones

    Type: String

NAME

Google::Dataflow::V1beta3::Jobs::RuntimeUpdatableParams - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::RuntimeUpdatableParams->new(
    max_num_workers => $value,
);

FIELDS

  • max_num_workers

    Type: Int32

  • min_num_workers

    Type: Int32

  • worker_utilization_hint

    Type: Double

  • acceptable_backlog_duration

    Type: Message (.google.protobuf.Duration)

  • autoscaling_tier

    Type: String

NAME

Google::Dataflow::V1beta3::Jobs::DatastoreIODetails - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::DatastoreIODetails->new(
    namespace => $value,
);

FIELDS

  • namespace

    Type: String

  • project_id

    Type: String

NAME

Google::Dataflow::V1beta3::Jobs::PubSubIODetails - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::PubSubIODetails->new(
    topic => $value,
);

FIELDS

  • topic

    Type: String

  • subscription

    Type: String

NAME

Google::Dataflow::V1beta3::Jobs::FileIODetails - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::FileIODetails->new(
    file_pattern => $value,
);

FIELDS

  • file_pattern

    Type: String

NAME

Google::Dataflow::V1beta3::Jobs::BigTableIODetails - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::BigTableIODetails->new(
    project_id => $value,
);

FIELDS

  • project_id

    Type: String

  • instance_id

    Type: String

  • table_id

    Type: String

NAME

Google::Dataflow::V1beta3::Jobs::BigQueryIODetails - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::BigQueryIODetails->new(
    table => $value,
);

FIELDS

  • table

    Type: String

  • dataset

    Type: String

  • project_id

    Type: String

  • query

    Type: String

NAME

Google::Dataflow::V1beta3::Jobs::SpannerIODetails - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::SpannerIODetails->new(
    project_id => $value,
);

FIELDS

  • project_id

    Type: String

  • instance_id

    Type: String

  • database_id

    Type: String

NAME

Google::Dataflow::V1beta3::Jobs::SdkVersion - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::SdkVersion->new(
    version => $value,
);

FIELDS

  • version

    Type: String

  • version_display_name

    Type: String

  • sdk_support_status

    Type: Enum (.google.dataflow.v1beta3.SdkVersion.SdkSupportStatus)

  • bugs

    Type: Message (.google.dataflow.v1beta3.SdkBug)

Enum: SdkVersion::SdkSupportStatus

Values:

  • UNKNOWN => 0

  • SUPPORTED => 1

  • STALE => 2

  • DEPRECATED => 3

  • UNSUPPORTED => 4

NAME

Google::Dataflow::V1beta3::Jobs::SdkBug - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::SdkBug->new(
    type => $value,
);

FIELDS

  • type

    Type: Enum (.google.dataflow.v1beta3.SdkBug.Type)

  • severity

    Type: Enum (.google.dataflow.v1beta3.SdkBug.Severity)

  • uri

    Type: String

Enum: SdkBug::Type

Values:

  • TYPE_UNSPECIFIED => 0

  • GENERAL => 1

  • PERFORMANCE => 2

  • DATALOSS => 3

Enum: SdkBug::Severity

Values:

  • SEVERITY_UNSPECIFIED => 0

  • NOTICE => 1

  • WARNING => 2

  • SEVERE => 3

NAME

Google::Dataflow::V1beta3::Jobs::JobMetadata - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::JobMetadata->new(
    sdk_version => $value,
);

FIELDS

  • sdk_version

    Type: Message (.google.dataflow.v1beta3.SdkVersion)

  • spanner_details

    Type: Message (.google.dataflow.v1beta3.SpannerIODetails)

  • bigquery_details

    Type: Message (.google.dataflow.v1beta3.BigQueryIODetails)

  • big_table_details

    Type: Message (.google.dataflow.v1beta3.BigTableIODetails)

  • pubsub_details

    Type: Message (.google.dataflow.v1beta3.PubSubIODetails)

  • file_details

    Type: Message (.google.dataflow.v1beta3.FileIODetails)

  • datastore_details

    Type: Message (.google.dataflow.v1beta3.DatastoreIODetails)

  • user_display_properties

    Type: Message (.google.dataflow.v1beta3.JobMetadata.UserDisplayPropertiesEntry)

NAME

Google::Dataflow::V1beta3::Jobs::ExecutionStageState - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::ExecutionStageState->new(
    execution_stage_name => $value,
);

FIELDS

  • execution_stage_name

    Type: String

  • execution_stage_state

    Type: Enum (.google.dataflow.v1beta3.JobState)

  • current_state_time

    Type: Message (.google.protobuf.Timestamp)

NAME

Google::Dataflow::V1beta3::Jobs::PipelineDescription - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::PipelineDescription->new(
    original_pipeline_transform => $value,
);

FIELDS

  • original_pipeline_transform

    Type: Message (.google.dataflow.v1beta3.TransformSummary)

  • execution_pipeline_stage

    Type: Message (.google.dataflow.v1beta3.ExecutionStageSummary)

  • display_data

    Type: Message (.google.dataflow.v1beta3.DisplayData)

  • step_names_hash

    Type: String

NAME

Google::Dataflow::V1beta3::Jobs::TransformSummary - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::TransformSummary->new(
    kind => $value,
);

FIELDS

  • kind

    Type: Enum (.google.dataflow.v1beta3.KindType)

  • id

    Type: String

  • name

    Type: String

  • display_data

    Type: Message (.google.dataflow.v1beta3.DisplayData)

  • output_collection_name

    Type: String

  • input_collection_name

    Type: String

NAME

Google::Dataflow::V1beta3::Jobs::ExecutionStageSummary - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::ExecutionStageSummary->new(
    name => $value,
);

FIELDS

  • name

    Type: String

  • id

    Type: String

  • kind

    Type: Enum (.google.dataflow.v1beta3.KindType)

  • input_source

    Type: Message (.google.dataflow.v1beta3.ExecutionStageSummary.StageSource)

  • output_source

    Type: Message (.google.dataflow.v1beta3.ExecutionStageSummary.StageSource)

  • prerequisite_stage

    Type: String

  • component_transform

    Type: Message (.google.dataflow.v1beta3.ExecutionStageSummary.ComponentTransform)

  • component_source

    Type: Message (.google.dataflow.v1beta3.ExecutionStageSummary.ComponentSource)

NAME

Google::Dataflow::V1beta3::Jobs::DisplayData - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::DisplayData->new(
    key => $value,
);

FIELDS

  • key

    Type: String

  • namespace

    Type: String

  • str_value

    Type: String

  • int64_value

    Type: Int64

  • float_value

    Type: Float

  • java_class_value

    Type: String

  • timestamp_value

    Type: Message (.google.protobuf.Timestamp)

  • duration_value

    Type: Message (.google.protobuf.Duration)

  • bool_value

    Type: Bool

  • short_str_value

    Type: String

  • url

    Type: String

  • label

    Type: String

NAME

Google::Dataflow::V1beta3::Jobs::Step - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::Step->new(
    kind => $value,
);

FIELDS

  • kind

    Type: String

  • name

    Type: String

  • properties

    Type: Message (.google.protobuf.Struct)

NAME

Google::Dataflow::V1beta3::Jobs::JobExecutionInfo - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::JobExecutionInfo->new(
    stages => $value,
);

FIELDS

  • stages

    Type: Message (.google.dataflow.v1beta3.JobExecutionInfo.StagesEntry)

NAME

Google::Dataflow::V1beta3::Jobs::JobExecutionStageInfo - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::JobExecutionStageInfo->new(
    step_name => $value,
);

FIELDS

  • step_name

    Type: String

NAME

Google::Dataflow::V1beta3::Jobs::CreateJobRequest - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::CreateJobRequest->new(
    project_id => $value,
);

FIELDS

  • project_id

    Type: String

  • job

    Type: Message (.google.dataflow.v1beta3.Job)

  • view

    Type: Enum (.google.dataflow.v1beta3.JobView)

  • replace_job_id

    Type: String

  • location

    Type: String

NAME

Google::Dataflow::V1beta3::Jobs::GetJobRequest - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::GetJobRequest->new(
    project_id => $value,
);

FIELDS

  • project_id

    Type: String

  • job_id

    Type: String

  • view

    Type: Enum (.google.dataflow.v1beta3.JobView)

  • location

    Type: String

NAME

Google::Dataflow::V1beta3::Jobs::UpdateJobRequest - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::UpdateJobRequest->new(
    project_id => $value,
);

FIELDS

  • project_id

    Type: String

  • job_id

    Type: String

  • job

    Type: Message (.google.dataflow.v1beta3.Job)

  • location

    Type: String

  • update_mask

    Type: Message (.google.protobuf.FieldMask)

NAME

Google::Dataflow::V1beta3::Jobs::ListJobsRequest - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::ListJobsRequest->new(
    filter => $value,
);

FIELDS

  • filter

    Type: Enum (.google.dataflow.v1beta3.ListJobsRequest.Filter)

  • project_id

    Type: String

  • view

    Type: Enum (.google.dataflow.v1beta3.JobView)

  • page_size

    Type: Int32

  • page_token

    Type: String

  • location

    Type: String

  • name

    Type: String

Enum: ListJobsRequest::Filter

Values:

  • UNKNOWN => 0

  • ALL => 1

  • TERMINATED => 2

  • ACTIVE => 3

NAME

Google::Dataflow::V1beta3::Jobs::FailedLocation - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::FailedLocation->new(
    name => $value,
);

FIELDS

  • name

    Type: String

NAME

Google::Dataflow::V1beta3::Jobs::ListJobsResponse - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::ListJobsResponse->new(
    jobs => $value,
);

FIELDS

  • jobs

    Type: Message (.google.dataflow.v1beta3.Job)

  • next_page_token

    Type: String

  • failed_location

    Type: Message (.google.dataflow.v1beta3.FailedLocation)

NAME

Google::Dataflow::V1beta3::Jobs::SnapshotJobRequest - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::SnapshotJobRequest->new(
    project_id => $value,
);

FIELDS

  • project_id

    Type: String

  • job_id

    Type: String

  • ttl

    Type: Message (.google.protobuf.Duration)

  • location

    Type: String

  • snapshot_sources

    Type: Bool

  • description

    Type: String

NAME

Google::Dataflow::V1beta3::Jobs::CheckActiveJobsRequest - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::CheckActiveJobsRequest->new(
    project_id => $value,
);

FIELDS

  • project_id

    Type: String

NAME

Google::Dataflow::V1beta3::Jobs::CheckActiveJobsResponse - Compiled Protocol Buffers message class

SYNOPSIS

use Google::Dataflow::V1beta3::Jobs;

my $msg = Google::Dataflow::V1beta3::Jobs::CheckActiveJobsResponse->new(
    active_jobs_exist => $value,
);

FIELDS

  • active_jobs_exist

    Type: Bool

NAME

Google::Dataflow::V1beta3::Jobs::JobsV1beta3Client - Client stub representing the remote JobsV1Beta3 service

DESCRIPTION

This class acts as a local client stub for the remote gRPC service. It delegates call dispatching to an underlying Google::gRPC::Client instance, ensuring type-safe request parsing and response mapping.

CONFIGURATION AND ENVIRONMENT

target

The endpoint target address. Defaults to dataflow.googleapis.com:443.

credentials

The authentication credentials provider. Defaults to application default credentials via Google::Auth.

NAME

Google::Dataflow::V1beta3::Jobs - Protocol Buffers schema definition

DESCRIPTION

Auto-generated Protocol Buffers schema definition class.

LICENSE AND COPYRIGHT

Copyright (C) 2026 Google LLC

This program is released under the Apache 2.0 license.