lib/chronicle/etl/transformers/transformer.rb in chronicle-etl-0.2.3 vs lib/chronicle/etl/transformers/transformer.rb in chronicle-etl-0.2.4
- old
+ new
@@ -9,16 +9,16 @@
# options::
# Options for configuring this Transformer
def initialize(options = {}, data)
@options = options
@data = data
+ @record = Chronicle::ETL::Models::Activity.new
end
- # The main entrypoint for transforming a record. Called by a Runner on each extracted record
- def transform
- raise NotImplementedError
- end
+ # @abstract Subclass is expected to implement #transform
+ # @!method transform
+ # The main entrypoint for transforming a record. Called by a Runner on each extracted record
# The domain or provider-specific id of the record this transformer is working on.
# Used for building a cursor so an extractor doesn't have to start from the beginning of a
# data source from the beginning.
def id; end
@@ -29,7 +29,6 @@
def timestamp; end
end
end
end
-require_relative 'json_transformer'
require_relative 'null_transformer'