public class org.finos.legend.engine.persistence.components.relational.h.H2Sink extends org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink
{
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;
public static org.finos.legend.engine.persistence.components.relational.RelationalSink get()
{
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
v = <org.finos.legend.engine.persistence.components.relational.h.H2Sink: org.finos.legend.engine.persistence.components.relational.RelationalSink INSTANCE>;
return v;
}
public static java.sql.Connection createConnection(java.lang.String, java.lang.String, java.lang.String)
{
java.sql.SQLException v;
java.sql.Connection v;
java.lang.String v, v, v;
java.lang.IllegalArgumentException v;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
label:
v = staticinvoke <java.sql.DriverManager: java.sql.Connection getConnection(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
label:
return v;
label:
v := @caughtexception;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.Throwable)>(v);
throw v;
catch java.sql.SQLException from label to label with label;
}
private void <init>()
{
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.RelationalSink$ValidateMainDatasetSchema v;
org.finos.legend.engine.persistence.components.relational.h.H2Sink v;
v := @this: org.finos.legend.engine.persistence.components.relational.h.H2Sink;
v = <org.finos.legend.engine.persistence.components.relational.h.H2Sink: java.util.Set CAPABILITIES>;
v = <org.finos.legend.engine.persistence.components.relational.h.H2Sink: java.util.Map IMPLICIT_DATA_TYPE_MAPPING>;
v = <org.finos.legend.engine.persistence.components.relational.h.H2Sink: java.util.Map EXPLICIT_DATA_TYPE_MAPPING>;
v = <org.finos.legend.engine.persistence.components.relational.h.H2Sink: java.util.Map LOGICAL_PLAN_VISITOR_BY_CLASS>;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.h.H2Sink$lambda_new_0__1: org.finos.legend.engine.persistence.components.relational.RelationalSink$DatasetExists bootstrap$()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.h.H2Sink$lambda_new_1__2: org.finos.legend.engine.persistence.components.relational.RelationalSink$ValidateMainDatasetSchema bootstrap$()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.h.H2Sink$lambda_new_2__3: org.finos.legend.engine.persistence.components.relational.RelationalSink$ConstructDatasetFromDatabase bootstrap$()>();
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: void <init>(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.h.H2Sink v;
boolean v;
org.finos.legend.engine.persistence.components.relational.api.RelationalConnection v;
v := @this: org.finos.legend.engine.persistence.components.relational.h.H2Sink;
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.<org.finos.legend.engine.persistence.components.relational.jdbc.JdbcConnection: java.sql.Connection connection()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.jdbc.JdbcHelper: org.finos.legend.engine.persistence.components.relational.jdbc.JdbcHelper of(java.sql.Connection)>(v);
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.executor.RelationalExecutor: void <init>(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.UnsupportedOperationException: void <init>(java.lang.String)>("Only JdbcConnection is supported for H2 Sink");
throw 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.relational.api.IngestStatus v;
org.finos.legend.engine.persistence.components.common.StatisticName v, v, v, v;
org.finos.legend.engine.persistence.components.common.Datasets v;
java.lang.Integer v, v, v;
java.util.Map v, v;
org.finos.legend.engine.persistence.components.relational.h.H2Sink v;
boolean v;
org.finos.legend.engine.persistence.components.relational.api.IngestorResult$Builder v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.api.IngestorResult v;
java.util.List v;
java.util.stream.Stream v;
java.util.Optional v, v, v, v, v, v;
java.time.LocalDateTime v;
org.finos.legend.engine.persistence.components.relational.SqlPlan v, v;
java.util.HashMap v;
java.util.function.Function v, v, v, v;
java.util.function.Supplier v;
java.lang.String v, v, 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 := @this: org.finos.legend.engine.persistence.components.relational.h.H2Sink;
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;
interfaceinvoke v.<org.finos.legend.engine.persistence.components.executor.Executor: void executePhysicalPlan(org.finos.legend.engine.persistence.components.physicalplan.PhysicalPlan,java.util.Map)>(v, v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = <org.finos.legend.engine.persistence.components.common.StatisticName: org.finos.legend.engine.persistence.components.common.StatisticName FILES_LOADED>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.common.StatisticName: org.finos.legend.engine.persistence.components.common.StatisticName ROWS_WITH_ERRORS>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.common.StatisticName: org.finos.legend.engine.persistence.components.common.StatisticName ROWS_INSERTED>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = <org.finos.legend.engine.persistence.components.common.StatisticName: org.finos.legend.engine.persistence.components.common.StatisticName ROWS_INSERTED>;
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.executor.Executor: java.util.List executePhysicalPlanAndGetResults(org.finos.legend.engine.persistence.components.physicalplan.PhysicalPlan,java.util.Map)>(v, v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.Optional findFirst()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.h.H2Sink$getData__4: java.util.function.Function bootstrap$()>();
v = virtualinvoke v.<java.util.Optional: java.util.Optional map(java.util.function.Function)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.h.H2Sink$lambda_performBulkLoad_3__5: java.util.function.Function bootstrap$()>();
v = virtualinvoke v.<java.util.Optional: java.util.Optional flatMap(java.util.function.Function)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.h.H2Sink$values__6: java.util.function.Function bootstrap$()>();
v = virtualinvoke v.<java.util.Optional: java.util.Optional map(java.util.function.Function)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.h.H2Sink$lambda_performBulkLoad_4__7: java.util.function.Function bootstrap$()>();
v = virtualinvoke v.<java.util.Optional: java.util.Optional flatMap(java.util.function.Function)>(v);
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.h.H2Sink$init__8: java.util.function.Supplier bootstrap$()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object orElseThrow(java.util.function.Supplier)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.IngestorResult: org.finos.legend.engine.persistence.components.relational.api.IngestorResult$Builder builder()>();
v = <org.finos.legend.engine.persistence.components.relational.api.IngestStatus: org.finos.legend.engine.persistence.components.relational.api.IngestStatus SUCCEEDED>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.IngestorResult$Builder: org.finos.legend.engine.persistence.components.relational.api.IngestorResult$Builder status(org.finos.legend.engine.persistence.components.relational.api.IngestStatus)>(v);
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("{NEXT_BATCH_ID_PATTERN}");
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("{NEXT_BATCH_ID_PATTERN}");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.PlaceholderValue: java.lang.String value()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(java.lang.String)>(v);
goto label;
label:
v = null;
label:
v = staticinvoke <java.util.Optional: java.util.Optional ofNullable(java.lang.Object)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.IngestorResult$Builder: org.finos.legend.engine.persistence.components.relational.api.IngestorResult$Builder batchId(java.util.Optional)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.IngestorResult$Builder: org.finos.legend.engine.persistence.components.relational.api.IngestorResult$Builder updatedDatasets(org.finos.legend.engine.persistence.components.common.Datasets)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.IngestorResult$Builder: org.finos.legend.engine.persistence.components.relational.api.IngestorResult$Builder putAllStatisticByName(java.util.Map)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("{BATCH_START_TIMESTAMP_PLACEHOLDER}");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.util.PlaceholderValue: java.lang.String value()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.IngestorResult$Builder: org.finos.legend.engine.persistence.components.relational.api.IngestorResult$Builder ingestionTimestampUTC(java.lang.String)>(v);
v = staticinvoke <java.time.LocalDateTime: java.time.LocalDateTime now(java.time.Clock)>(v);
v = <org.finos.legend.engine.persistence.components.transformer.Transformer$TransformOptionsAbstract: java.time.format.DateTimeFormatter DATE_TIME_FORMATTER>;
v = virtualinvoke v.<java.time.LocalDateTime: java.lang.String format(java.time.format.DateTimeFormatter)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.IngestorResult$Builder: org.finos.legend.engine.persistence.components.relational.api.IngestorResult$Builder ingestionEndTimestampUTC(java.lang.String)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.IngestorResult$Builder: org.finos.legend.engine.persistence.components.relational.api.IngestorResult build()>();
return 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;
java.util.Map v;
int v;
org.finos.legend.engine.persistence.components.transformer.Transformer v;
org.finos.legend.engine.persistence.components.relational.h.H2Sink v;
v := @this: org.finos.legend.engine.persistence.components.relational.h.H2Sink;
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:
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.h.H2Sink: java.util.List performDryRunWithValidationQueries(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)>(v, v, v, v, v, v, v);
label:
return v;
label:
v := @caughtexception;
v = specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.H2Sink: java.util.List parseH2Exceptions(java.lang.Exception)>(v);
return v;
catch java.lang.Exception from label to label with label;
}
private java.util.List parseH2Exceptions(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;
java.util.Map v;
java.lang.String v, v, v;
org.finos.legend.engine.persistence.components.relational.h.H2Sink v;
boolean v;
org.finos.legend.engine.persistence.components.relational.api.DataError$Builder v, v, v, v, v, v, v;
java.lang.Exception v;
java.util.List v, v;
java.util.Optional v, v, v;
v := @this: org.finos.legend.engine.persistence.components.relational.h.H2Sink;
v := @parameter: java.lang.Exception;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.utils.IngestionUtils: java.lang.String removeLineBreaks(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("IO Exception");
if v == 0 goto label;
v = specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.H2Sink: java.util.Optional extractProblematicValueFromErrorMessage(java.lang.String)>(v);
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.h.H2Sink: java.util.Map buildErrorDetails(java.util.Optional,java.util.Optional,java.util.Optional)>(v, v, v);
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.DataError: org.finos.legend.engine.persistence.components.relational.api.DataError$Builder builder()>();
v = <org.finos.legend.engine.persistence.components.relational.api.ErrorCategory: org.finos.legend.engine.persistence.components.relational.api.ErrorCategory FILE_NOT_FOUND>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.DataError$Builder: org.finos.legend.engine.persistence.components.relational.api.DataError$Builder errorCategory(org.finos.legend.engine.persistence.components.relational.api.ErrorCategory)>(v);
v = <org.finos.legend.engine.persistence.components.relational.api.ErrorCategory: org.finos.legend.engine.persistence.components.relational.api.ErrorCategory FILE_NOT_FOUND>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.ErrorCategory: java.lang.String getDefaultErrorMessage()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.DataError$Builder: org.finos.legend.engine.persistence.components.relational.api.DataError$Builder errorMessage(java.lang.String)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.DataError$Builder: org.finos.legend.engine.persistence.components.relational.api.DataError$Builder putAllErrorDetails(java.util.Map)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.DataError$Builder: org.finos.legend.engine.persistence.components.relational.api.DataError build()>();
v = staticinvoke <java.util.Collections: java.util.List singletonList(java.lang.Object)>(v);
return v;
label:
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.DataError: org.finos.legend.engine.persistence.components.relational.api.DataError$Builder builder()>();
v = <org.finos.legend.engine.persistence.components.relational.api.ErrorCategory: org.finos.legend.engine.persistence.components.relational.api.ErrorCategory UNKNOWN>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.DataError$Builder: org.finos.legend.engine.persistence.components.relational.api.DataError$Builder errorCategory(org.finos.legend.engine.persistence.components.relational.api.ErrorCategory)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.DataError$Builder: org.finos.legend.engine.persistence.components.relational.api.DataError$Builder errorMessage(java.lang.String)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.DataError$Builder: org.finos.legend.engine.persistence.components.relational.api.DataError build()>();
v = staticinvoke <java.util.Collections: java.util.List singletonList(java.lang.Object)>(v);
return v;
}
public java.util.List performDryRunWithValidationQueries(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.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;
org.finos.legend.engine.persistence.components.relational.h.H2Sink v;
boolean v, v, v, v, v;
org.finos.legend.engine.persistence.components.util.ValidationCategory[] v;
org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan v;
java.util.List v, v, v, v;
java.util.stream.Stream v, v;
org.finos.legend.engine.persistence.components.util.ValidationCategory v, v, v, v, v;
java.util.Optional v;
java.lang.Throwable v;
org.finos.legend.engine.persistence.components.relational.SqlPlan v, v, v;
java.util.HashMap v;
java.util.function.Function 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.lang.String v, v;
java.util.LinkedList v;
java.util.Iterator v, v, v;
org.finos.legend.engine.persistence.components.executor.Executor v;
java.lang.RuntimeException v;
java.lang.Object v, v, v, v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.transformer.Transformer v;
v := @this: org.finos.legend.engine.persistence.components.relational.h.H2Sink;
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;
interfaceinvoke v.<org.finos.legend.engine.persistence.components.executor.Executor: void executePhysicalPlan(org.finos.legend.engine.persistence.components.physicalplan.PhysicalPlan)>(v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.util.ValidationCategory: org.finos.legend.engine.persistence.components.util.ValidationCategory[] values()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.common.Datasets: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset stagingDataset()>();
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset: org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaReference schemaReference()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.SchemaReference: java.util.List fieldValues()>();
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.h.H2Sink$fieldName__9: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v = <org.finos.legend.engine.persistence.components.util.ValidationCategory: org.finos.legend.engine.persistence.components.util.ValidationCategory NULL_VALUE>;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object getOrDefault(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.util.ValidationCategory: org.finos.legend.engine.persistence.components.util.ValidationCategory TYPE_CONVERSION>;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object getOrDefault(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.h.H2Sink: int findNullValuesDataErrors(org.finos.legend.engine.persistence.components.executor.Executor,java.util.List,java.util.Map,java.util.List,org.finos.legend.engine.persistence.components.relational.CaseConversion)>(v, v, v, v, v);
v = 0 + v;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
label:
interfaceinvoke v.<org.eclipse.collections.api.tuple.Pair: java.lang.Object getTwo()>();
interfaceinvoke v.<org.finos.legend.engine.persistence.components.executor.Executor: java.util.List executePhysicalPlanAndGetResults(org.finos.legend.engine.persistence.components.physicalplan.PhysicalPlan)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.RuntimeException: java.lang.Throwable getCause()>();
v = virtualinvoke v.<java.lang.Throwable: java.lang.String getMessage()>();
v = specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.H2Sink: java.util.Optional extractProblematicValueFromErrorMessage(java.lang.String)>(v);
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.eclipse.collections.api.tuple.Pair: java.lang.Object getOne()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.LogicalPlanFactory: org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan getLogicalPlanForSelectAllFieldsWithStringFieldEquals(org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue,java.lang.String)>(v, v);
interfaceinvoke v.<org.finos.legend.engine.persistence.components.transformer.Transformer: org.finos.legend.engine.persistence.components.physicalplan.PhysicalPlan generatePhysicalPlan(org.finos.legend.engine.persistence.components.logicalplan.LogicalPlan)>(v);
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.executor.Executor: java.util.List executePhysicalPlanAndGetResults(org.finos.legend.engine.persistence.components.physicalplan.PhysicalPlan,int)>(v, v);
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.sql.TabularData: java.util.List getData()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = <org.finos.legend.engine.persistence.components.util.ValidationCategory: org.finos.legend.engine.persistence.components.util.ValidationCategory TYPE_CONVERSION>;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue: java.lang.String fieldName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.h.H2Sink: org.finos.legend.engine.persistence.components.relational.api.DataError constructDataError(java.util.List,java.util.Map,org.finos.legend.engine.persistence.components.util.ValidationCategory,java.lang.String,org.finos.legend.engine.persistence.components.relational.CaseConversion)>(v, v, v, v, v);
v = <org.finos.legend.engine.persistence.components.util.ValidationCategory: org.finos.legend.engine.persistence.components.util.ValidationCategory TYPE_CONVERSION>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
interfaceinvoke v.<java.util.Queue: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.h.H2Sink: java.util.List getDataErrorsWithFairDistributionAcrossCategories(int,int,java.util.Map)>(v, v, v);
return v;
catch java.lang.RuntimeException from label to label with label;
}
private java.util.Optional extractProblematicValueFromErrorMessage(java.lang.String)
{
int v;
java.util.Optional v;
java.lang.String v, v;
org.finos.legend.engine.persistence.components.relational.h.H2Sink v;
boolean v, v, v;
v := @this: org.finos.legend.engine.persistence.components.relational.h.H2Sink;
v := @parameter: java.lang.String;
v = virtualinvoke v.<java.lang.String: int indexOf(java.lang.String)>("; SQL statement");
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(0, v);
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("Data conversion error");
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.utils.IngestionUtils: java.util.Optional findToken(java.lang.String,java.lang.String,int)>(v, "Data conversion error converting \"(.*)\"", 1);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("Cannot parse");
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.utils.IngestionUtils: java.util.Optional findToken(java.lang.String,java.lang.String,int)>(v, "Cannot parse \"(.*)\" constant \"(.*)\"", 2);
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("IO Exception");
if v == 0 goto label;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.utils.IngestionUtils: java.util.Optional findToken(java.lang.String,java.lang.String,int)>(v, "IO Exception: \"IOException reading (.*)\"", 1);
label:
return v;
}
static void <clinit>()
{
java.util.Map v, v, v;
org.finos.legend.engine.persistence.components.relational.h.H2Sink v;
org.finos.legend.engine.persistence.components.relational.h.sql.visitor.SchemaDefinitionVisitor v;
org.finos.legend.engine.persistence.components.relational.h.sql.visitor.MetadataRowNumberFieldVisitor v;
org.finos.legend.engine.persistence.components.util.Capability v, v, v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.h.sql.visitor.LoadCsvVisitor v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType[] v, v, v, v, v, v, v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.h.sql.visitor.StagedFilesSelectionVisitor v;
org.finos.legend.engine.persistence.components.relational.h.sql.visitor.CsvExternalDatasetReferenceVisitor v;
org.finos.legend.engine.persistence.components.relational.h.sql.visitor.StagedFilesDatasetReferenceVisitor v;
java.util.HashSet v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.h.sql.visitor.StagedFilesDatasetVisitor v;
org.finos.legend.engine.persistence.components.relational.h.sql.visitor.FieldVisitor v;
org.finos.legend.engine.persistence.components.relational.h.sql.visitor.ParseJsonFunctionVisitor v;
org.finos.legend.engine.persistence.components.relational.h.sql.visitor.HashFunctionVisitor v;
java.util.Set v, v, v, v;
org.finos.legend.engine.persistence.components.relational.h.sql.visitor.ToArrayFunctionVisitor v;
org.finos.legend.engine.persistence.components.relational.h.sql.visitor.MetadataFileNameFieldVisitor v;
org.finos.legend.engine.persistence.components.relational.h.sql.visitor.TryCastFunctionVisitor v;
org.finos.legend.engine.persistence.components.relational.h.sql.visitor.DigestUdfVisitor v;
java.util.List v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.HashMap 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, 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, v, v, v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.h.sql.visitor.CopyVisitor v;
org.finos.legend.engine.persistence.components.relational.h.sql.visitor.StagedFilesFieldValueVisitor v;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = <org.finos.legend.engine.persistence.components.util.Capability: org.finos.legend.engine.persistence.components.util.Capability MERGE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.finos.legend.engine.persistence.components.util.Capability: org.finos.legend.engine.persistence.components.util.Capability ALIAS_IN_HAVING>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.finos.legend.engine.persistence.components.util.Capability: org.finos.legend.engine.persistence.components.util.Capability ADD_COLUMN>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.finos.legend.engine.persistence.components.util.Capability: org.finos.legend.engine.persistence.components.util.Capability IMPLICIT_DATA_TYPE_CONVERSION>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.finos.legend.engine.persistence.components.util.Capability: org.finos.legend.engine.persistence.components.util.Capability EXPLICIT_DATA_TYPE_CONVERSION>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.finos.legend.engine.persistence.components.util.Capability: org.finos.legend.engine.persistence.components.util.Capability DATA_TYPE_LENGTH_CHANGE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.finos.legend.engine.persistence.components.util.Capability: org.finos.legend.engine.persistence.components.util.Capability DATA_TYPE_SCALE_CHANGE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.finos.legend.engine.persistence.components.util.Capability: org.finos.legend.engine.persistence.components.util.Capability TRANSFORM_WHILE_COPY>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.finos.legend.engine.persistence.components.util.Capability: org.finos.legend.engine.persistence.components.util.Capability DRY_RUN>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
<org.finos.legend.engine.persistence.components.relational.h.H2Sink: java.util.Set CAPABILITIES> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = new org.finos.legend.engine.persistence.components.relational.h.sql.visitor.SchemaDefinitionVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.sql.visitor.SchemaDefinitionVisitor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(class "Lorg/finos/legend/engine/persistence/components/logicalplan/datasets/SchemaDefinition;", v);
v = new org.finos.legend.engine.persistence.components.relational.h.sql.visitor.HashFunctionVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.sql.visitor.HashFunctionVisitor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(class "Lorg/finos/legend/engine/persistence/components/logicalplan/values/HashFunction;", v);
v = new org.finos.legend.engine.persistence.components.relational.h.sql.visitor.ParseJsonFunctionVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.sql.visitor.ParseJsonFunctionVisitor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(class "Lorg/finos/legend/engine/persistence/components/logicalplan/values/ParseJsonFunction;", v);
v = new org.finos.legend.engine.persistence.components.relational.h.sql.visitor.LoadCsvVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.sql.visitor.LoadCsvVisitor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(class "Lorg/finos/legend/engine/persistence/components/logicalplan/operations/LoadCsv;", v);
v = new org.finos.legend.engine.persistence.components.relational.h.sql.visitor.CsvExternalDatasetReferenceVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.sql.visitor.CsvExternalDatasetReferenceVisitor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(class "Lorg/finos/legend/engine/persistence/components/logicalplan/datasets/CsvExternalDatasetReference;", v);
v = new org.finos.legend.engine.persistence.components.relational.h.sql.visitor.FieldVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.sql.visitor.FieldVisitor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(class "Lorg/finos/legend/engine/persistence/components/logicalplan/datasets/Field;", v);
v = new org.finos.legend.engine.persistence.components.relational.h.sql.visitor.CopyVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.sql.visitor.CopyVisitor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(class "Lorg/finos/legend/engine/persistence/components/logicalplan/operations/Copy;", v);
v = new org.finos.legend.engine.persistence.components.relational.h.sql.visitor.StagedFilesDatasetVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.sql.visitor.StagedFilesDatasetVisitor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(class "Lorg/finos/legend/engine/persistence/components/logicalplan/datasets/StagedFilesDataset;", v);
v = new org.finos.legend.engine.persistence.components.relational.h.sql.visitor.StagedFilesSelectionVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.sql.visitor.StagedFilesSelectionVisitor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(class "Lorg/finos/legend/engine/persistence/components/logicalplan/datasets/StagedFilesSelection;", v);
v = new org.finos.legend.engine.persistence.components.relational.h.sql.visitor.StagedFilesDatasetReferenceVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.sql.visitor.StagedFilesDatasetReferenceVisitor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(class "Lorg/finos/legend/engine/persistence/components/logicalplan/datasets/StagedFilesDatasetReference;", v);
v = new org.finos.legend.engine.persistence.components.relational.h.sql.visitor.StagedFilesFieldValueVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.sql.visitor.StagedFilesFieldValueVisitor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(class "Lorg/finos/legend/engine/persistence/components/logicalplan/values/StagedFilesFieldValue;", v);
v = new org.finos.legend.engine.persistence.components.relational.h.sql.visitor.DigestUdfVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.sql.visitor.DigestUdfVisitor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(class "Lorg/finos/legend/engine/persistence/components/logicalplan/values/DigestUdf;", v);
v = new org.finos.legend.engine.persistence.components.relational.h.sql.visitor.ToArrayFunctionVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.sql.visitor.ToArrayFunctionVisitor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(class "Lorg/finos/legend/engine/persistence/components/logicalplan/values/ToArrayFunction;", v);
v = new org.finos.legend.engine.persistence.components.relational.h.sql.visitor.TryCastFunctionVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.sql.visitor.TryCastFunctionVisitor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(class "Lorg/finos/legend/engine/persistence/components/logicalplan/values/TryCastFunction;", v);
v = new org.finos.legend.engine.persistence.components.relational.h.sql.visitor.MetadataFileNameFieldVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.sql.visitor.MetadataFileNameFieldVisitor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(class "Lorg/finos/legend/engine/persistence/components/logicalplan/values/MetadataFileNameField;", v);
v = new org.finos.legend.engine.persistence.components.relational.h.sql.visitor.MetadataRowNumberFieldVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.sql.visitor.MetadataRowNumberFieldVisitor: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(class "Lorg/finos/legend/engine/persistence/components/logicalplan/values/MetadataRowNumberField;", v);
v = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
<org.finos.legend.engine.persistence.components.relational.h.H2Sink: java.util.Map LOGICAL_PLAN_VISITOR_BY_CLASS> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DECIMAL>;
v = new java.util.HashSet;
v = newarray (org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType)[9];
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType TINYINT>;
v[0] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType SMALLINT>;
v[1] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType INTEGER>;
v[2] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType INT>;
v[3] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType BIGINT>;
v[4] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType FLOAT>;
v[5] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DOUBLE>;
v[6] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType REAL>;
v[7] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType NUMERIC>;
v[8] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DOUBLE>;
v = new java.util.HashSet;
v = newarray (org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType)[6];
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType TINYINT>;
v[0] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType SMALLINT>;
v[1] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType INTEGER>;
v[2] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType INT>;
v[3] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType FLOAT>;
v[4] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType REAL>;
v[5] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType REAL>;
v = new java.util.HashSet;
v = newarray (org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType)[6];
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType TINYINT>;
v[0] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType SMALLINT>;
v[1] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType INTEGER>;
v[2] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType INT>;
v[3] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType FLOAT>;
v[4] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DOUBLE>;
v[5] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType BIGINT>;
v = new java.util.HashSet;
v = newarray (org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType)[4];
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType TINYINT>;
v[0] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType SMALLINT>;
v[1] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType INTEGER>;
v[2] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType INT>;
v[3] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType INTEGER>;
v = new java.util.HashSet;
v = newarray (org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType)[3];
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType INT>;
v[0] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType TINYINT>;
v[1] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType SMALLINT>;
v[2] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType SMALLINT>;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType TINYINT>;
v = staticinvoke <java.util.Collections: java.util.Set singleton(java.lang.Object)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType VARCHAR>;
v = new java.util.HashSet;
v = newarray (org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType)[2];
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType CHAR>;
v[0] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType STRING>;
v[1] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType TIMESTAMP>;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DATETIME>;
v = staticinvoke <java.util.Collections: java.util.Set singleton(java.lang.Object)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
<org.finos.legend.engine.persistence.components.relational.h.H2Sink: java.util.Map IMPLICIT_DATA_TYPE_MAPPING> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType TINYINT>;
v = new java.util.HashSet;
v = newarray (org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType)[8];
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType SMALLINT>;
v[0] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType INTEGER>;
v[1] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType INT>;
v[2] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType BIGINT>;
v[3] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType FLOAT>;
v[4] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DOUBLE>;
v[5] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DECIMAL>;
v[6] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType NUMERIC>;
v[7] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType SMALLINT>;
v = new java.util.HashSet;
v = newarray (org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType)[7];
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType INTEGER>;
v[0] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType INT>;
v[1] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType BIGINT>;
v[2] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType FLOAT>;
v[3] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DOUBLE>;
v[4] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DECIMAL>;
v[5] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType NUMERIC>;
v[6] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType INTEGER>;
v = new java.util.HashSet;
v = newarray (org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType)[5];
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType BIGINT>;
v[0] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType FLOAT>;
v[1] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DOUBLE>;
v[2] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DECIMAL>;
v[3] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType NUMERIC>;
v[4] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType BIGINT>;
v = new java.util.HashSet;
v = newarray (org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType)[2];
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DECIMAL>;
v[0] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType NUMERIC>;
v[1] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType REAL>;
v = new java.util.HashSet;
v = newarray (org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType)[3];
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DOUBLE>;
v[0] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DECIMAL>;
v[1] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType NUMERIC>;
v[2] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DOUBLE>;
v = new java.util.HashSet;
v = newarray (org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType)[2];
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DECIMAL>;
v[0] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType NUMERIC>;
v[1] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType CHAR>;
v = new java.util.HashSet;
v = newarray (org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType)[3];
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType VARCHAR>;
v[0] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType LONGTEXT>;
v[1] = v;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType STRING>;
v[2] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType VARCHAR>;
v = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType LONGTEXT>;
v = staticinvoke <java.util.Collections: java.util.Set singleton(java.lang.Object)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
<org.finos.legend.engine.persistence.components.relational.h.H2Sink: java.util.Map EXPLICIT_DATA_TYPE_MAPPING> = v;
v = new org.finos.legend.engine.persistence.components.relational.h.H2Sink;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.h.H2Sink: void <init>()>();
<org.finos.legend.engine.persistence.components.relational.h.H2Sink: org.finos.legend.engine.persistence.components.relational.RelationalSink INSTANCE> = v;
return;
}
}