DEA-C02 Practice Questions

While running an external function, the following error message is received: Error: Function received the wrong number of rows What is causing this to occur?

A Data Engineer enables a result cache at the session level with the following command: ALTER SESSION SET USE_CACHED_RESULT = TRUE; The Engineer then runs the following SELECT quer...

A company built a sales reporting system with Python, connecting to Snowflake using the Python Connector. Based on the user's selections, the system generates the SQL queries neede...

A company is using Snowpipe to bring in millions of rows every day of Change Data Capture (CDC) into a Snowflake staging table on a real-time basis. The CDC needs to get processed...

A Data Engineer is building a pipeline to transform a 1 TB table by joining it with supplemental tables. The Engineer is applying filters and several aggregations leveraging Common...

Which system role is recommended for a custom role hierarchy to be ultimately assigned to?

Which callback function is required within a JavaScript User-Defined Function (UDF) for it to execute successfully?

Which Snowflake feature facilitates access to external API services such as geocoders, data transformation, machine learning models, and other custom code?

A Data Engineer needs to know the details regarding the micro-partition layout for a table named Invoice using a built-in function. Which query will provide this information?

A Data Engineer would like to define a file structure for loading and unloading data. Where can the file structure be defined? (Choose three.)

Assuming that the session parameter USE_CACHED_RESULT is set to false, what are characteristics of Snowflake virtual warehouses in terms of the use of Snowpark?

Database XYZ has the data_retention_time_in_days parameter set to 7 days and table XYZ.public.ABC has the data_retention_time_in_days set to 10 days. A Developer accidentally dropp...

A Data Engineer is building a set of reporting tables to analyze consumer requests by region for each of the Data Exchange offerings annually, as well as click-through rates for ea...

The following code is executed in a Snowflake environment with the default settings: What will be the result of the select statement?

A Data Engineer defines the following masking policy: The policy must be applied to the full_name column in the customer table: Which query will apply the masking policy on the ful...

Which command will load data successfully to the table named finance_dept_location?

Which of the following grants are required for the role running the kafka_load_role_1 Snowflake Connector for Kafka, with the intent of loading data to Snowflake? (Choose three.) (...

A Data Engineer creates a pipe called mypipe. What command needs to be run to verify that the pipe is configured correctly and is running?

Which attribute is used by Snowpipe to ensure the same file is not loaded twice from a path in a stage? File partition details A.

A company called IOT Corporation has subsidiary companies in Germany and Japan. - The German subsidiary has a Snowflake account called IOTGER in AWS region EU (Frankfurt) (Region I...

A Data Engineer made modifications to staged files and re-staged them. A pipe is running but the changed data is not appearing in the table. What step should the Engineer take in o...

A Data Engineer has been asked by the development team to create a snapshot of production data from the ABC database into the developer account. None of the data is Personal Identi...

A company would like to get data from a Snowflake Marketplace provider for data enrichment purposes. A Data Engineer needs to build a data pipeline that would blend existing data i...

A Data Engineer is creating a pipe by executing the following statement: create or replace pipe mypipe auto_ingest=true as copy into mytable from @mystage; The Data Engineer adds a...

How can a directory table be used when working with unstructured data? (Choose two.)

A Data Engineer needs to obtain details about data loading history for tables in a specific database and schema. The tables were loaded using Snowpipe in the last 24 hours. How sho...

A Data Engineer is developing a data pipeline to ingest data from an Amazon S3 bucket into a Snowflake table. Files will be loaded into the S3 bucket randomly, with most files load...

How should a Data Engineer build a pipeline that executes a stored procedure to parse and load unstructured data files as the files arrive in a stage?

A Data Engineer needs to configure a task in Snowflake to automatically send error notifications in case of a data loading failure. The Engineer wants to use an existing task that...

A company using Snowflake works with a third party that provides economic data. The third-party provider recently moved their data to Snowflake. How can the company access the thir...

A Data Engineer is trying to clone a very large table from a source environment that has set DATA_RETENTION_TIME_IN_DAYS = 0. During the cloning operation, Data Manipulation Langua...

A company has deployed a data pipeline that streams customer transaction data from an on- premises PostgreSQL database to Snowflake for real-time analytics. A Data Engineer needs t...

How can a Data Engineer return all the errors encountered during a previous file upload that used the COPY command?

A Data Engineer is cloning a production database for use as a development environment using these commands: USE ROLE CLONE_ADMIN; CREATE DATABASE DB_DEV CLONE DE_PROD AT (OFFSET =>...

A Data Engineer is setting up a data processing pipeline in Snowflake. The pipeline needs to process PDF files that are uploaded to a stage with a directory table enabled. The data...

A Data Engineer is designing a solution that will send report files generated and stored in a Snowflake stage to a customer, using email. The files can only be available for downlo...

A Data Engineer needs to monitor a continuous data pipeline that is processing data. The data is ingested into Snowflake using a pipe from an Amazon S3 bucket, then it is transform...

What action could a Data Engineer take to increase the query performance of an external table?

When using a stored procedure in Snowflake, how many threads can the Snowflake API run concurrently?

Given the following cron expression "0 1 * * * America/Los_Angeles", how will the task behave when changing from Daylight Savings Time to Standard Time, moving the clock one hour b...

A company has many nested JSON files in cloud storage. The company would like to use these files in complex JOIN operations. Which method would provide the BEST performance?

Data is loaded into a staging table every day. From there, several departments perform transformations on the data and load it into different production tables. How should the stag...

A Data Engineer is reviewing Python data pipeline code that is dynamically scaling warehouse HOL_WH: What effect is the WAIT_FOR_COMPLETION clause having on the pipeline?

A Data Engineer has a table with no clustering key defined. The Engineer wants to analyze the distribution of micro-partitions by using system functions. To identify the best clust...

A Data Engineer is using Snowpark to perform data transformations on large data sets in Snowflake. The Engineer wants to optimize the transformation process by minimizing the amoun...

A Data Engineer is querying a large table (+100 million rows) with the following SQL: select name , address , datediff(year, birthdate, current_date()) from customers; The Engineer...

This query was executed: SELECT SYSTEM$EXPLAIN_PLAN_JSON( 'SELECT Z1.ID, Z2.ID FROM Z1, Z2 WHERE Z2.ID = Z1.ID' ) AS explain_plan; What information will be provided in the results?

A company built data pipelines using dynamic tables in Snowflake. Recently, some dynamic table refreshes have been taking longer than expected, causing delays in data availability...

A Data Engineer used a secondary role to create a dynamic table using a CREATE DYNAMIC TABLE command. The secondary role has been granted the USAGE privilege, but the primary role...

A Data Engineer needs to optimize the performance and minimize the costs of a dynamic table pipeline in Snowflake. The Engineer wants to monitor and separate the dynamic table cost...