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