public class org.apache.nifi.processors.standard.ValidateCsv extends org.apache.nifi.processor.AbstractProcessor { private static final java.util.List allowedOperators; private static final java.lang.String routeWholeFlowFile; private static final java.lang.String routeLinesIndividually; public static final org.apache.nifi.components.AllowableValue VALIDATE_WHOLE_FLOWFILE; public static final org.apache.nifi.components.AllowableValue VALIDATE_LINES_INDIVIDUALLY; public static final org.apache.nifi.components.PropertyDescriptor SCHEMA; public static final org.apache.nifi.components.PropertyDescriptor HEADER; public static final org.apache.nifi.components.PropertyDescriptor QUOTE_CHARACTER; public static final org.apache.nifi.components.PropertyDescriptor DELIMITER_CHARACTER; public static final org.apache.nifi.components.PropertyDescriptor END_OF_LINE_CHARACTER; public static final org.apache.nifi.components.PropertyDescriptor VALIDATION_STRATEGY; public static final org.apache.nifi.processor.Relationship REL_VALID; public static final org.apache.nifi.processor.Relationship REL_INVALID; private java.util.List properties; private java.util.Set relationships; public void () { org.apache.nifi.processors.standard.ValidateCsv v; v := @this: org.apache.nifi.processors.standard.ValidateCsv; specialinvoke v.()>(); return; } protected void init(org.apache.nifi.processor.ProcessorInitializationContext) { java.util.Set v; org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; java.util.ArrayList v; java.util.HashSet v; java.util.List v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.processor.ProcessorInitializationContext v; v := @this: org.apache.nifi.processors.standard.ValidateCsv; v := @parameter: org.apache.nifi.processor.ProcessorInitializationContext; v = new java.util.ArrayList; specialinvoke v.()>(); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = staticinvoke (v); v. = v; v = new java.util.HashSet; specialinvoke v.()>(); v = ; interfaceinvoke v.(v); v = ; interfaceinvoke v.(v); v = staticinvoke (v); v. = v; return; } public java.util.Set getRelationships() { java.util.Set v; org.apache.nifi.processors.standard.ValidateCsv v; v := @this: org.apache.nifi.processors.standard.ValidateCsv; v = v.; return v; } protected java.util.List getSupportedPropertyDescriptors() { java.util.List v; org.apache.nifi.processors.standard.ValidateCsv v; v := @this: org.apache.nifi.processors.standard.ValidateCsv; v = v.; return v; } protected java.util.Collection customValidate(org.apache.nifi.components.ValidationContext) { org.apache.nifi.components.ValidationContext v; org.apache.nifi.processors.standard.ValidateCsv v; org.apache.nifi.components.PropertyDescriptor v, v; java.util.ArrayList v; org.apache.nifi.components.PropertyValue v; java.lang.String v, v, v, v; org.apache.nifi.components.ValidationResult v, v; boolean v, v; org.apache.nifi.components.ValidationResult$Builder v, v, v, v, v, v, v, v, v, v; java.util.Collection v; java.lang.Exception v; java.util.List v; v := @this: org.apache.nifi.processors.standard.ValidateCsv; v := @parameter: org.apache.nifi.components.ValidationContext; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.(v); if v == 0 goto label; v = new org.apache.nifi.components.ValidationResult$Builder; specialinvoke v.()>(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.("Expression Language Present"); v = virtualinvoke v.(1); v = virtualinvoke v.(); v = staticinvoke (v); return v; label: specialinvoke v.(v); label: goto label; label: v := @caughtexception; v = new java.util.ArrayList; specialinvoke v.(int)>(1); v = new org.apache.nifi.components.ValidationResult$Builder; specialinvoke v.()>(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Error while parsing the schema: \u0001"); v = virtualinvoke v.(v); v = virtualinvoke v.(); interfaceinvoke v.(v); return v; label: v = specialinvoke v.(v); return v; catch java.lang.Exception from label to label with label; } public org.supercsv.prefs.CsvPreference getPreference(org.apache.nifi.processor.ProcessContext, org.apache.nifi.flowfile.FlowFile) { org.apache.nifi.processors.standard.ValidateCsv v; org.supercsv.prefs.CsvPreference v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v; java.lang.String v, v, v, v, v, v; org.apache.nifi.flowfile.FlowFile v; org.apache.nifi.processor.ProcessContext v; char v, v; org.supercsv.prefs.CsvPreference$Builder v; v := @this: org.apache.nifi.processors.standard.ValidateCsv; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.flowfile.FlowFile; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.("\\n", "\n"); v = virtualinvoke v.("\\r", "\r"); v = virtualinvoke v.("\\t", "\t"); v = new org.supercsv.prefs.CsvPreference$Builder; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(0); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(0); specialinvoke v.(char,int,java.lang.String)>(v, v, v); v = virtualinvoke v.(); return v; } private org.supercsv.cellprocessor.ift.CellProcessor[] parseSchema(java.lang.String) { java.lang.Object[] v; org.apache.nifi.processors.standard.ValidateCsv v; java.util.ArrayList v; org.supercsv.cellprocessor.ift.CellProcessor[] v; int v, v; java.lang.String v, v; v := @this: org.apache.nifi.processors.standard.ValidateCsv; v := @parameter: java.lang.String; v = new java.util.ArrayList; specialinvoke v.()>(); v = v; label: v = virtualinvoke v.(); if v <= 0 goto label; v = specialinvoke v.(v, v); goto label; label: v = interfaceinvoke v.(); v = newarray (org.supercsv.cellprocessor.ift.CellProcessor)[v]; v = interfaceinvoke v.(v); return v; } private java.lang.String setProcessor(java.lang.String, java.util.List) { org.supercsv.cellprocessor.ift.CellProcessor v; org.apache.nifi.processors.standard.ValidateCsv v; java.lang.StringBuffer v; int v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v; char v; java.util.List v; v := @this: org.apache.nifi.processors.standard.ValidateCsv; v := @parameter: java.lang.String; v := @parameter: java.util.List; v = new java.lang.StringBuffer; specialinvoke v.()>(); v = v; v = 0; v = 0; v = 0; label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v == v goto label; v = virtualinvoke v.(v); v = v + 1; if v != 0 goto label; if v != 44 goto label; if v != 1 goto label; v = virtualinvoke v.(1); goto label; label: virtualinvoke v.(v); if v != 40 goto label; v = v + 1; goto label; label: if v != 41 goto label; v = v + 1; label: if v <= 0 goto label; if v != v goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(40); v = v; v = null; v = (int) -1; if v == v goto label; v = v + 1; v = virtualinvoke v.(); v = v - 1; v = virtualinvoke v.(v, v); v = virtualinvoke v.(0, v); label: v = virtualinvoke v.(); v = specialinvoke v.(v, v); interfaceinvoke v.(v); v = virtualinvoke v.(v); return v; } private org.supercsv.cellprocessor.ift.CellProcessor getProcessor(java.lang.String, java.lang.String) { org.supercsv.cellprocessor.constraint.IsIncludedIn v; org.supercsv.cellprocessor.ParseInt v; byte v; org.supercsv.cellprocessor.constraint.LMinMax v; long v, v, v, v; org.supercsv.cellprocessor.ift.CellProcessor v; org.supercsv.cellprocessor.constraint.Strlen v; org.supercsv.cellprocessor.ParseBool v; org.supercsv.cellprocessor.constraint.RequireSubStr v; int[] v, v; org.supercsv.cellprocessor.constraint.NotNull v; org.supercsv.cellprocessor.constraint.Unique v; org.supercsv.cellprocessor.constraint.StrNotNullOrEmpty v; org.supercsv.cellprocessor.constraint.StrRegEx v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.supercsv.cellprocessor.ParseLong v; org.supercsv.cellprocessor.Optional v; org.supercsv.cellprocessor.ParseBigDecimal v; java.lang.String 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.supercsv.cellprocessor.constraint.RequireHashCode v; boolean 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.supercsv.cellprocessor.ParseDate v; org.supercsv.cellprocessor.constraint.UniqueHashCode v; java.lang.String[] v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.ValidateCsv v; org.supercsv.cellprocessor.constraint.ForbidSubStr v; org.supercsv.cellprocessor.constraint.Equals v; org.supercsv.cellprocessor.ParseChar v; double v, v; org.supercsv.cellprocessor.ParseDouble v; org.supercsv.cellprocessor.constraint.StrMinMax v; java.lang.IllegalArgumentException v, v, v, v, v, v, v, v, v, v, v, v, v; org.supercsv.cellprocessor.constraint.DMinMax v; v := @this: org.apache.nifi.processors.standard.ValidateCsv; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = -1; v = virtualinvoke v.(); lookupswitch(v) { case -1832664035: goto label; case -1832641399: goto label; case -1832617759: goto label; case -1832366161: goto label; case -1295482945: goto label; case -991534388: goto label; case -904032956: goto label; case -891983292: goto label; case -840528943: goto label; case -196115388: goto label; case -79160509: goto label; case -79017120: goto label; case 3392903: goto label; case 287081790: goto label; case 579463585: goto label; case 989800581: goto label; case 1017982859: goto label; case 1187814492: goto label; case 1318716512: goto label; case 1509685654: goto label; case 1776986934: goto label; case 1803053238: goto label; case 2129514202: goto label; default: goto label; }; label: v = virtualinvoke v.("optional"); if v == 0 goto label; v = 0; goto label; label: v = virtualinvoke v.("parsedate"); if v == 0 goto label; v = 1; goto label; label: v = virtualinvoke v.("parsedouble"); if v == 0 goto label; v = 2; goto label; label: v = virtualinvoke v.("parsebigdecimal"); if v == 0 goto label; v = 3; goto label; label: v = virtualinvoke v.("parsebool"); if v == 0 goto label; v = 4; goto label; label: v = virtualinvoke v.("parsechar"); if v == 0 goto label; v = 5; goto label; label: v = virtualinvoke v.("parseint"); if v == 0 goto label; v = 6; goto label; label: v = virtualinvoke v.("parselong"); if v == 0 goto label; v = 7; goto label; label: v = virtualinvoke v.("notnull"); if v == 0 goto label; v = 8; goto label; label: v = virtualinvoke v.("strregex"); if v == 0 goto label; v = 9; goto label; label: v = virtualinvoke v.("unique"); if v == 0 goto label; v = 10; goto label; label: v = virtualinvoke v.("uniquehashcode"); if v == 0 goto label; v = 11; goto label; label: v = virtualinvoke v.("strlen"); if v == 0 goto label; v = 12; goto label; label: v = virtualinvoke v.("strminmax"); if v == 0 goto label; v = 13; goto label; label: v = virtualinvoke v.("lminmax"); if v == 0 goto label; v = 14; goto label; label: v = virtualinvoke v.("dminmax"); if v == 0 goto label; v = 15; goto label; label: v = virtualinvoke v.("equals"); if v == 0 goto label; v = 16; goto label; label: v = virtualinvoke v.("forbidsubstr"); if v == 0 goto label; v = 17; goto label; label: v = virtualinvoke v.("requiresubstr"); if v == 0 goto label; v = 18; goto label; label: v = virtualinvoke v.("strnotnullorempty"); if v == 0 goto label; v = 19; goto label; label: v = virtualinvoke v.("requirehashcode"); if v == 0 goto label; v = 20; goto label; label: v = virtualinvoke v.("null"); if v == 0 goto label; v = 21; goto label; label: v = virtualinvoke v.("isincludedin"); if v == 0 goto label; v = 22; label: tableswitch(v) { case 0: goto label; case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; case 6: goto label; case 7: goto label; case 8: goto label; case 9: goto label; case 10: goto label; case 11: goto label; case 12: goto label; case 13: goto label; case 14: goto label; case 15: goto label; case 16: goto label; case 17: goto label; case 18: goto label; case 19: goto label; case 20: goto label; case 21: goto label; case 22: goto label; default: goto label; }; label: v = virtualinvoke v.(40); v = v; v = null; v = (int) -1; if v == v goto label; v = v + 1; v = virtualinvoke v.(); v = v - 1; v = virtualinvoke v.(v, v); v = virtualinvoke v.(0, v); label: v = new org.supercsv.cellprocessor.Optional; v = virtualinvoke v.(); v = specialinvoke v.(v, v); specialinvoke v.(org.supercsv.cellprocessor.ift.CellProcessor)>(v); return v; label: v = new org.supercsv.cellprocessor.ParseDate; v = virtualinvoke v.(); v = v - 1; v = virtualinvoke v.(1, v); specialinvoke v.(java.lang.String)>(v); return v; label: if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("ParseDouble does not expect any argument but has \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.supercsv.cellprocessor.ParseDouble; specialinvoke v.()>(); return v; label: if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("ParseBigDecimal does not expect any argument but has \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.supercsv.cellprocessor.ParseBigDecimal; specialinvoke v.()>(); return v; label: if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("ParseBool does not expect any argument but has \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.supercsv.cellprocessor.ParseBool; specialinvoke v.()>(); return v; label: if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("ParseChar does not expect any argument but has \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.supercsv.cellprocessor.ParseChar; specialinvoke v.()>(); return v; label: if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("ParseInt does not expect any argument but has \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.supercsv.cellprocessor.ParseInt; specialinvoke v.()>(); return v; label: if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("ParseLong does not expect any argument but has \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.supercsv.cellprocessor.ParseLong; specialinvoke v.()>(); return v; label: if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("NotNull does not expect any argument but has \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.supercsv.cellprocessor.constraint.NotNull; specialinvoke v.()>(); return v; label: v = new org.supercsv.cellprocessor.constraint.StrRegEx; v = virtualinvoke v.(); v = v - 1; v = virtualinvoke v.(1, v); specialinvoke v.(java.lang.String)>(v); return v; label: if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unique does not expect any argument but has \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.supercsv.cellprocessor.constraint.Unique; specialinvoke v.()>(); return v; label: if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("UniqueHashCode does not expect any argument but has \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.supercsv.cellprocessor.constraint.UniqueHashCode; specialinvoke v.()>(); return v; label: v = virtualinvoke v.(","); v = lengthof v; v = newarray (int)[v]; v = 0; label: v = lengthof v; if v >= v goto label; v = v[v]; v = staticinvoke (v); v[v] = v; v = v + 1; goto label; label: v = new org.supercsv.cellprocessor.constraint.Strlen; specialinvoke v.(int[])>(v); return v; label: v = virtualinvoke v.(","); v = new org.supercsv.cellprocessor.constraint.StrMinMax; v = v[0]; v = staticinvoke (v); v = v[1]; v = staticinvoke (v); specialinvoke v.(long,long)>(v, v); return v; label: v = virtualinvoke v.(","); v = new org.supercsv.cellprocessor.constraint.LMinMax; v = v[0]; v = staticinvoke (v); v = v[1]; v = staticinvoke (v); specialinvoke v.(long,long)>(v, v); return v; label: v = virtualinvoke v.(","); v = new org.supercsv.cellprocessor.constraint.DMinMax; v = v[0]; v = staticinvoke (v); v = v[1]; v = staticinvoke (v); specialinvoke v.(double,double)>(v, v); return v; label: if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Equals does not expect any argument but has \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.supercsv.cellprocessor.constraint.Equals; specialinvoke v.()>(); return v; label: v = virtualinvoke v.("\"", ""); v = virtualinvoke v.(",[ ]*"); v = new org.supercsv.cellprocessor.constraint.ForbidSubStr; specialinvoke v.(java.lang.String[])>(v); return v; label: v = virtualinvoke v.("\"", ""); v = virtualinvoke v.(",[ ]*"); v = new org.supercsv.cellprocessor.constraint.RequireSubStr; specialinvoke v.(java.lang.String[])>(v); return v; label: if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("StrNotNullOrEmpty does not expect any argument but has \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = new org.supercsv.cellprocessor.constraint.StrNotNullOrEmpty; specialinvoke v.()>(); return v; label: v = virtualinvoke v.(","); v = lengthof v; v = newarray (int)[v]; v = 0; label: v = lengthof v; if v >= v goto label; v = v[v]; v = staticinvoke (v); v[v] = v; v = v + 1; goto label; label: v = new org.supercsv.cellprocessor.constraint.RequireHashCode; specialinvoke v.(int[])>(v); return v; label: if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Null does not expect any argument but has \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: return null; label: v = virtualinvoke v.("\"", ""); v = virtualinvoke v.(",[ ]*"); v = new org.supercsv.cellprocessor.constraint.IsIncludedIn; specialinvoke v.(java.lang.Object[])>(v); return v; label: v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("[\u] is not an allowed method to define a Cell Processor"); specialinvoke v.(java.lang.String)>(v); throw v; } public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) { java.lang.Integer v, v, v; org.apache.nifi.components.AllowableValue v; org.supercsv.cellprocessor.ift.CellProcessor[] v; java.lang.Object[] v, v, v, v; org.apache.nifi.processors.standard.ValidateCsv$1 v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.ProcessSession v; org.apache.nifi.components.PropertyValue v, v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Boolean v, v, v, v; java.lang.Object 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.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.provenance.ProvenanceReporter v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; boolean v, v, v, v; org.apache.nifi.flowfile.FlowFile v, v, v; org.apache.nifi.logging.ComponentLog v; java.util.concurrent.atomic.AtomicReference v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.ValidateCsv v; org.supercsv.prefs.CsvPreference v; org.apache.nifi.processor.ProcessContext v; v := @this: org.apache.nifi.processors.standard.ValidateCsv; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSession; v = interfaceinvoke v.(); if v != null goto label; return; label: v = virtualinvoke v.(v, v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = specialinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = new java.util.concurrent.atomic.AtomicReference; v = staticinvoke (1); specialinvoke v.(java.lang.Object)>(v); v = new java.util.concurrent.atomic.AtomicReference; v = staticinvoke (1); specialinvoke v.(java.lang.Object)>(v); v = new java.util.concurrent.atomic.AtomicReference; v = staticinvoke (1); specialinvoke v.(java.lang.Object)>(v); v = new java.util.concurrent.atomic.AtomicReference; v = staticinvoke (0); specialinvoke v.(java.lang.Object)>(v); v = new java.util.concurrent.atomic.AtomicReference; v = staticinvoke (0); specialinvoke v.(java.lang.Object)>(v); v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.(java.lang.Object)>(null); v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.(java.lang.Object)>(null); v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.(java.lang.Object)>(null); if v != 0 goto label; v = interfaceinvoke v.(v); virtualinvoke v.(v); v = interfaceinvoke v.(v); virtualinvoke v.(v); label: v = new org.apache.nifi.processors.standard.ValidateCsv$1; specialinvoke v.(org.apache.nifi.processors.standard.ValidateCsv,org.supercsv.prefs.CsvPreference,boolean,boolean,java.util.concurrent.atomic.AtomicReference,org.apache.nifi.processor.ProcessSession,java.util.concurrent.atomic.AtomicReference,java.util.concurrent.atomic.AtomicReference,java.util.concurrent.atomic.AtomicReference,org.supercsv.cellprocessor.ift.CellProcessor[],java.util.concurrent.atomic.AtomicReference,java.util.concurrent.atomic.AtomicReference,java.util.concurrent.atomic.AtomicReference,org.apache.nifi.logging.ComponentLog,org.apache.nifi.flowfile.FlowFile,java.util.concurrent.atomic.AtomicReference)>(v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v); interfaceinvoke v.(v, v); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("Successfully validated {} against schema; routing to \'valid\'", v); v = interfaceinvoke v.(); v = ; interfaceinvoke v.(v, v); v = ; interfaceinvoke v.(v, v); goto label; label: v = interfaceinvoke v.(); v = ; interfaceinvoke v.(v, v); v = virtualinvoke v.(); interfaceinvoke v.(v, "validation.error.message", v); v = ; interfaceinvoke v.(v, v); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v[0] = v; interfaceinvoke v.("Successfully validated {} against schema; routing to \'valid\'", v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("All \u line(s) are valid"); interfaceinvoke v.(v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, "count.valid.lines", v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, "count.total.lines", v); v = virtualinvoke v.(); v = ; interfaceinvoke v.(v, v); v = virtualinvoke v.(); interfaceinvoke v.(v); interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - 1; v = staticinvoke (v); virtualinvoke v.(v); v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v[2] = v; interfaceinvoke v.("Successfully validated {}/{} line(s) in {} against schema; routing valid lines to \'valid\' and invalid lines to \'invalid\'", v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u valid line(s)"); interfaceinvoke v.(v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, "count.total.lines", v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, "count.valid.lines", v); v = virtualinvoke v.(); v = ; interfaceinvoke v.(v, v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u invalid line(s)"); interfaceinvoke v.(v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; v = staticinvoke (v); interfaceinvoke v.(v, "count.invalid.lines", v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, "count.total.lines", v); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, "validation.error.message", v); v = virtualinvoke v.(); v = ; interfaceinvoke v.(v, v); interfaceinvoke v.(v); goto label; label: v = newarray (java.lang.Object)[1]; v = virtualinvoke v.(); v[0] = v; interfaceinvoke v.("All lines in {} are invalid; routing to \'invalid\'", v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("All \u line(s) are invalid"); interfaceinvoke v.(v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, "count.invalid.lines", v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, "count.total.lines", v); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, "validation.error.message", v); v = virtualinvoke v.(); v = ; interfaceinvoke v.(v, v); v = virtualinvoke v.(); interfaceinvoke v.(v); interfaceinvoke v.(v); label: return; } private byte[] print(java.lang.String, org.supercsv.prefs.CsvPreference, boolean) { byte[] v; org.apache.nifi.processors.standard.ValidateCsv v; org.supercsv.prefs.CsvPreference v; java.lang.StringBuffer v, v; java.lang.String v, v, v; boolean v; v := @this: org.apache.nifi.processors.standard.ValidateCsv; v := @parameter: java.lang.String; v := @parameter: org.supercsv.prefs.CsvPreference; v := @parameter: boolean; v = new java.lang.StringBuffer; specialinvoke v.()>(); if v != 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); return v; } static void () { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; org.apache.nifi.components.AllowableValue v, v, v, v, v; org.apache.nifi.processor.Relationship v, v; java.lang.String v, v, v; org.apache.nifi.components.PropertyDescriptor$Builder 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.apache.nifi.expression.ExpressionLanguageScope v, v, v, v; java.util.List v, v; org.apache.nifi.components.AllowableValue[] v; java.lang.String[] v, v; org.apache.nifi.components.Validator v, v, v, v, v, v; org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v; v = newarray (java.lang.String)[23]; v[0] = "ParseBigDecimal"; v[1] = "ParseBool"; v[2] = "ParseChar"; v[3] = "ParseDate"; v[4] = "ParseDouble"; v[5] = "ParseInt"; v[6] = "ParseLong"; v[7] = "Optional"; v[8] = "DMinMax"; v[9] = "Equals"; v[10] = "ForbidSubStr"; v[11] = "LMinMax"; v[12] = "NotNull"; v[13] = "Null"; v[14] = "RequireHashCode"; v[15] = "RequireSubStr"; v[16] = "Strlen"; v[17] = "StrMinMax"; v[18] = "StrNotNullOrEmpty"; v[19] = "StrRegEx"; v[20] = "Unique"; v[21] = "UniqueHashCode"; v[22] = "IsIncludedIn"; v = staticinvoke (v); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("FlowFile validation", "FlowFile validation", "As soon as an error is found in the CSV file, the validation will stop and the whole flow file will be routed to the \'invalid\' relationship. This option offers best performances."); = v; v = new org.apache.nifi.components.AllowableValue; specialinvoke v.(java.lang.String,java.lang.String,java.lang.String)>("Line by line validation", "Line by line validation", "In case an error is found, the input CSV file will be split into two FlowFiles: one routed to the \'valid\' relationship containing all the correct lines and one routed to the \'invalid\' relationship containing all the incorrect lines. Take care if choosing this option while using Unique cell processors in schema definition:the first occurrence will be considered valid and the next ones as invalid."); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("validate-csv-schema"); v = virtualinvoke v.("Schema"); v =