diff --git a/analyses/call_eudf_address_to_coordinates.sql b/analyses/call_eudf_address_to_coordinates.sql new file mode 100644 index 0000000..e1959d9 --- /dev/null +++ b/analyses/call_eudf_address_to_coordinates.sql @@ -0,0 +1,5 @@ +select + company_address_id, + district_id, + {{ address_to_coordinates( 'company_address_id', 'district_id' ) }} as output_1 +from {{ ref('test_address__mock_data') }}; diff --git a/analyses/get_geo_loc.sql b/analyses/get_geo_loc.sql deleted file mode 100644 index f88e8b7..0000000 --- a/analyses/get_geo_loc.sql +++ /dev/null @@ -1 +0,0 @@ -SELECT * FROM {{ ref('snowpark_geoloc') }} \ No newline at end of file diff --git a/macros/address_to_coordinates.sql b/macros/address_to_coordinates.sql new file mode 100644 index 0000000..59e5c9d --- /dev/null +++ b/macros/address_to_coordinates.sql @@ -0,0 +1,5 @@ +-- Macro to call EUDF stored in snowflake +-- id, created_datetime, updated_datetime, reference, address_1, address_2, postcode, district, state, country +{%- macro address_to_coordinates(column1, column2) -%} + GLOBAL_FUNCTION.EUDF.ECHO_ADDRESS_TO_COORDINATES({{column1}}, {{column2}}) +{%- endmacro -%} diff --git a/models/marts/warehouse/geo_loc_test.sql b/models/marts/warehouse/geo_loc_test.sql new file mode 100644 index 0000000..e69de29