public class org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler extends java.lang.Object implements org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenStrategyVisitor
{
private java.util.List fieldsToSelect;
private java.util.List fieldsToInsert;
private java.util.List fieldTypes;
private org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset mainDataset;
public void <init>(org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset, java.util.List, java.util.List, java.util.List)
{
java.util.List v, v, v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v;
org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler;
v := @parameter: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset mainDataset> = v;
v.<org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler: java.util.List fieldsToSelect> = v;
v.<org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler: java.util.List fieldsToInsert> = v;
v.<org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler: java.util.List fieldTypes> = v;
return;
}
public java.lang.Void visitNoDigestGenStrategy(org.finos.legend.engine.persistence.components.ingestmode.digest.NoDigestGenStrategyAbstract)
{
org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler v;
org.finos.legend.engine.persistence.components.ingestmode.digest.NoDigestGenStrategyAbstract v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler;
v := @parameter: org.finos.legend.engine.persistence.components.ingestmode.digest.NoDigestGenStrategyAbstract;
return null;
}
public java.lang.Void visitUDFBasedDigestGenStrategy(org.finos.legend.engine.persistence.components.ingestmode.digest.UDFBasedDigestGenStrategyAbstract)
{
java.lang.IllegalStateException v;
org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf$Builder v, v, v, v, v, v, v;
org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder v, v, v;
java.util.Map v;
java.util.stream.Collector v;
boolean v, v, v, v, v;
java.util.Set v;
java.util.List v, v, v, v, v;
java.util.stream.Stream v, v;
java.util.Optional v;
org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler v;
java.util.ArrayList v, v, v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference v;
int v;
org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset v;
java.lang.String v, v, v, v, v, v;
java.util.Iterator v;
org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue v;
org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf v;
org.finos.legend.engine.persistence.components.logicalplan.values.Value v;
org.finos.legend.engine.persistence.components.ingestmode.digest.UDFBasedDigestGenStrategyAbstract v;
java.lang.Object v, v, v;
java.util.Comparator v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler;
v := @parameter: org.finos.legend.engine.persistence.components.ingestmode.digest.UDFBasedDigestGenStrategyAbstract;
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.digest.UDFBasedDigestGenStrategyAbstract: java.util.Set fieldsToExcludeFromDigest()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v.<org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler: java.util.List fieldsToSelect>;
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler$lambda_visitUDFBasedDigestGenStrategy_0__2: java.util.Comparator bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream sorted(java.util.Comparator)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler: java.util.List fieldsToSelect>;
v = interfaceinvoke v.<java.util.List: int indexOf(java.lang.Object)>(v);
v = v.<org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler: java.util.List fieldTypes>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = v instanceof org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue;
if v == 0 goto label;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue: java.lang.String fieldName()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue: java.lang.String fieldName()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v instanceof org.finos.legend.engine.persistence.components.logicalplan.values.StagedFilesFieldValue;
if v == 0 goto label;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.values.StagedFilesFieldValue: java.lang.String fieldName()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.values.StagedFilesFieldValue: java.lang.String fieldName()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Value can either be a FieldValue or StagedFilesFieldValue for UDF based digest generation");
throw v;
label:
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf: org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf$Builder builder()>();
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.digest.UDFBasedDigestGenStrategyAbstract: java.lang.String digestUdfName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf$Builder: org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf$Builder udfName(java.lang.String)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf$Builder: org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf$Builder addAllFieldNames(java.lang.Iterable)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf$Builder: org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf$Builder addAllValues(java.lang.Iterable)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf$Builder: org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf$Builder addAllFieldTypes(java.lang.Iterable)>(v);
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.digest.UDFBasedDigestGenStrategyAbstract: java.util.Map typeConversionUdfNames()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf$Builder: org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf$Builder putAllTypeConversionUdfNames(java.util.Map)>(v);
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.digest.UDFBasedDigestGenStrategyAbstract: java.util.Optional columnTransformationUdfName()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf$Builder: org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf$Builder columnTransformationUdfName(java.util.Optional)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf$Builder: org.finos.legend.engine.persistence.components.logicalplan.values.DigestUdf build()>();
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.ingestmode.digest.UDFBasedDigestGenStrategyAbstract: java.lang.String digestField()>();
v = v.<org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler: java.util.List fieldsToInsert>;
v = staticinvoke <org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue: org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder builder()>();
v = v.<org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler: org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset mainDataset>;
v = interfaceinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.datasets.Dataset: org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference datasetReference()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder: org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder datasetRef(org.finos.legend.engine.persistence.components.logicalplan.datasets.DatasetReference)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder: org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder fieldName(java.lang.String)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue$Builder: org.finos.legend.engine.persistence.components.logicalplan.values.FieldValue build()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v.<org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler: java.util.List fieldsToSelect>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return null;
}
public java.lang.Void visitUserProvidedDigestGenStrategy(org.finos.legend.engine.persistence.components.ingestmode.digest.UserProvidedDigestGenStrategyAbstract)
{
org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler v;
org.finos.legend.engine.persistence.components.ingestmode.digest.UserProvidedDigestGenStrategyAbstract v;
v := @this: org.finos.legend.engine.persistence.components.ingestmode.digest.DigestGenerationHandler;
v := @parameter: org.finos.legend.engine.persistence.components.ingestmode.digest.UserProvidedDigestGenStrategyAbstract;
return null;
}
}