Drop fivetran_utils by copying code. (#97)

Author: maciejklimek

LICENSE

@@ -28,5 +28,7 @@ Third party Apache 2.0 licenses
 The following files contain signifant parts of code licensed under third party Apache 2.0 License.
 
 macros/public/validating/regex_dict.sql 
+macros/utils/fivetran_utils/percentile.sql
+macros/utils/fivetran_utils/json_extract.sql
 
 

macros/utils/fivetran_utils/json_extract.sql

@@ -0,0 +1,40 @@
+{#
+# This file contains significant part of code derived from 
+# https://github.com/fivetran/dbt_fivetran_utils/tree/v0.4.0 which is licensed under Apache License 2.0.
+#}
+
+{% macro json_extract(string, string_path) -%}
+
+{{ adapter.dispatch('json_extract') (string, string_path) }}
+
+{%- endmacro %}
+
+{% macro default__json_extract(string, string_path) %}
+
+  json_extract_path_text({{string}}, {{ "'" ~ string_path ~ "'" }} )
+ 
+{% endmacro %}
+
+{% macro snowflake__json_extract(string, string_path) %}
+
+  json_extract_path_text(try_parse_json( {{string}} ), {{ "'" ~ string_path ~ "'" }} )
+
+{% endmacro %}
+
+{% macro redshift__json_extract(string, string_path) %}
+
+  case when is_valid_json( {{string}} ) then json_extract_path_text({{string}}, {{ "'" ~ string_path ~ "'" }} ) else null end
+ 
+{% endmacro %}
+
+{% macro bigquery__json_extract(string, string_path) %}
+
+  json_extract_scalar({{string}}, {{ "'$." ~ string_path ~ "'" }} )
+
+{% endmacro %}
+
+{% macro postgres__json_extract(string, string_path) %}
+
+  {{string}}::json->>{{"'" ~ string_path ~ "'" }}
+
+{% endmacro %}

macros/utils/fivetran_utils/percentile.sql

@@ -0,0 +1,60 @@
+{#
+# This file contains significant part of code derived from 
+# https://github.com/fivetran/dbt_fivetran_utils/tree/v0.4.0 which is licensed under Apache License 2.0.
+#}
+
+{% macro percentile(percentile_field, partition_field, percent) -%}
+
+{{ adapter.dispatch('percentile') (percentile_field, partition_field, percent) }}
+
+{%- endmacro %}
+
+--percentile calculation specific to Redshift
+{% macro default__percentile(percentile_field, partition_field, percent)  %}
+
+    percentile_cont( 
+        {{ percent }} )
+        within group ( order by {{ percentile_field }} )
+        over ( partition by {{ partition_field }} )
+
+{% endmacro %}
+
+--percentile calculation specific to Redshift
+{% macro redshift__percentile(percentile_field, partition_field, percent)  %}
+
+    percentile_cont( 
+        {{ percent }} )
+        within group ( order by {{ percentile_field }} )
+        over ( partition by {{ partition_field }} )
+
+{% endmacro %}
+
+--percentile calculation specific to BigQuery
+{% macro bigquery__percentile(percentile_field, partition_field, percent)  %}
+
+    percentile_cont( 
+        {{ percentile_field }}, 
+        {{ percent }}) 
+        over (partition by {{ partition_field }}    
+        )
+
+{% endmacro %}
+
+{% macro postgres__percentile(percentile_field, partition_field, percent)  %}
+
+    percentile_cont( 
+        {{ percent }} )
+        within group ( order by {{ percentile_field }} )
+    /* have to group by partition field */
+
+{% endmacro %}
+
+{% macro spark__percentile(percentile_field, partition_field, percent)  %}
+
+    percentile( 
+        {{ percentile_field }}, 
+        {{ percent }}) 
+        over (partition by {{ partition_field }}    
+        )
+
+{% endmacro %}

macros/utils/json_extract.sql

@@ -2,6 +2,3 @@
 packages:
   - package: dbt-labs/dbt_utils
     version: [">=0.7.0", "<0.9.0"]
-
-  - package: fivetran/fivetran_utils
-    version: 0.3.9