Sha256: 29335f5e48c3ede0a312d52d5c3245a083ca3bd5c836356a1d2a73e9f7011e12

Contents?: true

Size: 452 Bytes

Versions: 1

Compression:

Stored size: 452 Bytes

Contents

# frozen_string_literal: true

module Chronicle
  module ETL
    class MergeMetaTransformer < Chronicle::ETL::Transformer
      register_connector do |r|
        r.identifier = :merge_meta
        r.description = 'merge extraction meta fields into the record'
      end

      def transform(record)
        record.data unless record.extraction&.meta

        record.data[:_meta] = record.extraction.meta
        record.data
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
chronicle-etl-0.6.1 lib/chronicle/etl/transformers/merge_meta_transformer.rb