public class org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink extends org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink { private static final org.slf4j.Logger LOGGER; private static final org.finos.legend.engine.persistence.components.relational.RelationalSink INSTANCE; private static final java.util.Set CAPABILITIES; private static final java.util.Map LOGICAL_PLAN_VISITOR_BY_CLASS; private static final java.util.Map IMPLICIT_DATA_TYPE_MAPPING; private static final java.util.Map EXPLICIT_DATA_TYPE_MAPPING; private static final java.lang.String LOADED; private static final java.lang.String FILE; private static final java.lang.String BULK_LOAD_STATUS; private static final java.lang.String ROWS_LOADED; private static final java.lang.String ERRORS_SEEN; private static final java.lang.String FIRST_ERROR; private static final java.lang.String FIRST_ERROR_COLUMN_NAME; private static final java.lang.String ERROR; protected static final java.lang.String FILE_WITH_ERROR; protected static final java.lang.String ROW_NUMBER; private static final java.lang.String LINE; private static final java.lang.String CHARACTER; private static final java.lang.String CATEGORY; private static final java.lang.String COLUMN_NAME; private static final java.lang.String REJECTED_RECORD; private static final java.lang.String FIELD_DELIMITER; private static final java.lang.String ESCAPE; private static final java.lang.String FIELD_OPTIONALLY_ENCLOSED_BY; private static final java.lang.String CATEGORY_CONVERSION; private static final java.lang.String CATEGORY_CHECK_CONSTRAINT; private static final java.lang.String CATEGORY_OTHER; public static org.finos.legend.engine.persistence.components.relational.RelationalSink get() { org.finos.legend.engine.persistence.components.relational.RelationalSink v; v = ; return v; } public static java.sql.Connection createConnection(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String) { java.sql.Connection v; java.util.Properties v; java.lang.IllegalArgumentException v; java.sql.SQLException v; java.lang.String v, v, v, v, v, v; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = new java.util.Properties; specialinvoke v.()>(); virtualinvoke v.("user", v); virtualinvoke v.("password", v); virtualinvoke v.("account", v); virtualinvoke v.("db", v); virtualinvoke v.("schema", v); label: v = staticinvoke (v, v); label: return v; label: v := @caughtexception; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.Throwable)>(v); throw v; catch java.sql.SQLException from label to label with label; } private void () { java.util.Set v; org.finos.legend.engine.persistence.components.relational.RelationalSink$DatasetExists v; java.util.Map v, v, v; org.finos.legend.engine.persistence.components.relational.RelationalSink$ConstructDatasetFromDatabase v; org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink v; org.finos.legend.engine.persistence.components.relational.RelationalSink$ValidateMainDatasetSchema v; v := @this: org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink; v = ; v = ; v = ; v = ; v = staticinvoke (); v = staticinvoke (); v = staticinvoke (); specialinvoke v.(java.util.Set,java.util.Map,java.util.Map,java.lang.String,java.util.Map,org.finos.legend.engine.persistence.components.relational.RelationalSink$DatasetExists,org.finos.legend.engine.persistence.components.relational.RelationalSink$ValidateMainDatasetSchema,org.finos.legend.engine.persistence.components.relational.RelationalSink$ConstructDatasetFromDatabase)>(v, v, v, "\"%s\"", v, v, v, v); return; } public org.finos.legend.engine.persistence.components.executor.Executor getRelationalExecutor(org.finos.legend.engine.persistence.components.relational.api.RelationalConnection) { java.lang.UnsupportedOperationException v; java.sql.Connection v; org.finos.legend.engine.persistence.components.relational.jdbc.JdbcHelper v; org.finos.legend.engine.persistence.components.relational.executor.RelationalExecutor v; org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink v; boolean v; org.finos.legend.engine.persistence.components.relational.api.RelationalConnection v; v := @this: org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink; v := @parameter: org.finos.legend.engine.persistence.components.relational.api.RelationalConnection; v = v instanceof org.finos.legend.engine.persistence.components.relational.jdbc.JdbcConnection; if v == 0 goto label; v = new org.finos.legend.engine.persistence.components.relational.executor.RelationalExecutor; v = virtualinvoke v.(); v = staticinvoke (v); specialinvoke v.(org.finos.legend.engine.persistence.components.relational.RelationalSink,org.finos.legend.engine.persistence.components.executor.RelationalExecutionHelper)>(v, v); return v; label: v = new java.lang.UnsupportedOperationException; specialinvoke v.(java.lang.String)>("Only JdbcConnection is supported for Snowflake Sink"); throw v; } public java.util.Optional optimizerForCaseConversion(org.finos.legend.engine.persistence.components.relational.CaseConversion) { org.finos.legend.engine.persistence.components.relational.snowflake.optmizer.LowerCaseOptimizer v; java.lang.IllegalArgumentException v; org.finos.legend.engine.persistence.components.relational.CaseConversion v; org.finos.legend.engine.persistence.components.relational.snowflake.optmizer.UpperCaseOptimizer v; int[] v; int v, v; java.util.Optional v, v, v; java.lang.String v; org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink v; v := @this: org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink; v := @parameter: org.finos.legend.engine.persistence.components.relational.CaseConversion; v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; default: goto label; }; label: v = new org.finos.legend.engine.persistence.components.relational.snowflake.optmizer.LowerCaseOptimizer; specialinvoke v.()>(); v = staticinvoke (v); return v; label: v = new org.finos.legend.engine.persistence.components.relational.snowflake.optmizer.UpperCaseOptimizer; specialinvoke v.()>(); v = staticinvoke (v); return v; label: v = staticinvoke (); return v; label: v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unrecognized case conversion: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; } public java.util.List performDryRun(org.finos.legend.engine.persistence.components.common.Datasets, org.finos.legend.engine.persistence.components.transformer.Transformer, org.finos.legend.engine.persistence.components.executor.Executor, org.finos.legend.engine.persistence.components.relational.SqlPlan, java.util.Map, int, org.finos.legend.engine.persistence.components.relational.CaseConversion) { org.finos.legend.engine.persistence.components.executor.Executor v; org.finos.legend.engine.persistence.components.common.Datasets v; org.finos.legend.engine.persistence.components.relational.SqlPlan v; org.finos.legend.engine.persistence.components.relational.CaseConversion v; java.lang.Exception v; java.util.List v, v, v; java.util.Map v; int v; org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink v; org.finos.legend.engine.persistence.components.transformer.Transformer v; boolean v; v := @this: org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink; v := @parameter: org.finos.legend.engine.persistence.components.common.Datasets; v := @parameter: org.finos.legend.engine.persistence.components.transformer.Transformer; v := @parameter: org.finos.legend.engine.persistence.components.executor.Executor; v := @parameter: org.finos.legend.engine.persistence.components.relational.SqlPlan; v := @parameter: java.util.Map; v := @parameter: int; v := @parameter: org.finos.legend.engine.persistence.components.relational.CaseConversion; label: if v == null goto label; v = interfaceinvoke v.(); if v == 0 goto label; label: v = specialinvoke v.(v, v, v, v); label: return v; label: v = specialinvoke v.(v, v, v, v, v, v); label: return v; label: v := @caughtexception; v = specialinvoke v.(v); return v; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; } private java.util.List parseSnowflakeExceptions(java.lang.Exception) { org.finos.legend.engine.persistence.components.relational.api.ErrorCategory v, v, v; org.finos.legend.engine.persistence.components.relational.api.DataError v, v, v; java.util.Map v; java.lang.String v, v, v; org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink v; boolean v, v, v; org.finos.legend.engine.persistence.components.relational.api.DataError$Builder v, v, v, v, v, v, v, v, v, v; java.lang.Exception v; java.util.List v, v, v; java.util.Optional v, v, v; v := @this: org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink; v := @parameter: java.lang.Exception; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.("Error parsing"); if v == 0 goto label; v = staticinvoke (); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v); return v; label: v = virtualinvoke v.("file"); if v == 0 goto label; v = virtualinvoke v.("was not found"); if v == 0 goto label; v = staticinvoke (v, "file \'(.*)\' was not found", 1); v = staticinvoke (); v = staticinvoke (); v = virtualinvoke v.(v, v, v); v = staticinvoke (); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v); return v; label: v = staticinvoke (); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v); return v; } private java.util.List performDryRunWithValidationMode(org.finos.legend.engine.persistence.components.common.Datasets, org.finos.legend.engine.persistence.components.executor.Executor, org.finos.legend.engine.persistence.components.relational.SqlPlan, int) { org.finos.legend.engine.persistence.components.relational.api.ErrorCategory v; org.finos.legend.engine.persistence.components.common.Datasets v; org.finos.legend.engine.persistence.components.relational.api.DataError v; java.util.Map v; boolean v, v; org.finos.legend.engine.persistence.components.relational.api.DataError$Builder v, v, v, v, v; java.util.List v, v; java.util.Optional v, v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.relational.SqlPlan v; java.util.function.Function v; java.util.function.Supplier v; java.util.ArrayList v; int v; org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink v; java.util.Iterator v; org.finos.legend.engine.persistence.components.executor.Executor v; java.util.function.Consumer v, v; java.lang.Object v, v, v; v := @this: org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink; v := @parameter: org.finos.legend.engine.persistence.components.common.Datasets; v := @parameter: org.finos.legend.engine.persistence.components.executor.Executor; v := @parameter: org.finos.legend.engine.persistence.components.relational.SqlPlan; v := @parameter: int; v = interfaceinvoke v.(v, v); v = new java.util.ArrayList; specialinvoke v.()>(); v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v, "FILE"); v = virtualinvoke v.(v, "COLUMN_NAME"); v = virtualinvoke v.(v, "ROW_NUMBER"); v = virtualinvoke v.(v, v, v); v = virtualinvoke v.(v, "LINE"); v = staticinvoke (v); virtualinvoke v.(v); v = virtualinvoke v.(v, "CHARACTER"); v = staticinvoke (v); virtualinvoke v.(v); v = staticinvoke (); v = virtualinvoke v.(v, "ERROR"); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = specialinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(v, "REJECTED_RECORD"); v = staticinvoke (v, v); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: return v; } private org.finos.legend.engine.persistence.components.relational.api.ErrorCategory parseSnowflakeErrorCategory(java.util.Map) { org.finos.legend.engine.persistence.components.relational.api.ErrorCategory v, v, v, v, v, v; java.util.function.Supplier v, v; java.util.Map v; org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink v; boolean v, v, v, v, v, v; java.util.Optional v, v; java.lang.Object v, v; v := @this: org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink; v := @parameter: java.util.Map; v = virtualinvoke v.(v, "CATEGORY"); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(v, "ERROR"); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.("conversion"); if v == 0 goto label; v = ; return v; label: v = virtualinvoke v.("check_constraint"); if v == 0 goto label; v = virtualinvoke v.("NULL result in a non-nullable column"); if v == 0 goto label; v = ; return v; label: v = ; return v; label: v = virtualinvoke v.("other"); if v == 0 goto label; v = virtualinvoke v.("file"); if v == 0 goto label; v = virtualinvoke v.("was not found"); if v == 0 goto label; v = ; return v; label: v = ; return v; label: v = ; return v; } public java.lang.String parseSnowflakeRejectedRecord(org.finos.legend.engine.persistence.components.common.Datasets, java.lang.String) throws java.io.IOException { org.finos.legend.engine.persistence.components.common.Datasets v; org.apache.commons.csv.CSVFormat v, v, v; java.util.Map v; org.apache.commons.csv.CSVParser v; java.util.stream.Collector v; boolean v, v, v, v; java.util.List v, v; java.util.stream.Stream v, v; java.util.Optional v, v, v; java.util.HashMap v; java.util.function.Function v; java.util.function.Supplier v, v, v; int v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaReference v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; java.lang.String v, v, v; org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink v; java.util.Iterator v; com.fasterxml.jackson.databind.ObjectMapper v; char v; java.io.StringReader v; java.lang.Object v, v, v, v, v, v; v := @this: org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink; v := @parameter: org.finos.legend.engine.persistence.components.common.Datasets; v := @parameter: java.lang.String; v = specialinvoke v.(v); v = ; v = virtualinvoke v.(null); v = virtualinvoke v.(null); v = interfaceinvoke v.("FIELD_DELIMITER"); if v == 0 goto label; v = virtualinvoke v.(v, "FIELD_DELIMITER"); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); label: v = interfaceinvoke v.("ESCAPE"); if v == 0 goto label; v = virtualinvoke v.(v, "ESCAPE"); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(v); label: v = interfaceinvoke v.("FIELD_OPTIONALLY_ENCLOSED_BY"); if v == 0 goto label; v = virtualinvoke v.(v, "FIELD_OPTIONALLY_ENCLOSED_BY"); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(v); label: v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = new java.util.HashMap; specialinvoke v.()>(); v = new java.io.StringReader; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = 0; label: v = virtualinvoke v.(); if v >= v goto label; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); interfaceinvoke v.(v, v); v = v + 1; goto label; label: v = new com.fasterxml.jackson.databind.ObjectMapper; specialinvoke v.()>(); v = virtualinvoke v.(v); return v; } private java.util.Map getFormatOptions(org.finos.legend.engine.persistence.components.common.Datasets) { org.finos.legend.engine.persistence.components.common.FileFormatType v, v; java.lang.IllegalStateException v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.StagedFilesDatasetProperties v, v; org.finos.legend.engine.persistence.components.common.Datasets v; java.util.Map v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v, v; org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink v; boolean v, v, v, v, v; java.util.Optional v, v, v; java.lang.Object v, v; v := @this: org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink; v := @parameter: org.finos.legend.engine.persistence.components.common.Datasets; v = virtualinvoke v.(); v = v instanceof org.finos.legend.engine.persistence.components.logicalplan.datasets.StagedFilesDataset; if v != 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("StagedFilesDataset expected"); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = v instanceof org.finos.legend.engine.persistence.components.relational.snowflake.logicalplan.datasets.SnowflakeStagedFilesDatasetProperties; if v != 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("SnowflakeStagedFilesDatasetProperties expected"); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v instanceof org.finos.legend.engine.persistence.components.relational.snowflake.logicalplan.datasets.StandardFileFormat; if v != 0 goto label; label: v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("StandardFileFormat expected"); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); if v != 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("CSV format expected"); throw v; label: v = virtualinvoke v.(); return v; } private java.util.List performDryRunWithValidationQueries(org.finos.legend.engine.persistence.components.common.Datasets, org.finos.legend.engine.persistence.components.executor.Executor, org.finos.legend.engine.persistence.components.relational.SqlPlan, java.util.Map, int, org.finos.legend.engine.persistence.components.relational.CaseConversion) { org.finos.legend.engine.persistence.components.common.Datasets v; org.finos.legend.engine.persistence.components.relational.CaseConversion v; org.finos.legend.engine.persistence.components.relational.api.DataError v; java.util.Map v; java.util.stream.Collector v, v; boolean v, v, v, v; org.finos.legend.engine.persistence.components.util.ValidationCategory[] v; java.util.List v, v, v, v; java.util.stream.Stream v, v, v, v; org.finos.legend.engine.persistence.components.util.ValidationCategory v, v, v, v, v; org.finos.legend.engine.persistence.components.relational.SqlPlan v, v; java.util.HashMap v; java.util.function.Function v, v; java.util.ArrayList v, v; int v, v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaReference v; org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v; java.util.LinkedList v; org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink v; java.util.Iterator v, v, v; org.finos.legend.engine.persistence.components.executor.Executor v; java.lang.Object v, v, v, v, v, v, v, v, v, v; v := @this: org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink; v := @parameter: org.finos.legend.engine.persistence.components.common.Datasets; v := @parameter: org.finos.legend.engine.persistence.components.executor.Executor; v := @parameter: org.finos.legend.engine.persistence.components.relational.SqlPlan; v := @parameter: java.util.Map; v := @parameter: int; v := @parameter: org.finos.legend.engine.persistence.components.relational.CaseConversion; interfaceinvoke v.(v); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = new java.util.LinkedList; specialinvoke v.()>(); interfaceinvoke v.(v, v); v = v + 1; goto label; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = ; v = new java.util.ArrayList; specialinvoke v.()>(); v = interfaceinvoke v.(v, v); v = ; v = new java.util.ArrayList; specialinvoke v.()>(); v = interfaceinvoke v.(v, v); v = virtualinvoke v.(v, v, v, v, v); v = 0 + v; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(v, v, v, v, v); v = ; v = interfaceinvoke v.(v); interfaceinvoke v.(v); v = v + 1; goto label; label: v = virtualinvoke v.(v, v, v); return v; } public org.finos.legend.engine.persistence.components.relational.api.IngestorResult performBulkLoad(org.finos.legend.engine.persistence.components.common.Datasets, org.finos.legend.engine.persistence.components.executor.Executor, org.finos.legend.engine.persistence.components.relational.SqlPlan, java.util.Map, java.util.Map, java.time.Clock) { org.finos.legend.engine.persistence.components.common.StatisticName v, v, v; java.lang.Integer v; java.lang.Long v, v, v; java.util.Map v, v; org.finos.legend.engine.persistence.components.relational.api.IngestorResult$Builder v, v, v, v, v, v, v, v, v; java.time.LocalDateTime v; long v, v, v, v, v; java.util.ArrayList v, v; java.lang.String v, v, v, v, v, v; org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink v; org.finos.legend.engine.persistence.components.relational.api.IngestStatus v, v; org.finos.legend.engine.persistence.components.common.Datasets v; boolean v, v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.relational.api.IngestorResult v; java.util.List v, v; java.util.Optional v, v, v, v, v; org.finos.legend.engine.persistence.components.relational.SqlPlan v; java.util.HashMap v; org.slf4j.Logger v; java.util.Iterator v; org.finos.legend.engine.persistence.components.executor.Executor v; java.time.format.DateTimeFormatter v; java.time.Clock v; java.lang.Object v, v, v, v, v, v, v, v; v := @this: org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink; v := @parameter: org.finos.legend.engine.persistence.components.common.Datasets; v := @parameter: org.finos.legend.engine.persistence.components.executor.Executor; v := @parameter: org.finos.legend.engine.persistence.components.relational.SqlPlan; v := @parameter: java.util.Map; v := @parameter: java.util.Map; v := @parameter: java.time.Clock; v = interfaceinvoke v.(v, v); v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = new java.util.ArrayList; specialinvoke v.()>(); v = 0L; v = 0L; v = 0L; v = new java.util.ArrayList; specialinvoke v.()>(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v, "status"); v = virtualinvoke v.(v, "file"); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.("LOADED"); if v == 0 goto label; v = v + 1L; goto label; label: v = virtualinvoke v.(); interfaceinvoke v.(v); v = specialinvoke v.(v); interfaceinvoke v.(v); label: v = virtualinvoke v.(v, "errors_seen"); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v + v; label: v = virtualinvoke v.(v, "rows_loaded"); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v + v; goto label; label: v = new java.util.HashMap; specialinvoke v.()>(); v = ; v = staticinvoke (v); interfaceinvoke v.(v, v); v = ; v = staticinvoke (v); interfaceinvoke v.(v, v); v = ; v = staticinvoke (v); interfaceinvoke v.(v, v); v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = interfaceinvoke v.("{BATCH_START_TIMESTAMP_PLACEHOLDER}"); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = staticinvoke (v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = interfaceinvoke v.("{NEXT_BATCH_ID_PATTERN}"); if v == 0 goto label; v = interfaceinvoke v.("{NEXT_BATCH_ID_PATTERN}"); v = virtualinvoke v.(); v = staticinvoke (v); goto label; label: v = null; label: v = staticinvoke (v); v = virtualinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); goto label; label: v = staticinvoke (",", v); v = dynamicinvoke "makeConcatWithConstants" (v) ("Errors encountered: \u0001"); v = ; interfaceinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); label: return v; } private java.lang.String getErrorMessage(java.util.Map) { java.lang.Throwable v; org.finos.legend.engine.persistence.components.exception.JsonReadOrWriteException v; com.fasterxml.jackson.databind.ObjectMapper v; java.util.HashMap v; java.util.Map v; java.lang.Object v, v, v, v, v; java.lang.String v, v; org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink v; v := @this: org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink; v := @parameter: java.util.Map; v = new java.util.HashMap; specialinvoke v.()>(); v = interfaceinvoke v.("file"); interfaceinvoke v.("file", v); v = interfaceinvoke v.("status"); interfaceinvoke v.("status", v); v = interfaceinvoke v.("errors_seen"); interfaceinvoke v.("errors_seen", v); v = interfaceinvoke v.("first_error"); interfaceinvoke v.("first_error", v); v = interfaceinvoke v.("first_error_column_name"); interfaceinvoke v.("first_error_column_name", v); v = new com.fasterxml.jackson.databind.ObjectMapper; specialinvoke v.()>(); label: v = virtualinvoke v.(v); label: return v; label: v := @caughtexception; v = new org.finos.legend.engine.persistence.components.exception.JsonReadOrWriteException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; catch com.fasterxml.jackson.core.JsonProcessingException from label to label with label; } static void () { org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.TryCastFunctionVisitor v; java.util.Map v, v, v; java.util.Set v, v, v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.ToArrayFunctionVisitor v; org.finos.legend.engine.persistence.components.util.Capability v, v, v, v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType[] v, v, v, v, v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.StagedFilesDatasetVisitor v; org.finos.legend.engine.persistence.components.relational.snowflake.SnowflakeSink v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.AlterVisitor v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.CastFunctionVisitor v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.StagedFilesSelectionVisitor v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.ClusterKeyVisitor v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.ShowVisitor v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.MetadataRowNumberFieldVisitor v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.MetadataFileNameFieldVisitor v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.CopyVisitor v; java.util.List v, v, v, v, v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.DatasetAdditionalPropertiesVisitor v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.SchemaDefinitionVisitor v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.FieldVisitor v; java.util.HashMap v, v, v; java.util.HashSet v, v, v, v, v, v; org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.slf4j.Logger v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.StagedFilesDatasetReferenceVisitor v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.StagedFilesFieldValueVisitor v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.DigestUdfVisitor v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.SQLCreateVisitor v; org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.BatchEndTimestampVisitor v; v = staticinvoke (class "Lorg/finos/legend/engine/persistence/components/relational/snowflake/SnowflakeSink;"); = v; v = new java.util.HashSet; specialinvoke v.()>(); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = staticinvoke (v); = v; v = new java.util.HashMap; specialinvoke v.()>(); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.SchemaDefinitionVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/datasets/SchemaDefinition;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.SQLCreateVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/operations/Create;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.ClusterKeyVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/datasets/ClusterKey;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.AlterVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/operations/Alter;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.ShowVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/operations/Show;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.BatchEndTimestampVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/values/BatchEndTimestamp;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.FieldVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/datasets/Field;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.DatasetAdditionalPropertiesVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/datasets/DatasetAdditionalProperties;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.CopyVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/operations/Copy;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.StagedFilesDatasetReferenceVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/datasets/StagedFilesDatasetReference;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.StagedFilesDatasetVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/datasets/StagedFilesDataset;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.StagedFilesFieldValueVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/values/StagedFilesFieldValue;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.StagedFilesSelectionVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/datasets/StagedFilesSelection;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.DigestUdfVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/values/DigestUdf;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.CastFunctionVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/values/CastFunction;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.TryCastFunctionVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/values/TryCastFunction;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.MetadataFileNameFieldVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/values/MetadataFileNameField;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.MetadataRowNumberFieldVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/values/MetadataRowNumberField;", v); v = new org.finos.legend.engine.persistence.components.relational.snowflake.sql.visitor.ToArrayFunctionVisitor; specialinvoke v.()>(); interfaceinvoke v.(class "Lorg/finos/legend/engine/persistence/components/logicalplan/values/ToArrayFunction;", v); v = staticinvoke (v); = v; v = new java.util.HashMap; specialinvoke v.()>(); v = ; v = new java.util.HashSet; v = newarray (org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType)[6]; v = ; v[0] = v; v = ; v[1] = v; v = ; v[2] = v; v = ; v[3] = v; v = ; v[4] = v; v = ; v[5] = v; v = staticinvoke (v); specialinvoke v.(java.util.Collection)>(v); interfaceinvoke v.(v, v); v = ; v = new java.util.HashSet; v = newarray (org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType)[9]; v = ; v[0] = v; v = ; v[1] = v; v = ; v[2] = v; v = ; v[3] = v; v = ; v[4] = v; v = ; v[5] = v; v = ; v[6] = v; v = ; v[7] = v; v = ; v[8] = v; v = staticinvoke (v); specialinvoke v.(java.util.Collection)>(v); interfaceinvoke v.(v, v); v = ; v = new java.util.HashSet; v = newarray (org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType)[6]; v = ; v[0] = v; v = ; v[1] = v; v = ; v[2] = v; v = ; v[3] = v; v = ; v[4] = v; v = ; v[5] = v; v = staticinvoke (v); specialinvoke v.(java.util.Collection)>(v); interfaceinvoke v.(v, v); v = ; v = new java.util.HashSet; v = newarray (org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType)[3]; v = ; v[0] = v; v = ; v[1] = v; v = ; v[2] = v; v = staticinvoke (v); specialinvoke v.