public class org.apache.nifi.processors.standard.ValidateJson extends org.apache.nifi.processor.AbstractProcessor
{
protected static final java.lang.String ERROR_ATTRIBUTE_KEY;
private static final java.lang.String SCHEMA_NAME_PROPERTY_NAME;
private static final java.lang.String SCHEMA_CONTENT_PROPERTY_NAME;
public static final org.apache.nifi.components.PropertyDescriptor SCHEMA_ACCESS_STRATEGY;
public static final org.apache.nifi.components.PropertyDescriptor SCHEMA_NAME;
public static final org.apache.nifi.components.PropertyDescriptor SCHEMA_REGISTRY;
public static final org.apache.nifi.components.PropertyDescriptor SCHEMA_CONTENT;
public static final org.apache.nifi.components.PropertyDescriptor SCHEMA_VERSION;
private static final java.util.List PROPERTIES;
public static final org.apache.nifi.processor.Relationship REL_VALID;
public static final org.apache.nifi.processor.Relationship REL_INVALID;
public static final org.apache.nifi.processor.Relationship REL_FAILURE;
private static final java.util.Set RELATIONSHIPS;
private static final com.fasterxml.jackson.databind.ObjectMapper MAPPER;
private final java.util.concurrent.ConcurrentMap schemaFactories;
private volatile com.networknt.schema.JsonSchema schema;
private volatile org.apache.nifi.schemaregistry.services.JsonSchemaRegistry jsonSchemaRegistry;
public void <init>()
{
java.util.stream.Stream v;
java.lang.Object v;
org.apache.nifi.processors.standard.ValidateJson v;
java.util.stream.Collector v;
org.apache.nifi.json.schema.SchemaVersion[] v;
java.util.function.Function v, v;
v := @this: org.apache.nifi.processors.standard.ValidateJson;
specialinvoke v.<org.apache.nifi.processor.AbstractProcessor: void <init>()>();
v = staticinvoke <org.apache.nifi.json.schema.SchemaVersion: org.apache.nifi.json.schema.SchemaVersion[] values()>();
v = staticinvoke <java.util.Arrays: java.util.stream.Stream stream(java.lang.Object[])>(v);
v = staticinvoke <java.util.function.Function: java.util.function.Function identity()>();
v = staticinvoke <org.apache.nifi.processors.standard.ValidateJson$lambda_new_0__254: java.util.function.Function bootstrap$()>();
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toConcurrentMap(java.util.function.Function,java.util.function.Function)>(v, v);
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v.<org.apache.nifi.processors.standard.ValidateJson: java.util.concurrent.ConcurrentMap schemaFactories> = v;
return;
}
public java.util.Set getRelationships()
{
java.util.Set v;
org.apache.nifi.processors.standard.ValidateJson v;
v := @this: org.apache.nifi.processors.standard.ValidateJson;
v = <org.apache.nifi.processors.standard.ValidateJson: java.util.Set RELATIONSHIPS>;
return v;
}
public final java.util.List getSupportedPropertyDescriptors()
{
java.util.List v;
org.apache.nifi.processors.standard.ValidateJson v;
v := @this: org.apache.nifi.processors.standard.ValidateJson;
v = <org.apache.nifi.processors.standard.ValidateJson: java.util.List PROPERTIES>;
return v;
}
protected java.util.Collection customValidate(org.apache.nifi.components.ValidationContext)
{
org.apache.nifi.components.ValidationContext v;
org.apache.nifi.processors.standard.ValidateJson v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v;
java.util.ArrayList v;
org.apache.nifi.components.PropertyValue v, v;
java.lang.String v, v, v, v, v;
org.apache.nifi.components.ValidationResult v, v;
boolean v, v, v, v;
org.apache.nifi.components.ValidationResult$Builder v, v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.ValidateJson;
v := @parameter: org.apache.nifi.components.ValidationContext;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.ValidateJson: java.lang.String getSchemaAccessStrategy(org.apache.nifi.context.PropertyContext)>(v);
v = specialinvoke v.<org.apache.nifi.processors.standard.ValidateJson: boolean isNameStrategy(org.apache.nifi.context.PropertyContext)>(v);
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_REGISTRY>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: boolean isSet()>();
if v != 0 goto label;
v = new org.apache.nifi.components.ValidationResult$Builder;
specialinvoke v.<org.apache.nifi.components.ValidationResult$Builder: void <init>()>();
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_REGISTRY>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getDisplayName()>();
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder subject(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_REGISTRY>;
v = specialinvoke v.<org.apache.nifi.processors.standard.ValidateJson: java.lang.String getPropertyValidateMessage(java.lang.String,org.apache.nifi.components.PropertyDescriptor)>(v, v);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder explanation(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder valid(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult build()>();
interfaceinvoke v.<java.util.Collection: boolean add(java.lang.Object)>(v);
goto label;
label:
v = specialinvoke v.<org.apache.nifi.processors.standard.ValidateJson: boolean isContentStrategy(org.apache.nifi.context.PropertyContext)>(v);
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_CONTENT>;
v = interfaceinvoke v.<org.apache.nifi.components.ValidationContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: boolean isSet()>();
if v != 0 goto label;
v = new org.apache.nifi.components.ValidationResult$Builder;
specialinvoke v.<org.apache.nifi.components.ValidationResult$Builder: void <init>()>();
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_CONTENT>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getDisplayName()>();
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder subject(java.lang.String)>(v);
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_CONTENT>;
v = specialinvoke v.<org.apache.nifi.processors.standard.ValidateJson: java.lang.String getPropertyValidateMessage(java.lang.String,org.apache.nifi.components.PropertyDescriptor)>(v, v);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder explanation(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult$Builder valid(boolean)>(0);
v = virtualinvoke v.<org.apache.nifi.components.ValidationResult$Builder: org.apache.nifi.components.ValidationResult build()>();
interfaceinvoke v.<java.util.Collection: boolean add(java.lang.Object)>(v);
label:
return v;
}
public void onScheduled(org.apache.nifi.processor.ProcessContext) throws java.io.IOException
{
java.lang.Throwable v;
org.apache.nifi.processors.standard.ValidateJson v;
org.apache.nifi.components.PropertyDescriptor v, v, v;
java.util.concurrent.ConcurrentMap v;
org.apache.nifi.components.PropertyValue v, v, v;
java.lang.String v;
org.apache.nifi.components.resource.ResourceReference v;
boolean v, v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.controller.ControllerService v;
java.lang.Object v;
com.networknt.schema.JsonSchema v;
org.apache.nifi.json.schema.SchemaVersion v;
java.io.InputStream v;
v := @this: org.apache.nifi.processors.standard.ValidateJson;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v = specialinvoke v.<org.apache.nifi.processors.standard.ValidateJson: boolean isNameStrategy(org.apache.nifi.context.PropertyContext)>(v);
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_REGISTRY>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.controller.ControllerService asControllerService(java.lang.Class)>(class "Lorg/apache/nifi/schemaregistry/services/JsonSchemaRegistry;");
v.<org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.schemaregistry.services.JsonSchemaRegistry jsonSchemaRegistry> = v;
goto label;
label:
v = specialinvoke v.<org.apache.nifi.processors.standard.ValidateJson: boolean isContentStrategy(org.apache.nifi.context.PropertyContext)>(v);
if v == 0 goto label;
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_CONTENT>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.resource.ResourceReference asResource()>();
v = interfaceinvoke v.<org.apache.nifi.components.resource.ResourceReference: java.io.InputStream read()>();
label:
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_VERSION>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = staticinvoke <org.apache.nifi.json.schema.SchemaVersion: org.apache.nifi.json.schema.SchemaVersion valueOf(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.ValidateJson: java.util.concurrent.ConcurrentMap schemaFactories>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<com.networknt.schema.JsonSchemaFactory: com.networknt.schema.JsonSchema getSchema(java.io.InputStream)>(v);
v.<org.apache.nifi.processors.standard.ValidateJson: com.networknt.schema.JsonSchema schema> = v;
label:
if v == null goto label;
virtualinvoke v.<java.io.InputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException
{
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.components.PropertyValue v, v;
com.fasterxml.jackson.databind.JsonNode v;
boolean v, v;
org.apache.nifi.schemaregistry.services.JsonSchemaRegistry v;
org.apache.nifi.flowfile.FlowFile v;
java.util.Set v;
java.lang.Exception v, v;
com.networknt.schema.JsonSchema v, v;
org.apache.nifi.json.schema.JsonSchema v;
java.lang.Throwable v;
java.lang.Object[] v, v, v, v;
org.apache.nifi.processors.standard.ValidateJson v;
org.apache.nifi.logging.ComponentLog v, v, v, v;
java.util.concurrent.ConcurrentMap v;
org.apache.nifi.provenance.ProvenanceReporter v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v;
java.lang.String v, v, v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.nifi.processor.ProcessContext v;
org.apache.nifi.processor.ProcessSession v;
java.lang.Object v;
org.apache.nifi.json.schema.SchemaVersion v;
java.io.InputStream v;
v := @this: org.apache.nifi.processors.standard.ValidateJson;
v := @parameter: org.apache.nifi.processor.ProcessContext;
v := @parameter: org.apache.nifi.processor.ProcessSession;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile get()>();
if v != null goto label;
return;
label:
v = specialinvoke v.<org.apache.nifi.processors.standard.ValidateJson: boolean isNameStrategy(org.apache.nifi.context.PropertyContext)>(v);
if v == 0 goto label;
label:
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_NAME>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: org.apache.nifi.components.PropertyValue evaluateAttributeExpressions(org.apache.nifi.flowfile.FlowFile)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
v = v.<org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.schemaregistry.services.JsonSchemaRegistry jsonSchemaRegistry>;
v = interfaceinvoke v.<org.apache.nifi.schemaregistry.services.JsonSchemaRegistry: org.apache.nifi.json.schema.JsonSchema retrieveSchema(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.ValidateJson: java.util.concurrent.ConcurrentMap schemaFactories>;
v = virtualinvoke v.<org.apache.nifi.json.schema.JsonSchema: org.apache.nifi.json.schema.SchemaVersion getSchemaVersion()>();
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.nifi.json.schema.JsonSchema: java.lang.String getSchemaText()>();
v = virtualinvoke v.<com.networknt.schema.JsonSchemaFactory: com.networknt.schema.JsonSchema getSchema(java.lang.String)>(v);
v.<org.apache.nifi.processors.standard.ValidateJson: com.networknt.schema.JsonSchema schema> = v;
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Could not retrieve JSON schema for {}", v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void route(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
return;
label:
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: java.io.InputStream read(org.apache.nifi.flowfile.FlowFile)>(v);
label:
v = <org.apache.nifi.processors.standard.ValidateJson: com.fasterxml.jackson.databind.ObjectMapper MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode readTree(java.io.InputStream)>(v);
v = v.<org.apache.nifi.processors.standard.ValidateJson: com.networknt.schema.JsonSchema schema>;
v = virtualinvoke v.<com.networknt.schema.JsonSchema: java.util.Set validate(com.fasterxml.jackson.databind.JsonNode)>(v);
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[1];
v[0] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void debug(java.lang.String,java.lang.Object[])>("JSON {} valid", v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.processor.Relationship REL_VALID>;
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void route(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.processor.Relationship REL_VALID>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
goto label;
label:
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile putAttribute(org.apache.nifi.flowfile.FlowFile,java.lang.String,java.lang.String)>(v, "json.validation.errors", v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String,java.lang.Object[])>("JSON {} invalid: Validation Errors {}", v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.processor.Relationship REL_INVALID>;
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void route(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.processor.Relationship REL_INVALID>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
label:
if v == null goto label;
virtualinvoke v.<java.io.InputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.logging.ComponentLog getLogger()>();
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("JSON processing failed {}", v);
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.provenance.ProvenanceReporter getProvenanceReporter()>();
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.provenance.ProvenanceReporter: void route(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(org.apache.nifi.flowfile.FlowFile,org.apache.nifi.processor.Relationship)>(v, v);
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Exception from label to label with label;
}
private java.lang.String getPropertyValidateMessage(java.lang.String, org.apache.nifi.components.PropertyDescriptor)
{
org.apache.nifi.processors.standard.ValidateJson v;
java.lang.String v, v, v;
org.apache.nifi.components.PropertyDescriptor v;
v := @this: org.apache.nifi.processors.standard.ValidateJson;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.components.PropertyDescriptor;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor: java.lang.String getDisplayName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("The \'\u0001\' Schema Access Strategy requires that the \u property be set.");
return v;
}
private boolean isNameStrategy(org.apache.nifi.context.PropertyContext)
{
org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy v;
org.apache.nifi.processors.standard.ValidateJson v;
java.lang.String v, v;
boolean v;
org.apache.nifi.context.PropertyContext v;
v := @this: org.apache.nifi.processors.standard.ValidateJson;
v := @parameter: org.apache.nifi.context.PropertyContext;
v = specialinvoke v.<org.apache.nifi.processors.standard.ValidateJson: java.lang.String getSchemaAccessStrategy(org.apache.nifi.context.PropertyContext)>(v);
v = <org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy: org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy SCHEMA_NAME_PROPERTY>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
return v;
}
private java.lang.String getSchemaAccessStrategy(org.apache.nifi.context.PropertyContext)
{
org.apache.nifi.processors.standard.ValidateJson v;
java.lang.String v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.components.PropertyValue v;
org.apache.nifi.context.PropertyContext v;
v := @this: org.apache.nifi.processors.standard.ValidateJson;
v := @parameter: org.apache.nifi.context.PropertyContext;
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_ACCESS_STRATEGY>;
v = interfaceinvoke v.<org.apache.nifi.context.PropertyContext: org.apache.nifi.components.PropertyValue getProperty(org.apache.nifi.components.PropertyDescriptor)>(v);
v = interfaceinvoke v.<org.apache.nifi.components.PropertyValue: java.lang.String getValue()>();
return v;
}
private boolean isContentStrategy(org.apache.nifi.context.PropertyContext)
{
org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy v;
org.apache.nifi.processors.standard.ValidateJson v;
java.lang.String v, v;
boolean v;
org.apache.nifi.context.PropertyContext v;
v := @this: org.apache.nifi.processors.standard.ValidateJson;
v := @parameter: org.apache.nifi.context.PropertyContext;
v = specialinvoke v.<org.apache.nifi.processors.standard.ValidateJson: java.lang.String getSchemaAccessStrategy(org.apache.nifi.context.PropertyContext)>(v);
v = <org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy: org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy SCHEMA_CONTENT_PROPERTY>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy: java.lang.String getValue()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
return v;
}
static void <clinit>()
{
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v;
java.lang.String v;
org.apache.nifi.components.PropertyDescriptor[] v;
org.apache.nifi.components.resource.ResourceType[] 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;
org.apache.nifi.components.resource.ResourceCardinality v;
org.apache.nifi.components.resource.ResourceType v, v, v;
org.apache.nifi.expression.ExpressionLanguageScope v;
java.util.List v, v;
org.apache.nifi.processor.Relationship[] v;
java.util.HashSet v;
com.fasterxml.jackson.core.JsonParser$Feature v;
org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy v, v, v, v, v;
org.apache.nifi.components.DescribedValue[] v, v, v, v;
org.apache.nifi.components.Validator v, v;
com.fasterxml.jackson.databind.ObjectMapper v, v;
org.apache.nifi.processor.Relationship$Builder v, v, v, v, v, v, v, v, v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Schema Access Strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Schema Access Strategy");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies how to obtain the schema that is to be used for interpreting the data.");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder allowableValues(java.lang.Class)>(class "Lorg/apache/nifi/processors/standard/ValidateJson$JsonSchemaStrategy;");
v = <org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy: org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy SCHEMA_CONTENT_PROPERTY>;
v = virtualinvoke v.<org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy: java.lang.String getValue()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_ACCESS_STRATEGY> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("Schema Name");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("Schema Name");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies the name of the schema to lookup in the Schema Registry property");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_EMPTY_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = <org.apache.nifi.expression.ExpressionLanguageScope: org.apache.nifi.expression.ExpressionLanguageScope FLOWFILE_ATTRIBUTES>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder expressionLanguageSupported(org.apache.nifi.expression.ExpressionLanguageScope)>(v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder defaultValue(java.lang.String)>("${schema.name}");
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_ACCESS_STRATEGY>;
v = <org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy: org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy SCHEMA_NAME_PROPERTY>;
v = newarray (org.apache.nifi.components.DescribedValue)[0];
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dependsOn(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.DescribedValue,org.apache.nifi.components.DescribedValue[])>(v, v, v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_NAME> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("JSON Schema Registry");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("JSON Schema Registry");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("Specifies the Controller Service to use for the JSON Schema Registry");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder identifiesControllerService(java.lang.Class)>(class "Lorg/apache/nifi/schemaregistry/services/JsonSchemaRegistry;");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_ACCESS_STRATEGY>;
v = <org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy: org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy SCHEMA_NAME_PROPERTY>;
v = newarray (org.apache.nifi.components.DescribedValue)[0];
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dependsOn(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.DescribedValue,org.apache.nifi.components.DescribedValue[])>(v, v, v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_REGISTRY> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder name(java.lang.String)>("JSON Schema");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder displayName(java.lang.String)>("JSON Schema");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder description(java.lang.String)>("A URL or file path to the JSON schema or the actual JSON schema content");
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder required(boolean)>(1);
v = <org.apache.nifi.components.resource.ResourceCardinality: org.apache.nifi.components.resource.ResourceCardinality SINGLE>;
v = <org.apache.nifi.components.resource.ResourceType: org.apache.nifi.components.resource.ResourceType FILE>;
v = newarray (org.apache.nifi.components.resource.ResourceType)[2];
v = <org.apache.nifi.components.resource.ResourceType: org.apache.nifi.components.resource.ResourceType URL>;
v[0] = v;
v = <org.apache.nifi.components.resource.ResourceType: org.apache.nifi.components.resource.ResourceType TEXT>;
v[1] = v;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder identifiesExternalResource(org.apache.nifi.components.resource.ResourceCardinality,org.apache.nifi.components.resource.ResourceType,org.apache.nifi.components.resource.ResourceType[])>(v, v, v);
v = <org.apache.nifi.processor.util.StandardValidators: org.apache.nifi.components.Validator NON_BLANK_VALIDATOR>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder addValidator(org.apache.nifi.components.Validator)>(v);
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_ACCESS_STRATEGY>;
v = <org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy: org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy SCHEMA_CONTENT_PROPERTY>;
v = newarray (org.apache.nifi.components.DescribedValue)[0];
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dependsOn(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.DescribedValue,org.apache.nifi.components.DescribedValue[])>(v, v, v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_CONTENT> = v;
v = new org.apache.nifi.components.PropertyDescriptor$Builder;
specialinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: void <init>()>();
v = <org.apache.nifi.schema.access.JsonSchemaRegistryComponent: org.apache.nifi.components.PropertyDescriptor SCHEMA_VERSION>;
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder fromPropertyDescriptor(org.apache.nifi.components.PropertyDescriptor)>(v);
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_ACCESS_STRATEGY>;
v = <org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy: org.apache.nifi.processors.standard.ValidateJson$JsonSchemaStrategy SCHEMA_CONTENT_PROPERTY>;
v = newarray (org.apache.nifi.components.DescribedValue)[0];
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor$Builder dependsOn(org.apache.nifi.components.PropertyDescriptor,org.apache.nifi.components.DescribedValue,org.apache.nifi.components.DescribedValue[])>(v, v, v);
v = virtualinvoke v.<org.apache.nifi.components.PropertyDescriptor$Builder: org.apache.nifi.components.PropertyDescriptor build()>();
<org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_VERSION> = v;
v = newarray (org.apache.nifi.components.PropertyDescriptor)[5];
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_ACCESS_STRATEGY>;
v[0] = v;
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_NAME>;
v[1] = v;
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_REGISTRY>;
v[2] = v;
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_CONTENT>;
v[3] = v;
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.components.PropertyDescriptor SCHEMA_VERSION>;
v[4] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
<org.apache.nifi.processors.standard.ValidateJson: java.util.List PROPERTIES> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("valid");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("FlowFiles that are successfully validated against the schema are routed to this relationship");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.processor.Relationship REL_VALID> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("invalid");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("FlowFiles that are not valid according to the specified schema are routed to this relationship");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.processor.Relationship REL_INVALID> = v;
v = new org.apache.nifi.processor.Relationship$Builder;
specialinvoke v.<org.apache.nifi.processor.Relationship$Builder: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder name(java.lang.String)>("failure");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship$Builder description(java.lang.String)>("FlowFiles that cannot be read as JSON are routed to this relationship");
v = virtualinvoke v.<org.apache.nifi.processor.Relationship$Builder: org.apache.nifi.processor.Relationship build()>();
<org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.processor.Relationship REL_FAILURE> = v;
v = new java.util.HashSet;
v = newarray (org.apache.nifi.processor.Relationship)[3];
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.processor.Relationship REL_VALID>;
v[0] = v;
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.processor.Relationship REL_INVALID>;
v[1] = v;
v = <org.apache.nifi.processors.standard.ValidateJson: org.apache.nifi.processor.Relationship REL_FAILURE>;
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);
<org.apache.nifi.processors.standard.ValidateJson: java.util.Set RELATIONSHIPS> = v;
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = <com.fasterxml.jackson.core.JsonParser$Feature: com.fasterxml.jackson.core.JsonParser$Feature ALLOW_COMMENTS>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.ObjectMapper configure(com.fasterxml.jackson.core.JsonParser$Feature,boolean)>(v, 1);
<org.apache.nifi.processors.standard.ValidateJson: com.fasterxml.jackson.databind.ObjectMapper MAPPER> = v;
return;
}
}