Class: Google::Apis::DatapipelinesV1::GoogleCloudDatapipelinesV1DataflowJobDetails

Inherits:
Object
  • Object
show all
Includes:
Core::Hashable, Core::JsonObjectSupport
Defined in:
lib/google/apis/datapipelines_v1/classes.rb,
lib/google/apis/datapipelines_v1/representations.rb,
lib/google/apis/datapipelines_v1/representations.rb

Overview

Pipeline job details specific to the Dataflow API. This is encapsulated here to allow for more executors to store their specific details separately.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ GoogleCloudDatapipelinesV1DataflowJobDetails

Returns a new instance of GoogleCloudDatapipelinesV1DataflowJobDetails.



48
49
50
 
# File 'lib/google/apis/datapipelines_v1/classes.rb', line 48

def initialize(**args)
   update!(**args)
end

Instance Attribute Details

#current_workers ⇒ Fixnum

Output only. The current number of workers used to run the jobs. Only set to a value if the job is still running. Corresponds to the JSON property currentWorkers

Returns:

  • (Fixnum) 


34
35
36
 
# File 'lib/google/apis/datapipelines_v1/classes.rb', line 34

def current_workers
  @current_workers
end

#resource_info ⇒ Hash<String,Float>

Cached version of all the metrics of interest for the job. This value gets stored here when the job is terminated. As long as the job is running, this field is populated from the Dataflow API. Corresponds to the JSON property resourceInfo

Returns:

  • (Hash<String,Float>) 


41
42
43
 
# File 'lib/google/apis/datapipelines_v1/classes.rb', line 41

def resource_info
  @resource_info
end

#sdk_version ⇒ Google::Apis::DatapipelinesV1::GoogleCloudDatapipelinesV1SdkVersion

The version of the SDK used to run the job. Corresponds to the JSON property sdkVersion

Returns:



46
47
48
 
# File 'lib/google/apis/datapipelines_v1/classes.rb', line 46

def sdk_version
  @sdk_version
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



53
54
55
56
57
 
# File 'lib/google/apis/datapipelines_v1/classes.rb', line 53

def update!(**args)
  @current_workers = args[:current_workers] if args.key?(:current_workers)
  @resource_info = args[:resource_info] if args.key?(:resource_info)
  @sdk_version = args[:sdk_version] if args.key?(:sdk_version)
end