public class org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest extends java.lang.Object
{
public void <init>()
{
org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest v;
v := @this: org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void testTotalErrorsSmallerThanSampleRowCount()
{
org.finos.legend.engine.persistence.components.relational.api.ErrorCategory v, v;
java.util.HashMap v;
java.util.ArrayList v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
int v;
org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest v;
java.util.stream.Collector v, v;
java.util.LinkedList v, v;
java.util.function.Predicate v, v;
java.util.List v;
java.util.stream.Stream v, v, v, v;
org.finos.legend.engine.persistence.components.util.ValidationCategory v, v, v, v;
java.lang.Object v, v;
v := @this: org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = <org.finos.legend.engine.persistence.components.util.ValidationCategory: org.finos.legend.engine.persistence.components.util.ValidationCategory NULL_VALUE>;
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.util.ValidationCategory: org.finos.legend.engine.persistence.components.util.ValidationCategory TYPE_CONVERSION>;
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.finos.legend.engine.persistence.components.util.ValidationCategory: org.finos.legend.engine.persistence.components.util.ValidationCategory NULL_VALUE>;
v = <org.finos.legend.engine.persistence.components.relational.api.ErrorCategory: org.finos.legend.engine.persistence.components.relational.api.ErrorCategory CHECK_NULL_CONSTRAINT>;
specialinvoke v.<org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest: void populateDataErrors(org.finos.legend.engine.persistence.components.util.ValidationCategory,org.finos.legend.engine.persistence.components.relational.api.ErrorCategory,int,int,java.util.Map,java.util.List)>(v, v, 5, 5, v, v);
v = <org.finos.legend.engine.persistence.components.util.ValidationCategory: org.finos.legend.engine.persistence.components.util.ValidationCategory TYPE_CONVERSION>;
v = <org.finos.legend.engine.persistence.components.relational.api.ErrorCategory: org.finos.legend.engine.persistence.components.relational.api.ErrorCategory TYPE_CONVERSION>;
specialinvoke v.<org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest: void populateDataErrors(org.finos.legend.engine.persistence.components.util.ValidationCategory,org.finos.legend.engine.persistence.components.relational.api.ErrorCategory,int,int,java.util.Map,java.util.List)>(v, v, 5, 5, v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: java.util.List getDataErrorsWithFairDistributionAcrossCategories(int,int,java.util.Map)>(20, 10, v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(10, v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest$lambda_testTotalErrorsSmallerThanSampleRowCount_0__8: java.util.function.Predicate bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(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);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest$lambda_testTotalErrorsSmallerThanSampleRowCount_1__9: java.util.function.Predicate bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(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);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public void testExhaustingOneCategory()
{
org.finos.legend.engine.persistence.components.relational.api.ErrorCategory v, v;
java.util.HashMap v;
java.util.ArrayList v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
int v;
org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest v;
java.util.stream.Collector v, v;
java.util.LinkedList v, v;
java.util.function.Predicate v, v;
java.util.List v;
java.util.stream.Stream v, v, v, v;
org.finos.legend.engine.persistence.components.util.ValidationCategory v, v, v, v;
java.lang.Object v, v;
v := @this: org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = <org.finos.legend.engine.persistence.components.util.ValidationCategory: org.finos.legend.engine.persistence.components.util.ValidationCategory NULL_VALUE>;
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.util.ValidationCategory: org.finos.legend.engine.persistence.components.util.ValidationCategory TYPE_CONVERSION>;
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.finos.legend.engine.persistence.components.util.ValidationCategory: org.finos.legend.engine.persistence.components.util.ValidationCategory NULL_VALUE>;
v = <org.finos.legend.engine.persistence.components.relational.api.ErrorCategory: org.finos.legend.engine.persistence.components.relational.api.ErrorCategory CHECK_NULL_CONSTRAINT>;
specialinvoke v.<org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest: void populateDataErrors(org.finos.legend.engine.persistence.components.util.ValidationCategory,org.finos.legend.engine.persistence.components.relational.api.ErrorCategory,int,int,java.util.Map,java.util.List)>(v, v, 5, 5, v, v);
v = <org.finos.legend.engine.persistence.components.util.ValidationCategory: org.finos.legend.engine.persistence.components.util.ValidationCategory TYPE_CONVERSION>;
v = <org.finos.legend.engine.persistence.components.relational.api.ErrorCategory: org.finos.legend.engine.persistence.components.relational.api.ErrorCategory TYPE_CONVERSION>;
specialinvoke v.<org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest: void populateDataErrors(org.finos.legend.engine.persistence.components.util.ValidationCategory,org.finos.legend.engine.persistence.components.relational.api.ErrorCategory,int,int,java.util.Map,java.util.List)>(v, v, 50, 15, v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: java.util.List getDataErrorsWithFairDistributionAcrossCategories(int,int,java.util.Map)>(20, 55, v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(20, v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest$lambda_testExhaustingOneCategory_2__10: java.util.function.Predicate bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(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);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest$lambda_testExhaustingOneCategory_3__11: java.util.function.Predicate bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(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);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public void testExhaustingBothCategories()
{
org.finos.legend.engine.persistence.components.relational.api.ErrorCategory v, v;
java.util.HashMap v;
java.util.ArrayList v, v;
org.finos.legend.engine.persistence.components.relational.RelationalSink v;
int v;
org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest v;
java.util.stream.Collector v, v;
java.util.LinkedList v, v;
java.util.function.Predicate v, v;
java.util.List v;
java.util.stream.Stream v, v, v, v;
org.finos.legend.engine.persistence.components.util.ValidationCategory v, v, v, v;
java.lang.Object v, v;
v := @this: org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest;
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: org.finos.legend.engine.persistence.components.relational.RelationalSink get()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = <org.finos.legend.engine.persistence.components.util.ValidationCategory: org.finos.legend.engine.persistence.components.util.ValidationCategory NULL_VALUE>;
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = <org.finos.legend.engine.persistence.components.util.ValidationCategory: org.finos.legend.engine.persistence.components.util.ValidationCategory TYPE_CONVERSION>;
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = <org.finos.legend.engine.persistence.components.util.ValidationCategory: org.finos.legend.engine.persistence.components.util.ValidationCategory NULL_VALUE>;
v = <org.finos.legend.engine.persistence.components.relational.api.ErrorCategory: org.finos.legend.engine.persistence.components.relational.api.ErrorCategory CHECK_NULL_CONSTRAINT>;
specialinvoke v.<org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest: void populateDataErrors(org.finos.legend.engine.persistence.components.util.ValidationCategory,org.finos.legend.engine.persistence.components.relational.api.ErrorCategory,int,int,java.util.Map,java.util.List)>(v, v, 15, 10, v, v);
v = <org.finos.legend.engine.persistence.components.util.ValidationCategory: org.finos.legend.engine.persistence.components.util.ValidationCategory TYPE_CONVERSION>;
v = <org.finos.legend.engine.persistence.components.relational.api.ErrorCategory: org.finos.legend.engine.persistence.components.relational.api.ErrorCategory TYPE_CONVERSION>;
specialinvoke v.<org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest: void populateDataErrors(org.finos.legend.engine.persistence.components.util.ValidationCategory,org.finos.legend.engine.persistence.components.relational.api.ErrorCategory,int,int,java.util.Map,java.util.List)>(v, v, 20, 9, v, v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.ansi.AnsiSqlSink: java.util.List getDataErrorsWithFairDistributionAcrossCategories(int,int,java.util.Map)>(19, 35, v);
v = interfaceinvoke v.<java.util.List: int size()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(19, v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest$lambda_testExhaustingBothCategories_4__12: java.util.function.Predicate bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(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);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest$lambda_testExhaustingBothCategories_5__13: java.util.function.Predicate bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(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);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
return;
}
private void populateDataErrors(org.finos.legend.engine.persistence.components.util.ValidationCategory, org.finos.legend.engine.persistence.components.relational.api.ErrorCategory, int, int, java.util.Map, java.util.List)
{
org.finos.legend.engine.persistence.components.relational.api.ErrorCategory v;
java.util.List v;
org.finos.legend.engine.persistence.components.relational.api.DataError v;
org.finos.legend.engine.persistence.components.util.ValidationCategory v;
java.util.Map v;
int v, v, v;
org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest v;
java.lang.Object v;
v := @this: org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest;
v := @parameter: org.finos.legend.engine.persistence.components.util.ValidationCategory;
v := @parameter: org.finos.legend.engine.persistence.components.relational.api.ErrorCategory;
v := @parameter: int;
v := @parameter: int;
v := @parameter: java.util.Map;
v := @parameter: java.util.List;
v = 1;
label:
if v > v goto label;
v = specialinvoke v.<org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest: org.finos.legend.engine.persistence.components.relational.api.DataError getDummyDataError(org.finos.legend.engine.persistence.components.relational.api.ErrorCategory,long)>(v, v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
interfaceinvoke v.<java.util.Queue: boolean add(java.lang.Object)>(v);
if v > v goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = v + 1;
goto label;
label:
return;
}
private org.finos.legend.engine.persistence.components.relational.api.DataError getDummyDataError(org.finos.legend.engine.persistence.components.relational.api.ErrorCategory, long)
{
org.finos.legend.engine.persistence.components.relational.api.ErrorCategory v;
java.util.HashMap v;
long v;
java.lang.Long v;
org.finos.legend.engine.persistence.components.relational.api.DataError v;
org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest v;
org.finos.legend.engine.persistence.components.relational.api.DataError$Builder v, v, v, v, v;
v := @this: org.finos.legend.engine.persistence.components.util.DataErrorFairDistributionTest;
v := @parameter: org.finos.legend.engine.persistence.components.relational.api.ErrorCategory;
v := @parameter: long;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("file", "some_file_name");
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("record_number", v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("column_name", "some_column_name");
v = staticinvoke <org.finos.legend.engine.persistence.components.relational.api.DataError: org.finos.legend.engine.persistence.components.relational.api.DataError$Builder builder()>();
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.DataError$Builder: org.finos.legend.engine.persistence.components.relational.api.DataError$Builder errorCategory(org.finos.legend.engine.persistence.components.relational.api.ErrorCategory)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.DataError$Builder: org.finos.legend.engine.persistence.components.relational.api.DataError$Builder putAllErrorDetails(java.util.Map)>(v);
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.DataError$Builder: org.finos.legend.engine.persistence.components.relational.api.DataError$Builder errorRecord(java.lang.String)>("some_data");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.DataError$Builder: org.finos.legend.engine.persistence.components.relational.api.DataError$Builder errorMessage(java.lang.String)>("some_error_message");
v = virtualinvoke v.<org.finos.legend.engine.persistence.components.relational.api.DataError$Builder: org.finos.legend.engine.persistence.components.relational.api.DataError build()>();
return v;
}
}