Class: Google::Cloud::Bigquery::QueryJob::Stage

Inherits:
Object
  • Object
show all
Defined in:
lib/google/cloud/bigquery/query_job.rb

Overview

Represents a stage in the execution plan for the query.

Examples:

require "google/cloud/bigquery"

bigquery = Google::Cloud::Bigquery.new

sql = "SELECT word FROM publicdata.samples.shakespeare"
job = bigquery.query_job sql

job.wait_until_done!

stages = job.query_plan
stages.each do |stage|
  puts stage.name
  stage.steps.each do |step|
    puts step.kind
    puts step.substeps.inspect
  end
end

Instance Attribute Summary collapse

Instance Attribute Details

#compute_ratio_avg ⇒ Float (readonly)

Relative amount of time the average shard spent on CPU-bound tasks.

Returns:

  • (Float) —

    the current value of compute_ratio_avg



362
363
364
 
# File 'lib/google/cloud/bigquery/query_job.rb', line 362

def compute_ratio_avg
  @compute_ratio_avg
end

#compute_ratio_max ⇒ Float (readonly)

Relative amount of time the slowest shard spent on CPU-bound tasks.

Returns:

  • (Float) —

    the current value of compute_ratio_max



362
363
364
 
# File 'lib/google/cloud/bigquery/query_job.rb', line 362

def compute_ratio_max
  @compute_ratio_max
end

#id ⇒ Integer (readonly)

Unique ID for the stage within the query plan.

Returns:

  • (Integer) —

    the current value of id



362
363
364
 
# File 'lib/google/cloud/bigquery/query_job.rb', line 362

def id
  @id
end

#name ⇒ String (readonly)

Human-readable name for the stage.

Returns:

  • (String) —

    the current value of name



362
363
364
 
# File 'lib/google/cloud/bigquery/query_job.rb', line 362

def name
  @name
end

#read_ratio_avg ⇒ Float (readonly)

Relative amount of time the average shard spent reading input.

Returns:

  • (Float) —

    the current value of read_ratio_avg



362
363
364
 
# File 'lib/google/cloud/bigquery/query_job.rb', line 362

def read_ratio_avg
  @read_ratio_avg
end

#read_ratio_max ⇒ Float (readonly)

Relative amount of time the slowest shard spent reading input.

Returns:

  • (Float) —

    the current value of read_ratio_max



362
363
364
 
# File 'lib/google/cloud/bigquery/query_job.rb', line 362

def read_ratio_max
  @read_ratio_max
end

#records_read ⇒ Integer (readonly)

Number of records read into the stage.

Returns:

  • (Integer) —

    the current value of records_read



362
363
364
 
# File 'lib/google/cloud/bigquery/query_job.rb', line 362

def records_read
  @records_read
end

#records_written ⇒ Integer (readonly)

Number of records written by the stage.

Returns:

  • (Integer) —

    the current value of records_written



362
363
364
 
# File 'lib/google/cloud/bigquery/query_job.rb', line 362

def records_written
  @records_written
end

#status ⇒ Object (readonly)

Returns the value of attribute status



363
364
365
 
# File 'lib/google/cloud/bigquery/query_job.rb', line 363

def status
  @status
end

#steps ⇒ Array<Step> (readonly)

List of operations within the stage in dependency order (approximately chronological).

Returns:

  • (Array<Step>) —

    the current value of steps



362
363
364
 
# File 'lib/google/cloud/bigquery/query_job.rb', line 362

def steps
  @steps
end

#wait_ratio_avg ⇒ Float (readonly)

Relative amount of time the average shard spent waiting to be scheduled.

Returns:

  • (Float) —

    the current value of wait_ratio_avg



362
363
364
 
# File 'lib/google/cloud/bigquery/query_job.rb', line 362

def wait_ratio_avg
  @wait_ratio_avg
end

#wait_ratio_max ⇒ Float (readonly)

Relative amount of time the slowest shard spent waiting to be scheduled.

Returns:

  • (Float) —

    the current value of wait_ratio_max



362
363
364
 
# File 'lib/google/cloud/bigquery/query_job.rb', line 362

def wait_ratio_max
  @wait_ratio_max
end

#write_ratio_avg ⇒ Float (readonly)

Relative amount of time the average shard spent on writing output.

Returns:

  • (Float) —

    the current value of write_ratio_avg



362
363
364
 
# File 'lib/google/cloud/bigquery/query_job.rb', line 362

def write_ratio_avg
  @write_ratio_avg
end

#write_ratio_max ⇒ Float (readonly)

Relative amount of time the slowest shard spent on writing output.

Returns:

  • (Float) —

    the current value of write_ratio_max



362
363
364
 
# File 'lib/google/cloud/bigquery/query_job.rb', line 362

def write_ratio_max
  @write_ratio_max
end