text: {{ config(
      unique_key = '_airbyte_ab_id',
      schema = "_airbyte_test_normalization",
      tags = [ "top-level-intermediate" ]
  ) }}
  -- SQL model to parse JSON blob stored in a single column and extract into separated field columns as described by the JSON Schema
  select
      {{ json_extract_scalar('_airbyte_data', ['id'], ['id']) }} as id,
      {{ json_extract_scalar('_airbyte_data', ['name'], ['name']) }} as name,
      {{ json_extract_scalar('_airbyte_data', ['_ab_cdc_lsn'], ['_ab_cdc_lsn']) }} as _ab_cdc_lsn,
      {{ json_extract_scalar('_airbyte_data', ['_ab_cdc_updated_at'], ['_ab_cdc_updated_at']) }} as _ab_cdc_updated_at,
      {{ json_extract_scalar('_airbyte_data', ['_ab_cdc_deleted_at'], ['_ab_cdc_deleted_at']) }} as _ab_cdc_deleted_at,
      {{ json_extract_scalar('_airbyte_data', ['_ab_cdc_log_pos'], ['_ab_cdc_log_pos']) }} as _ab_cdc_log_pos,
      _airbyte_ab_id,
      _airbyte_emitted_at,
      {{ current_timestamp() }} as _airbyte_normalized_at
  from {{ source('test_normalization', '_airbyte_raw_pos_dedup_cdcx') }} as table_alias
  -- pos_dedup_cdcx
  where 1 = 1
  {{ incremental_clause('_airbyte_emitted_at') }}
  
  