public class org.apache.nifi.processors.standard.TestValidateCsv extends java.lang.Object { public void () { org.apache.nifi.processors.standard.TestValidateCsv v; v := @this: org.apache.nifi.processors.standard.TestValidateCsv; specialinvoke v.()>(); return; } public void testHeaderAndSplit() { org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.components.AllowableValue v; java.util.List v, v, v, v; java.lang.Object v, v, v, v; org.apache.nifi.processors.standard.TestValidateCsv v; v := @this: org.apache.nifi.processors.standard.TestValidateCsv; v = new org.apache.nifi.processors.standard.ValidateCsv; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, ","); v = ; interfaceinvoke v.(v, "\n"); v = ; interfaceinvoke v.(v, "\""); v = ; interfaceinvoke v.(v, "true"); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "Null, ParseDate(\"dd/MM/yyyy\"), Optional(ParseDouble())"); interfaceinvoke v.("Name,Birthdate,Weight\nJohn,22/11/1954,63.2\nBob,01/03/2004,45.0"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("Name,Birthdate,Weight\nJohn,22/11/1954,63.2\nBob,01/03/2004,45.0"); v = ; interfaceinvoke v.(v, 0); interfaceinvoke v.(); interfaceinvoke v.("Name,Birthdate,Weight\nJohn,22/11/1954,63a2\nBob,01/032004,45.0"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("Name,Birthdate,Weight\nJohn,22/11/1954,63a2\nBob,01/032004,45.0"); interfaceinvoke v.(); interfaceinvoke v.("Name,Birthdate,Weight\nJohn,22/111954,63.2\nBob,01/03/2004,45.0"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("Name,Birthdate,Weight\nBob,01/03/2004,45.0"); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("Name,Birthdate,Weight\nJohn,22/111954,63.2"); return; } public void testNullValues() { org.apache.nifi.components.AllowableValue v; org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; java.util.List v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; java.lang.Object v; org.apache.nifi.processors.standard.TestValidateCsv v; v := @this: org.apache.nifi.processors.standard.TestValidateCsv; v = new org.apache.nifi.processors.standard.ValidateCsv; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, ","); v = ; interfaceinvoke v.(v, "\n"); v = ; interfaceinvoke v.(v, "\""); v = ; interfaceinvoke v.(v, "true"); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "Null, Null, Null"); interfaceinvoke v.("#Name,Birthdate,Weight\nJohn,\"\",63.2\nBob,,45.0"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("#Name,Birthdate,Weight\nJohn,\"\",63.2\nBob,,45.0"); v = ; interfaceinvoke v.(v, 0); return; } public void testUniqueWithSplit() { org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.components.AllowableValue v; java.util.List v, v, v, v, v, v; java.lang.Object v, v, v, v, v, v; org.apache.nifi.processors.standard.TestValidateCsv v; v := @this: org.apache.nifi.processors.standard.TestValidateCsv; v = new org.apache.nifi.processors.standard.ValidateCsv; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, ","); v = ; interfaceinvoke v.(v, "\r\n"); v = ; interfaceinvoke v.(v, "\""); v = ; interfaceinvoke v.(v, "false"); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "Unique()"); interfaceinvoke v.("John\r\nBob\r\nBob\r\nJohn\r\nTom"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("John\r\nBob\r\nTom"); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("count.total.lines", "5"); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("count.valid.lines", "3"); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("Bob\r\nJohn"); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("count.invalid.lines", "2"); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("count.total.lines", "5"); return; } public void testValidDateOptionalDouble() { org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; java.util.List v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; java.lang.Object v; org.apache.nifi.processors.standard.TestValidateCsv v; v := @this: org.apache.nifi.processors.standard.TestValidateCsv; v = new org.apache.nifi.processors.standard.ValidateCsv; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, ","); v = ; interfaceinvoke v.(v, "\r\n"); v = ; interfaceinvoke v.(v, "\""); v = ; interfaceinvoke v.(v, "false"); v = ; interfaceinvoke v.(v, "true"); v = ; interfaceinvoke v.(v, "Null, ParseDate(\"dd/MM/yyyy\"), Optional(ParseDouble())"); interfaceinvoke v.("John,22/11/1954,63.2\r\nBob,01/03/2004,45.0"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); interfaceinvoke v.("John,22/111954,abc\r\nBob,01/03/2004,45.0"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("validation.error.message", "At {line=1, row=1}, \'22/111954\' could not be parsed as a Date at {column=2}, \'abc\' could not be parsed as a Double at {column=3}"); return; } public void testIsIncludedIn() { org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestValidateCsv v; v := @this: org.apache.nifi.processors.standard.TestValidateCsv; v = new org.apache.nifi.processors.standard.ValidateCsv; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, ","); v = ; interfaceinvoke v.(v, "\r\n"); v = ; interfaceinvoke v.(v, "\""); v = ; interfaceinvoke v.(v, "false"); v = ; interfaceinvoke v.(v, "Null, ParseDate(\"dd/MM/yyyy\"), IsIncludedIn(\"male\", \"female\")"); interfaceinvoke v.("John,22/11/1954,male\r\nMarie,01/03/2004,female"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); interfaceinvoke v.("John,22/111954,63.2\r\nBob,01/03/2004,45.0"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); return; } public void testBigDecimalBoolCharIntLong() { org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestValidateCsv v; v := @this: org.apache.nifi.processors.standard.TestValidateCsv; v = new org.apache.nifi.processors.standard.ValidateCsv; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, ","); v = ; interfaceinvoke v.(v, "\r\n"); v = ; interfaceinvoke v.(v, "\""); v = ; interfaceinvoke v.(v, "true"); v = ; interfaceinvoke v.(v, "ParseBigDecimal(), ParseBool(), ParseChar(), ParseInt(), ParseLong()"); interfaceinvoke v.("bigdecimal,bool,char,integer,long\r\n.0001,true,c,1,92147483647"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); interfaceinvoke v.("bigdecimal,bool,char,integer,long\r\n.0001,true,c,92147483647,92147483647"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); return; } public void testEqualsNotNullStrNotNullOrEmpty() { org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestValidateCsv v; v := @this: org.apache.nifi.processors.standard.TestValidateCsv; v = new org.apache.nifi.processors.standard.ValidateCsv; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, ","); v = ; interfaceinvoke v.(v, "\r\n"); v = ; interfaceinvoke v.(v, "\""); v = ; interfaceinvoke v.(v, "false"); v = ; interfaceinvoke v.(v, "Equals(), NotNull(), StrNotNullOrEmpty()"); interfaceinvoke v.("test,test,test\r\ntest,test,test"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); interfaceinvoke v.("test,test,test\r\ntset,test,test"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); return; } public void testStrlenStrMinMaxStrRegex() { org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; java.util.List v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v; java.lang.Object v; org.apache.nifi.processors.standard.TestValidateCsv v; v := @this: org.apache.nifi.processors.standard.TestValidateCsv; v = new org.apache.nifi.processors.standard.ValidateCsv; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, ","); v = ; interfaceinvoke v.(v, "\r\n"); v = ; interfaceinvoke v.(v, "\""); v = ; interfaceinvoke v.(v, "false"); v = ; interfaceinvoke v.(v, "Strlen(4), StrMinMax(3,5), StrRegex(\"[a-z0-9\\._]+@[a-z0-9\\.]+\")"); interfaceinvoke v.("test,test,test@apache.org"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); interfaceinvoke v.("test,test,testapache.org"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("validation.error.message", "\'testapache.org\' does not match the regular expression \'[a-z0-9\\._]+@[a-z0-9\\.]+\' at {line=1, row=1, column=3}"); return; } public void testDMinMaxForbidSubStrLMinMax() { org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestValidateCsv v; v := @this: org.apache.nifi.processors.standard.TestValidateCsv; v = new org.apache.nifi.processors.standard.ValidateCsv; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, ","); v = ; interfaceinvoke v.(v, "\r\n"); v = ; interfaceinvoke v.(v, "\""); v = ; interfaceinvoke v.(v, "false"); v = ; interfaceinvoke v.(v, "DMinMax(10,100),LMinMax(10,100),ForbidSubStr(\"test\", \"tset\")"); interfaceinvoke v.("50.001,50,hello"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); interfaceinvoke v.("10,10,testapache.org"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); return; } public void testUnique() { org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestValidateCsv v; v := @this: org.apache.nifi.processors.standard.TestValidateCsv; v = new org.apache.nifi.processors.standard.ValidateCsv; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, ","); v = ; interfaceinvoke v.(v, "\r\n"); v = ; interfaceinvoke v.(v, "\""); v = ; interfaceinvoke v.(v, "false"); v = ; interfaceinvoke v.(v, "Unique(), UniqueHashCode()"); interfaceinvoke v.("1,2\r\n,4"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); interfaceinvoke v.("1,2\r\n,4"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); return; } public void testRequire() { org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; int v; java.lang.String v, v; org.apache.nifi.processors.standard.TestValidateCsv v; v := @this: org.apache.nifi.processors.standard.TestValidateCsv; v = new org.apache.nifi.processors.standard.ValidateCsv; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, ","); v = ; interfaceinvoke v.(v, "\r\n"); v = ; interfaceinvoke v.(v, "\""); v = ; interfaceinvoke v.(v, "false"); v = "test"; v = virtualinvoke v.(); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("RequireHashCode(\u), RequireSubStr(\"test\")"); interfaceinvoke v.(v, v); interfaceinvoke v.("test,test"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); interfaceinvoke v.("tset,tset"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); return; } public void testValidate() { org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestValidateCsv v; v := @this: org.apache.nifi.processors.standard.TestValidateCsv; v = new org.apache.nifi.processors.standard.ValidateCsv; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, ","); v = ; interfaceinvoke v.(v, "\r\n"); v = ; interfaceinvoke v.(v, "\""); v = ; interfaceinvoke v.(v, "false"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, "RequireSubString(\"test\")"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, "\'\'"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, "\"\""); interfaceinvoke v.(); return; } public void testValidateWithEL() { org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v; int v; java.lang.String v, v; org.apache.nifi.processors.standard.TestValidateCsv v; v := @this: org.apache.nifi.processors.standard.TestValidateCsv; v = new org.apache.nifi.processors.standard.ValidateCsv; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "${comma}"); v = ; interfaceinvoke v.(v, "${crlf}"); v = ; interfaceinvoke v.(v, "${quote}"); v = ; interfaceinvoke v.(v, "false"); v = ; interfaceinvoke v.(v, "RequireSubString(\"test\")"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, "\'\'"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, "\"\""); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, "${schema}"); interfaceinvoke v.(); v = "test"; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("RequireHashCode(\u), RequireSubStr(\"test\")"); interfaceinvoke v.("schema", v); interfaceinvoke v.("comma", ","); interfaceinvoke v.("quote", "\""); interfaceinvoke v.("crlf", "\r\n"); interfaceinvoke v.("test,test"); interfaceinvoke v.(); v = ; interfaceinvoke v.(v, 1); return; } public void testParseSchemaCommaBoundary() { org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processors.standard.TestValidateCsv v; v := @this: org.apache.nifi.processors.standard.TestValidateCsv; v = new org.apache.nifi.processors.standard.ValidateCsv; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, "Null(),Null"); interfaceinvoke v.(); return; } public void testMultipleRuns() { org.apache.nifi.components.AllowableValue v; org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.processors.standard.TestValidateCsv v; v := @this: org.apache.nifi.processors.standard.TestValidateCsv; v = new org.apache.nifi.processors.standard.ValidateCsv; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, ","); v = ; interfaceinvoke v.(v, "\r\n"); v = ; interfaceinvoke v.(v, "\""); v = ; interfaceinvoke v.(v, "false"); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "Unique()"); interfaceinvoke v.("John\r\nBob\r\nTom"); interfaceinvoke v.("John\r\nBob\r\nTom"); interfaceinvoke v.(2); v = ; interfaceinvoke v.(v, 2); v = ; interfaceinvoke v.(v, 0); return; } public void testEscapingLineByLine() { org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v; org.apache.nifi.util.TestRunner v; org.apache.nifi.components.AllowableValue v; java.util.List v, v; java.lang.Object v, v; org.apache.nifi.processors.standard.TestValidateCsv v; v := @this: org.apache.nifi.processors.standard.TestValidateCsv; v = new org.apache.nifi.processors.standard.ValidateCsv; specialinvoke v.()>(); v = staticinvoke (v); v = ; interfaceinvoke v.(v, ","); v = ; interfaceinvoke v.(v, "\r\n"); v = ; interfaceinvoke v.(v, "\""); v = ; interfaceinvoke v.(v, "true"); v = ; v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, "ParseInt(),ParseInt(),ParseInt()"); interfaceinvoke v.("Header,\"Header,escaped\",Header3\r\nField,\"Field,escaped\",Field3"); interfaceinvoke v.(1); v = ; interfaceinvoke v.(v, 0); v = ; interfaceinvoke v.(v, 1); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.