public class org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink 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;
static final org.finos.legend.engine.persistence.components.relational.RelationalSink$ValidateMainDatasetSchema VALIDATE_MAIN_DATASET_SCHEMA;
private static final org.finos.legend.engine.persistence.components.ingestmode.IngestModeVisitor IS_INGEST_MODE_SUPPORTED;
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.memsql.MemSqlSink: 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;
org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink 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;
v := @this: org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink;
v = <org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink: java.util.Set CAPABILITIES>;
v = <org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink: java.util.Map IMPLICIT_DATA_TYPE_MAPPING>;
v = <org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink: java.util.Map EXPLICIT_DATA_TYPE_MAPPING>;
v = <org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink: java.util.Map LOGICAL_PLAN_VISITOR_BY_CLASS>;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink$lambda_new_0__3: org.finos.legend.engine.persistence.components.relational.RelationalSink$DatasetExists bootstrap$()>();
v = <org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink$ValidateMainDatasetSchema VALIDATE_MAIN_DATASET_SCHEMA>;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink$lambda_new_1__4: 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)
{
org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink v;
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;
boolean v;
org.finos.legend.engine.persistence.components.relational.api.RelationalConnection v;
v := @this: org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink;
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 MemSql Sink");
throw v;
}
public boolean isIngestModeSupported(org.finos.legend.engine.persistence.components.ingestmode.IngestMode)
{
org.finos.legend.engine.persistence.components.ingestmode.IngestMode v;
org.finos.legend.engine.persistence.components.ingestmode.IngestModeVisitor v;
org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink v;
java.lang.Object v;
boolean v;
v := @this: org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink;
v := @parameter: org.finos.legend.engine.persistence.components.ingestmode.IngestMode;
v = <org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink: org.finos.legend.engine.persistence.components.ingestmode.IngestModeVisitor IS_INGEST_MODE_SUPPORTED>;
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.IngestMode: java.lang.Object accept(org.finos.legend.engine.persistence.components.ingestmode.IngestModeVisitor)>(v);
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
return v;
}
static void <clinit>()
{
org.finos.legend.engine.persistence.components.relational.memsql.sql.visitor.SQLCreateVisitor v;
java.util.Map v, v, v;
org.finos.legend.engine.persistence.components.util.Capability 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;
org.finos.legend.engine.persistence.components.relational.memsql.sql.visitor.SQLUpdateVisitor v;
org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink$2 v;
org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink$1 v;
java.util.HashSet v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.memsql.sql.visitor.ShowVisitor v;
java.util.Set v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink v;
org.finos.legend.engine.persistence.components.relational.memsql.sql.visitor.FieldVisitor v;
java.util.List v, v, 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.relational.memsql.sql.visitor.SchemaDefinitionVisitor v;
org.finos.legend.engine.persistence.components.relational.memsql.sql.visitor.AlterVisitor 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, v, v, v, v, v, v, v, v, v, v, v, 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 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 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 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 = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
<org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink: 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.memsql.sql.visitor.SchemaDefinitionVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.memsql.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.memsql.sql.visitor.AlterVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.memsql.sql.visitor.AlterVisitor: 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/Alter;", v);
v = new org.finos.legend.engine.persistence.components.relational.memsql.sql.visitor.SQLCreateVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.memsql.sql.visitor.SQLCreateVisitor: 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/Create;", v);
v = new org.finos.legend.engine.persistence.components.relational.memsql.sql.visitor.ShowVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.memsql.sql.visitor.ShowVisitor: 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/Show;", v);
v = new org.finos.legend.engine.persistence.components.relational.memsql.sql.visitor.SQLUpdateVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.memsql.sql.visitor.SQLUpdateVisitor: 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/Update;", v);
v = new org.finos.legend.engine.persistence.components.relational.memsql.sql.visitor.FieldVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.memsql.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 = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
<org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink: 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)[8];
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 = 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 FLOAT>;
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 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 REAL>;
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 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 INT>;
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 INTEGER>;
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 = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType CHAR>;
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 LONGTEXT>;
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 VARCHAR>;
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 = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
<org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink: 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)[7];
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 = 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)[6];
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 = 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)[4];
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 = 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 INT>;
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 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 = 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 = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DECIMAL>;
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 FLOAT>;
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 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 = 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)[2];
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 = 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 = <org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType: org.finos.legend.engine.persistence.components.logicalplan.datasets.DataType DECIMAL>;
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 CHAR>;
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 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 = 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 = <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.memsql.MemSqlSink: java.util.Map EXPLICIT_DATA_TYPE_MAPPING> = v;
v = new org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink: void <init>()>();
<org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink INSTANCE> = v;
v = new org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink$1;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink$1: void <init>()>();
<org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink$ValidateMainDatasetSchema VALIDATE_MAIN_DATASET_SCHEMA> = v;
v = new org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink$2;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink$2: void <init>()>();
<org.finos.legend.engine.persistence.components.relational.memsql.MemSqlSink: org.finos.legend.engine.persistence.components.ingestmode.IngestModeVisitor IS_INGEST_MODE_SUPPORTED> = v;
return;
}
}