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=> 0SUPPORTED=> 1STALE=> 2DEPRECATED=> 3UNSUPPORTED=> 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=> 0GENERAL=> 1PERFORMANCE=> 2DATALOSS=> 3
Enum: SdkBug::Severity
Values:
SEVERITY_UNSPECIFIED=> 0NOTICE=> 1WARNING=> 2SEVERE=> 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=> 0ALL=> 1TERMINATED=> 2ACTIVE=> 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.