Class: Google::Apis::DataprocV1::SparkConnectExecutionInfo

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

Overview

Represents the lifecycle and details of an Execution via Spark Connect

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ SparkConnectExecutionInfo

Returns a new instance of SparkConnectExecutionInfo.



8869
8870
8871
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 8869

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

Instance Attribute Details

#close_timestamp ⇒ Fixnum

Timestamp when the execution was closed. Corresponds to the JSON property closeTimestamp

Returns:

  • (Fixnum) 


8807
8808
8809
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 8807

def close_timestamp
  @close_timestamp
end

#detail ⇒ String

Detailed information about the execution. Corresponds to the JSON property detail

Returns:

  • (String) 


8812
8813
8814
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 8812

def detail
  @detail
end

#finish_timestamp ⇒ Fixnum

Timestamp when the execution finished. Corresponds to the JSON property finishTimestamp

Returns:

  • (Fixnum) 


8817
8818
8819
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 8817

def finish_timestamp
  @finish_timestamp
end

#job_ids ⇒ Array<String>

Optional. List of job ids associated with the execution. Corresponds to the JSON property jobIds

Returns:

  • (Array<String>) 


8822
8823
8824
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 8822

def job_ids
  @job_ids
end

#job_tag ⇒ String

Required. Job tag of the execution. Corresponds to the JSON property jobTag

Returns:

  • (String) 


8827
8828
8829
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 8827

def job_tag
  @job_tag
end

#operation_id ⇒ String

Unique identifier for the operation. Corresponds to the JSON property operationId

Returns:

  • (String) 


8832
8833
8834
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 8832

def operation_id
  @operation_id
end

#session_id ⇒ String

Required. Session ID, ties the execution to a specific Spark Connect session. Corresponds to the JSON property sessionId

Returns:

  • (String) 


8837
8838
8839
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 8837

def session_id
  @session_id
end

#spark_session_tags ⇒ Array<String>

Optional. Tags associated with the Spark session. Corresponds to the JSON property sparkSessionTags

Returns:

  • (Array<String>) 


8842
8843
8844
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 8842

def spark_session_tags
  @spark_session_tags
end

#sql_exec_ids ⇒ Array<String>

Optional. List of sql execution ids associated with the execution. Corresponds to the JSON property sqlExecIds

Returns:

  • (Array<String>) 


8847
8848
8849
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 8847

def sql_exec_ids
  @sql_exec_ids
end

#start_timestamp ⇒ Fixnum

Timestamp when the execution started. Corresponds to the JSON property startTimestamp

Returns:

  • (Fixnum) 


8852
8853
8854
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 8852

def start_timestamp
  @start_timestamp
end

#state ⇒ String

Output only. Current state of the execution. Corresponds to the JSON property state

Returns:

  • (String) 


8857
8858
8859
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 8857

def state
  @state
end

#statement ⇒ String

statement of the execution. Corresponds to the JSON property statement

Returns:

  • (String) 


8862
8863
8864
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 8862

def statement
  @statement
end

#user_id ⇒ String

User ID of the user who started the execution. Corresponds to the JSON property userId

Returns:

  • (String) 


8867
8868
8869
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 8867

def user_id
  @user_id
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



8874
8875
8876
8877
8878
8879
8880
8881
8882
8883
8884
8885
8886
8887
8888
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 8874

def update!(**args)
  @close_timestamp = args[:close_timestamp] if args.key?(:close_timestamp)
  @detail = args[:detail] if args.key?(:detail)
  @finish_timestamp = args[:finish_timestamp] if args.key?(:finish_timestamp)
  @job_ids = args[:job_ids] if args.key?(:job_ids)
  @job_tag = args[:job_tag] if args.key?(:job_tag)
  @operation_id = args[:operation_id] if args.key?(:operation_id)
  @session_id = args[:session_id] if args.key?(:session_id)
  @spark_session_tags = args[:spark_session_tags] if args.key?(:spark_session_tags)
  @sql_exec_ids = args[:sql_exec_ids] if args.key?(:sql_exec_ids)
  @start_timestamp = args[:start_timestamp] if args.key?(:start_timestamp)
  @state = args[:state] if args.key?(:state)
  @statement = args[:statement] if args.key?(:statement)
  @user_id = args[:user_id] if args.key?(:user_id)
end