class BeetleETL::Step

Attributes

table_name[R]

Public Class Methods

new(config, table_name) click to toggle source
# File lib/beetle_etl/steps/step.rb, line 7
def initialize(config, table_name)
  @config = config
  @table_name = table_name
end
step_name(table_name) click to toggle source
# File lib/beetle_etl/steps/step.rb, line 12
def self.step_name(table_name)
  "#{table_name}: #{name.split('::').last}"
end

Public Instance Methods

database() click to toggle source
# File lib/beetle_etl/steps/step.rb, line 28
def database
  @config.database
end
dependencies() click to toggle source
# File lib/beetle_etl/steps/step.rb, line 20
def dependencies
  Set.new
end
external_source() click to toggle source
# File lib/beetle_etl/steps/step.rb, line 24
def external_source
  @config.external_source
end
name() click to toggle source
# File lib/beetle_etl/steps/step.rb, line 16
def name
  self.class.step_name(table_name)
end
stage_table_name(table_name = nil) click to toggle source
# File lib/beetle_etl/steps/step.rb, line 36
def stage_table_name(table_name = nil)
  BeetleETL::Naming.stage_table_name(external_source, table_name || @table_name)
end
target_schema() click to toggle source
# File lib/beetle_etl/steps/step.rb, line 32
def target_schema
  @config.target_schema
end