Skip to content

Commit c07583c

Browse files
committed
added user-defined-functions.csv
1 parent 2dee75a commit c07583c

File tree

1 file changed

+28
-0
lines changed

1 file changed

+28
-0
lines changed

dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/snowflake/SnowflakeLogsConnector.java

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -300,6 +300,17 @@ public final void addTasksTo(
300300
out.add(new FormatTask(FORMAT_NAME));
301301
out.add(SnowflakeYamlSummaryTask.create(FORMAT_NAME, arguments));
302302

303+
String userDefinedFunctions =
304+
"SELECT FUNCTION_SCHEMA, FUNCTION_NAME, FUNCTION_LANGUAGE, ARGUMENT_SIGNATURE, "
305+
+ "FUNCTION_OWNER, COMMENT, VOLATILITY, RUNTIME_VERSION, LAST_ALTERED, "
306+
+ "PACKAGES, IMPORTS, IS_AGGREGATE, IS_DATA_METRIC, IS_MEMOIZABLE "
307+
+ "FROM SNOWFLAKE.ACCOUNT_USAGE.FUNCTIONS "
308+
+ "WHERE FUNCTION_SCHEMA != 'INFORMATION_SCHEMA' "
309+
+ "AND DELETED IS NULL";
310+
out.add(
311+
new JdbcSelectTask("user-defined-functions.csv", userDefinedFunctions, TaskCategory.OPTIONAL)
312+
.withHeaderClass(FunctionsHeader.class));
313+
303314
// (24 * 7) -> 7 trailing days == 168 hours
304315
// Actually, on Snowflake, 7 days ago starts at midnight in an unadvertised time zone. What the
305316
// <deleted>.
@@ -507,6 +518,23 @@ String viewName() {
507518
}
508519
}
509520

521+
private enum FunctionsHeader {
522+
FUNCTION_SCHEMA,
523+
FUNCTION_NAME,
524+
FUNCTION_LANGUAGE,
525+
ARGUMENT_SIGNATURE,
526+
FUNCTION_OWNER,
527+
COMMENT,
528+
VOLATILITY,
529+
RUNTIME_VERSION,
530+
LAST_ALTERED,
531+
PACKAGES,
532+
IMPORTS,
533+
IS_AGGREGATE,
534+
IS_DATA_METRIC,
535+
IS_MEMOIZABLE
536+
}
537+
510538
@Nonnull
511539
static String formatPrefix(@Nonnull Class<? extends Enum<?>> enumClass, @Nonnull String view) {
512540
String selectList =

0 commit comments

Comments
 (0)