Class: Google::Apis::DataprocV1::StreamingQueryProgress

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

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(**args) ⇒ StreamingQueryProgress

Returns a new instance of StreamingQueryProgress.



10935
10936
10937
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10935

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

Instance Attribute Details

#batch_duration ⇒ Fixnum

Corresponds to the JSON property batchDuration

Returns:

  • (Fixnum) 


10878
10879
10880
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10878

def batch_duration
  @batch_duration
end

#batch_id ⇒ Fixnum

Corresponds to the JSON property batchId

Returns:

  • (Fixnum) 


10883
10884
10885
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10883

def batch_id
  @batch_id
end

#duration_millis ⇒ Hash<String,Fixnum>

Corresponds to the JSON property durationMillis

Returns:

  • (Hash<String,Fixnum>) 


10888
10889
10890
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10888

def duration_millis
  @duration_millis
end

#event_time ⇒ Hash<String,String>

Corresponds to the JSON property eventTime

Returns:

  • (Hash<String,String>) 


10893
10894
10895
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10893

def event_time
  @event_time
end

#name ⇒ String

Corresponds to the JSON property name

Returns:

  • (String) 


10898
10899
10900
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10898

def name
  @name
end

#observed_metrics ⇒ Hash<String,String>

Corresponds to the JSON property observedMetrics

Returns:

  • (Hash<String,String>) 


10903
10904
10905
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10903

def observed_metrics
  @observed_metrics
end

#run_id ⇒ String

Corresponds to the JSON property runId

Returns:

  • (String) 


10908
10909
10910
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10908

def run_id
  @run_id
end

#sink ⇒ Google::Apis::DataprocV1::SinkProgress

Corresponds to the JSON property sink

Returns:



10913
10914
10915
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10913

def sink
  @sink
end

#sources ⇒ Array<Google::Apis::DataprocV1::SourceProgress>

Corresponds to the JSON property sources

Returns:



10918
10919
10920
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10918

def sources
  @sources
end

#state_operators ⇒ Array<Google::Apis::DataprocV1::StateOperatorProgress>

Corresponds to the JSON property stateOperators

Returns:



10923
10924
10925
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10923

def state_operators
  @state_operators
end

#streaming_query_progress_id ⇒ String

Corresponds to the JSON property streamingQueryProgressId

Returns:

  • (String) 


10928
10929
10930
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10928

def streaming_query_progress_id
  @streaming_query_progress_id
end

#timestamp ⇒ String

Corresponds to the JSON property timestamp

Returns:

  • (String) 


10933
10934
10935
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10933

def timestamp
  @timestamp
end

Instance Method Details

#update!(**args) ⇒ Object

Update properties of this object



10940
10941
10942
10943
10944
10945
10946
10947
10948
10949
10950
10951
10952
10953
 
# File 'lib/google/apis/dataproc_v1/classes.rb', line 10940

def update!(**args)
  @batch_duration = args[:batch_duration] if args.key?(:batch_duration)
  @batch_id = args[:batch_id] if args.key?(:batch_id)
  @duration_millis = args[:duration_millis] if args.key?(:duration_millis)
  @event_time = args[:event_time] if args.key?(:event_time)
  @name = args[:name] if args.key?(:name)
  @observed_metrics = args[:observed_metrics] if args.key?(:observed_metrics)
  @run_id = args[:run_id] if args.key?(:run_id)
  @sink = args[:sink] if args.key?(:sink)
  @sources = args[:sources] if args.key?(:sources)
  @state_operators = args[:state_operators] if args.key?(:state_operators)
  @streaming_query_progress_id = args[:streaming_query_progress_id] if args.key?(:streaming_query_progress_id)
  @timestamp = args[:timestamp] if args.key?(:timestamp)
end