public class org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink 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;
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.postgres.PostgresSink: 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>()
{
org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink v;
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;
v := @this: org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink;
v = <org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink: java.util.Set CAPABILITIES>;
v = <org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink: java.util.Map IMPLICIT_DATA_TYPE_MAPPING>;
v = <org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink: java.util.Map EXPLICIT_DATA_TYPE_MAPPING>;
v = <org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink: java.util.Map LOGICAL_PLAN_VISITOR_BY_CLASS>;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink$lambda_new_0__1: org.finos.legend.engine.persistence.components.relational.RelationalSink$DatasetExists bootstrap$()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink$lambda_new_1__2: org.finos.legend.engine.persistence.components.relational.RelationalSink$ValidateMainDatasetSchema bootstrap$()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink$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.postgres.PostgresSink 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.postgres.PostgresSink;
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 Postgres 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.postgres.PostgresSink v;
java.lang.Object v;
boolean v;
v := @this: org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink;
v := @parameter: org.finos.legend.engine.persistence.components.ingestmode.IngestMode;
v = <org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink: 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>()
{
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;
org.finos.legend.engine.persistence.components.relational.postgres.sql.visitor.SchemaDefinitionVisitor v;
org.finos.legend.engine.persistence.components.relational.postgres.sql.visitor.SQLMergeVisitor v;
org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink$1 v;
org.finos.legend.engine.persistence.components.relational.postgres.sql.visitor.SQLUpdateVisitor 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.postgres.sql.visitor.FieldVisitor v;
java.util.Set v, v, v, v;
org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink 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.relational.postgres.sql.visitor.ParseJsonFunctionVisitor 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 = 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 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 = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
<org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink: 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.postgres.sql.visitor.SchemaDefinitionVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.postgres.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.postgres.sql.visitor.FieldVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.postgres.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.postgres.sql.visitor.SQLUpdateVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.postgres.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.postgres.sql.visitor.SQLMergeVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.postgres.sql.visitor.SQLMergeVisitor: 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/Merge;", v);
v = new org.finos.legend.engine.persistence.components.relational.postgres.sql.visitor.ParseJsonFunctionVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.postgres.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 = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
<org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink: 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.postgres.PostgresSink: 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.postgres.PostgresSink: java.util.Map EXPLICIT_DATA_TYPE_MAPPING> = v;
v = new org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink: void <init>()>();
<org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink: org.finos.legend.engine.persistence.components.relational.RelationalSink INSTANCE> = v;
v = new org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink$1;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink$1: void <init>()>();
<org.finos.legend.engine.persistence.components.relational.postgres.PostgresSink: org.finos.legend.engine.persistence.components.ingestmode.IngestModeVisitor IS_INGEST_MODE_SUPPORTED> = v;
return;
}
}