public class org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink 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.duckdb.DuckDBSink: 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.duckdb.DuckDBSink 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.duckdb.DuckDBSink;
v = <org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink: java.util.Set CAPABILITIES>;
v = <org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink: java.util.Map IMPLICIT_DATA_TYPE_MAPPING>;
v = <org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink: java.util.Map EXPLICIT_DATA_TYPE_MAPPING>;
v = <org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink: java.util.Map LOGICAL_PLAN_VISITOR_BY_CLASS>;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink$lambda_new_0__1: org.finos.legend.engine.persistence.components.relational.RelationalSink$DatasetExists bootstrap$()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink$lambda_new_1__2: org.finos.legend.engine.persistence.components.relational.RelationalSink$ValidateMainDatasetSchema bootstrap$()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink$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;
org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink v;
java.sql.Connection v;
org.finos.legend.engine.persistence.components.relational.executor.RelationalExecutor v;
org.finos.legend.engine.persistence.components.relational.duckdb.jdbc.DuckDBJdbcHelper v;
boolean v;
org.finos.legend.engine.persistence.components.relational.api.RelationalConnection v;
v := @this: org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink;
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.duckdb.jdbc.DuckDBJdbcHelper: org.finos.legend.engine.persistence.components.relational.duckdb.jdbc.DuckDBJdbcHelper 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 DuckDB Sink");
throw v;
}
public org.finos.legend.engine.persistence.components.logicalplan.datasets.Field evolveFieldLength(org.finos.legend.engine.persistence.components.logicalplan.datasets.Field, org.finos.legend.engine.persistence.components.logicalplan.datasets.Field)
{
boolean v, v, v, v;
org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Field v, v, v;
java.util.Optional v, v, v, v, v, v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType v, v, v, v, v, v, v, v, v, v, v, v, v, v;
int v, v, v, v;
java.lang.Object v, v, v, v;
v := @this: org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink;
v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Field;
v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Field;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Field: org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType type()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType: java.util.Optional length()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Field: org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType type()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType: java.util.Optional scale()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Field: org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType type()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType: java.util.Optional length()>();
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v == 0 goto label;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Field: org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType type()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType: java.util.Optional length()>();
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v == 0 goto label;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Field: org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType type()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType: java.util.Optional length()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Field: org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType type()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType: java.util.Optional length()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v < v goto label;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Field: org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType type()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType: java.util.Optional length()>();
goto label;
label:
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Field: org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType type()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType: java.util.Optional length()>();
label:
v = v;
label:
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Field: org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType type()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType: java.util.Optional scale()>();
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v == 0 goto label;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Field: org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType type()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType: java.util.Optional scale()>();
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v == 0 goto label;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Field: org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType type()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType: java.util.Optional scale()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Field: org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType type()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType: java.util.Optional scale()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v < v goto label;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Field: org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType type()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType: java.util.Optional scale()>();
goto label;
label:
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Field: org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType type()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.FieldType: java.util.Optional scale()>();
label:
v = v;
label:
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink: org.finos.legend.engine.persistence.components.logicalplan.datasets.Field createNewField(org.finos.legend.engine.persistence.components.logicalplan.datasets.Field,org.finos.legend.engine.persistence.components.logicalplan.datasets.Field,java.util.Optional,java.util.Optional)>(v, v, v, v);
return v;
}
public org.finos.legend.engine.persistence.components.relational.api.IngestorResult performBulkLoad(org.finos.legend.engine.persistence.components.common.Datasets, org.finos.legend.engine.persistence.components.executor.Executor, org.finos.legend.engine.persistence.components.relational.SqlPlan, java.util.Map, java.util.Map, java.time.Clock)
{
org.finos.legend.engine.persistence.components.relational.api.IngestStatus v;
org.finos.legend.engine.persistence.components.common.StatisticName v, v;
org.finos.legend.engine.persistence.components.common.Datasets v;
java.lang.Integer v;
java.util.Map v, 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.duckdb.DuckDBSink 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.duckdb.DuckDBSink;
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 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.duckdb.DuckDBSink$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.duckdb.DuckDBSink$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.duckdb.DuckDBSink$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.duckdb.DuckDBSink$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.duckdb.DuckDBSink$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 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.duckdb.DuckDBSink v;
java.lang.Object v;
boolean v;
v := @this: org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink;
v := @parameter: org.finos.legend.engine.persistence.components.ingestmode.IngestMode;
v = <org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink: 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, 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.duckdb.sql.visitor.StagedFilesSelectionVisitor v;
org.finos.legend.engine.persistence.components.relational.duckdb.sql.visitor.SchemaDefinitionVisitor v;
org.finos.legend.engine.persistence.components.relational.duckdb.sql.visitor.ParseJsonFunctionVisitor v;
org.finos.legend.engine.persistence.components.relational.duckdb.sql.visitor.StagedFilesFieldValueVisitor v;
org.finos.legend.engine.persistence.components.relational.duckdb.sql.visitor.StagedFilesDatasetVisitor 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.duckdb.sql.visitor.StagedFilesDatasetReferenceVisitor v;
java.util.Set v, v, v, v;
org.finos.legend.engine.persistence.components.relational.duckdb.sql.visitor.CopyVisitor v;
org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink v;
org.finos.legend.engine.persistence.components.relational.duckdb.sql.visitor.SQLUpdateVisitor v;
java.util.List v, v, v, v, v, v, v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.relational.duckdb.sql.visitor.FieldVisitor 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.duckdb.DuckDBSink$1 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 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 = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
<org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink: 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.duckdb.sql.visitor.SchemaDefinitionVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.duckdb.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.duckdb.sql.visitor.FieldVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.duckdb.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.duckdb.sql.visitor.SQLUpdateVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.duckdb.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.duckdb.sql.visitor.ParseJsonFunctionVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.duckdb.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.duckdb.sql.visitor.CopyVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.duckdb.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.duckdb.sql.visitor.StagedFilesDatasetReferenceVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.duckdb.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.duckdb.sql.visitor.StagedFilesDatasetVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.duckdb.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.duckdb.sql.visitor.StagedFilesFieldValueVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.duckdb.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.duckdb.sql.visitor.StagedFilesSelectionVisitor;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.duckdb.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 = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
<org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink: 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.duckdb.DuckDBSink: 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.duckdb.DuckDBSink: java.util.Map EXPLICIT_DATA_TYPE_MAPPING> = v;
v = new org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink: void <init>()>();
<org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink: org.finos.legend.engine.persistence.components.relational.RelationalSink INSTANCE> = v;
v = new org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink$1;
specialinvoke v.<org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink$1: void <init>()>();
<org.finos.legend.engine.persistence.components.relational.duckdb.DuckDBSink: org.finos.legend.engine.persistence.components.ingestmode.IngestModeVisitor IS_INGEST_MODE_SUPPORTED> = v;
return;
}
}