Skip to content

Commit

Permalink
new files (#401)
Browse files Browse the repository at this point in the history
  • Loading branch information
@austinFlipside
austinFlipside authored Oct 17, 2024
1 parent ee9dcd1 commit e587b8f
Show file tree
Hide file tree
Showing 12 changed files with 144 additions and 0 deletions.
12 changes: 12 additions & 0 deletions ...ne/silver/decoder/history/range_6/streamline__decode_logs_history_061850178_062150178.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
{{ config (
materialized = "view",
post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
tags = ['streamline_decoded_logs_history_range_6']
) }}

{% set start = this.identifier.split("_") [-2] %}
{% set stop = this.identifier.split("_") [-1] %}
{{ fsc_utils.decode_logs_history(
start,
stop
) }}
12 changes: 12 additions & 0 deletions ...ne/silver/decoder/history/range_6/streamline__decode_logs_history_062150179_062350179.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
{{ config (
materialized = "view",
post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
tags = ['streamline_decoded_logs_history_range_6']
) }}

{% set start = this.identifier.split("_") [-2] %}
{% set stop = this.identifier.split("_") [-1] %}
{{ fsc_utils.decode_logs_history(
start,
stop
) }}
12 changes: 12 additions & 0 deletions ...ne/silver/decoder/history/range_6/streamline__decode_logs_history_062350180_062550180.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
{{ config (
materialized = "view",
post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
tags = ['streamline_decoded_logs_history_range_6']
) }}

{% set start = this.identifier.split("_") [-2] %}
{% set stop = this.identifier.split("_") [-1] %}
{{ fsc_utils.decode_logs_history(
start,
stop
) }}
12 changes: 12 additions & 0 deletions ...ne/silver/decoder/history/range_6/streamline__decode_logs_history_062550181_062750181.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
{{ config (
materialized = "view",
post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
tags = ['streamline_decoded_logs_history_range_6']
) }}

{% set start = this.identifier.split("_") [-2] %}
{% set stop = this.identifier.split("_") [-1] %}
{{ fsc_utils.decode_logs_history(
start,
stop
) }}
12 changes: 12 additions & 0 deletions ...ne/silver/decoder/history/range_6/streamline__decode_logs_history_062750182_062950182.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
{{ config (
materialized = "view",
post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
tags = ['streamline_decoded_logs_history_range_6']
) }}

{% set start = this.identifier.split("_") [-2] %}
{% set stop = this.identifier.split("_") [-1] %}
{{ fsc_utils.decode_logs_history(
start,
stop
) }}
12 changes: 12 additions & 0 deletions ...ne/silver/decoder/history/range_6/streamline__decode_logs_history_062950183_063150183.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
{{ config (
materialized = "view",
post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
tags = ['streamline_decoded_logs_history_range_6']
) }}

{% set start = this.identifier.split("_") [-2] %}
{% set stop = this.identifier.split("_") [-1] %}
{{ fsc_utils.decode_logs_history(
start,
stop
) }}
12 changes: 12 additions & 0 deletions ...ne/silver/decoder/history/range_6/streamline__decode_logs_history_063150184_064150184.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
{{ config (
materialized = "view",
post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
tags = ['streamline_decoded_logs_history_range_6']
) }}

{% set start = this.identifier.split("_") [-2] %}
{% set stop = this.identifier.split("_") [-1] %}
{{ fsc_utils.decode_logs_history(
start,
stop
) }}
12 changes: 12 additions & 0 deletions ...ne/silver/decoder/history/range_6/streamline__decode_logs_history_064150185_065150185.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
{{ config (
materialized = "view",
post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
tags = ['streamline_decoded_logs_history_range_6']
) }}

{% set start = this.identifier.split("_") [-2] %}
{% set stop = this.identifier.split("_") [-1] %}
{{ fsc_utils.decode_logs_history(
start,
stop
) }}
12 changes: 12 additions & 0 deletions ...ne/silver/decoder/history/range_6/streamline__decode_logs_history_065150186_066150186.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
{{ config (
materialized = "view",
post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
tags = ['streamline_decoded_logs_history_range_6']
) }}

{% set start = this.identifier.split("_") [-2] %}
{% set stop = this.identifier.split("_") [-1] %}
{{ fsc_utils.decode_logs_history(
start,
stop
) }}
12 changes: 12 additions & 0 deletions ...ne/silver/decoder/history/range_6/streamline__decode_logs_history_066150187_067150187.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
{{ config (
materialized = "view",
post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
tags = ['streamline_decoded_logs_history_range_6']
) }}

{% set start = this.identifier.split("_") [-2] %}
{% set stop = this.identifier.split("_") [-1] %}
{{ fsc_utils.decode_logs_history(
start,
stop
) }}
12 changes: 12 additions & 0 deletions ...ne/silver/decoder/history/range_6/streamline__decode_logs_history_067150188_068150188.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
{{ config (
materialized = "view",
post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
tags = ['streamline_decoded_logs_history_range_6']
) }}

{% set start = this.identifier.split("_") [-2] %}
{% set stop = this.identifier.split("_") [-1] %}
{{ fsc_utils.decode_logs_history(
start,
stop
) }}
12 changes: 12 additions & 0 deletions ...ne/silver/decoder/history/range_6/streamline__decode_logs_history_068150189_069150189.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,12 @@
{{ config (
materialized = "view",
post_hook = [if_data_call_function( func = "{{model.schema}}.udf_bulk_decode_logs(object_construct('sql_source', '{{model.alias}}','producer_batch_size', 20000000,'producer_limit_size', {{var('row_limit',7500000)}}))", target = "{{model.schema}}.{{model.alias}}" ) ,if_data_call_wait()],
tags = ['streamline_decoded_logs_history_range_6']
) }}

{% set start = this.identifier.split("_") [-2] %}
{% set stop = this.identifier.split("_") [-1] %}
{{ fsc_utils.decode_logs_history(
start,
stop
) }}

0 comments on commit e587b8f

Please sign in to comment.