Materialize/test/canary-environment/macros/create_loadgen_source.sql

-- Copyright Materialize, Inc. and contributors. All rights reserved.
--
-- Use of this software is governed by the Business Source License
-- included in the LICENSE file at the root of this repository.
--
-- As of the Change Date specified in that file, in accordance with
-- the Business Source License, use of this software will be governed
-- by the Apache License, Version 2.0.

{% macro create_loadgen_source(name) %}
FROM KAFKA CONNECTION kafka_connection (TOPIC 'datagen_demo_snowflakeschema_{{ name.table }}');
{% endmacro %}

{% macro create_large_loadgen_source(name) %}
FROM KAFKA CONNECTION kafka_connection (TOPIC 'datagen_large_snowflakeschema_{{ name }}');
{% endmacro %}