public class org.apache.nifi.processors.standard.GetHTTP extends org.apache.nifi.processor.AbstractSessionFactoryProcessor { static final int PERSISTENCE_INTERVAL_MSEC; public static final java.lang.String HEADER_IF_NONE_MATCH; public static final java.lang.String HEADER_IF_MODIFIED_SINCE; public static final java.lang.String HEADER_ACCEPT; public static final java.lang.String HEADER_LAST_MODIFIED; public static final java.lang.String HEADER_ETAG; public static final int NOT_MODIFIED; public static final org.apache.nifi.components.PropertyDescriptor URL; public static final org.apache.nifi.components.PropertyDescriptor FOLLOW_REDIRECTS; public static final org.apache.nifi.components.PropertyDescriptor CONNECTION_TIMEOUT; public static final org.apache.nifi.components.PropertyDescriptor ACCEPT_CONTENT_TYPE; public static final org.apache.nifi.components.PropertyDescriptor DATA_TIMEOUT; public static final org.apache.nifi.components.PropertyDescriptor FILENAME; public static final org.apache.nifi.components.PropertyDescriptor USERNAME; public static final org.apache.nifi.components.PropertyDescriptor PASSWORD; public static final org.apache.nifi.components.PropertyDescriptor USER_AGENT; public static final org.apache.nifi.components.PropertyDescriptor SSL_CONTEXT_SERVICE; public static final java.lang.String DEFAULT_COOKIE_POLICY_STR; public static final java.lang.String STANDARD_COOKIE_POLICY_STR; public static final java.lang.String STRICT_COOKIE_POLICY_STR; public static final java.lang.String NETSCAPE_COOKIE_POLICY_STR; public static final java.lang.String IGNORE_COOKIE_POLICY_STR; public static final org.apache.nifi.components.AllowableValue DEFAULT_COOKIE_POLICY; public static final org.apache.nifi.components.AllowableValue STANDARD_COOKIE_POLICY; public static final org.apache.nifi.components.AllowableValue STRICT_COOKIE_POLICY; public static final org.apache.nifi.components.AllowableValue NETSCAPE_COOKIE_POLICY; public static final org.apache.nifi.components.AllowableValue IGNORE_COOKIE_POLICY; public static final org.apache.nifi.components.PropertyDescriptor REDIRECT_COOKIE_POLICY; public static final org.apache.nifi.processor.Relationship REL_SUCCESS; public static final java.lang.String LAST_MODIFIED_DATE_PATTERN_RFC1123; static final java.lang.String ETAG; static final java.lang.String LAST_MODIFIED; private java.util.Set relationships; private java.util.List properties; private final java.util.List customHeaders; private final java.util.concurrent.atomic.AtomicBoolean clearState; public void () { java.util.concurrent.atomic.AtomicBoolean v; org.apache.nifi.processors.standard.GetHTTP v; java.util.ArrayList v; v := @this: org.apache.nifi.processors.standard.GetHTTP; specialinvoke v.()>(); v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; return; } protected void init(org.apache.nifi.processor.ProcessorInitializationContext) { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.ArrayList v; java.util.HashSet v; org.apache.nifi.processors.standard.GetHTTP v; org.apache.nifi.processor.Relationship v; java.util.Set v; java.util.List v; org.apache.nifi.processor.ProcessorInitializationContext v; v := @this: org.apache.nifi.processors.standard.GetHTTP; v := @parameter: org.apache.nifi.processor.ProcessorInitializationContext; v = new java.util.HashSet; specialinvoke v.()>(); v = ; interfaceinvoke v.(v); v = staticinvoke (v); v. = v; 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 = ; interfaceinvoke v.(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 = ; interfaceinvoke v.(v); v = staticinvoke (v); v. = v; return; } public java.util.Set getRelationships() { java.util.Set v; org.apache.nifi.processors.standard.GetHTTP v; v := @this: org.apache.nifi.processors.standard.GetHTTP; v = v.; return v; } protected java.util.List getSupportedPropertyDescriptors() { org.apache.nifi.processors.standard.GetHTTP v; java.util.List v; v := @this: org.apache.nifi.processors.standard.GetHTTP; v = v.; return v; } public void onPropertyModified(org.apache.nifi.components.PropertyDescriptor, java.lang.String, java.lang.String) { org.apache.nifi.processors.standard.GetHTTP v; java.util.concurrent.atomic.AtomicBoolean v; java.lang.String v, v; org.apache.nifi.components.PropertyDescriptor v; v := @this: org.apache.nifi.processors.standard.GetHTTP; v := @parameter: org.apache.nifi.components.PropertyDescriptor; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = v.; virtualinvoke v.(1); return; } public void onScheduled(org.apache.nifi.processor.ProcessContext) throws java.io.IOException { java.util.concurrent.atomic.AtomicBoolean v; org.apache.nifi.processors.standard.GetHTTP v; org.apache.nifi.components.state.Scope v; java.util.Map v; int v; boolean v, v, v; java.util.Iterator v; org.apache.nifi.components.state.StateManager v; org.apache.nifi.processor.ProcessContext v; java.util.Set v; java.util.List v, v, v; java.lang.Object v, v, v; v := @this: org.apache.nifi.processors.standard.GetHTTP; v := @parameter: org.apache.nifi.processor.ProcessContext; v = v.; v = virtualinvoke v.(0); if v == 0 goto label; v = interfaceinvoke v.(); v = ; interfaceinvoke v.(v); label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(v); if v != 0 goto label; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); goto label; label: return; } protected java.util.Collection customValidate(org.apache.nifi.components.ValidationContext) { org.apache.nifi.components.ValidationContext v; org.apache.nifi.components.PropertyDescriptor v, v; java.util.ArrayList v; org.apache.nifi.components.PropertyValue v, v, v; org.apache.nifi.processors.standard.GetHTTP v; java.lang.String v, v; org.apache.nifi.components.ValidationResult v; boolean v; org.apache.nifi.components.ValidationResult$Builder v, v, v, v; v := @this: org.apache.nifi.processors.standard.GetHTTP; v := @parameter: org.apache.nifi.components.ValidationContext; v = new java.util.ArrayList; specialinvoke v.()>(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.("https"); if v == 0 goto label; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v != null goto label; v = new org.apache.nifi.components.ValidationResult$Builder; specialinvoke v.()>(); v = virtualinvoke v.("URL is set to HTTPS protocol but no SSLContext has been specified"); v = virtualinvoke v.(0); v = virtualinvoke v.("SSL Context"); v = virtualinvoke v.(); interfaceinvoke v.(v); label: staticinvoke (v, v); return v; } protected org.apache.nifi.components.PropertyDescriptor getSupportedDynamicPropertyDescriptor(java.lang.String) { org.apache.nifi.components.Validator v; org.apache.nifi.expression.ExpressionLanguageScope v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.components.PropertyDescriptor$Builder v, v, v, v, v, v; org.apache.nifi.processors.standard.GetHTTP v; java.lang.String v; v := @this: org.apache.nifi.processors.standard.GetHTTP; v := @parameter: java.lang.String; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(0); v = virtualinvoke v.(1); v = virtualinvoke v.(); return v; } public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSessionFactory) throws org.apache.nifi.processor.exception.ProcessException { java.lang.Integer v, v; org.apache.http.config.Registry v; byte v; java.lang.Long v, v, v; org.apache.nifi.components.state.Scope v; org.apache.nifi.controller.ControllerService v; org.apache.nifi.util.StopWatch v; java.lang.Object[] v, v, v, v, v, v; org.apache.http.config.RegistryBuilder v, v, v; long v, v; org.apache.nifi.processor.Relationship v, v; java.io.IOException v, v, v; org.apache.nifi.processor.ProcessSession v; org.apache.http.impl.client.HttpClientBuilder v; org.apache.nifi.flowfile.attributes.CoreAttributes v, v; java.net.URISyntaxException v; org.apache.http.Header v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.http.impl.client.BasicCredentialsProvider v; org.apache.nifi.processors.standard.GetHTTP v; org.apache.http.HttpEntity v; org.apache.nifi.components.state.StateMap v; org.apache.http.client.methods.HttpGet v; int v, v, v, v, v; java.lang.Boolean v; org.apache.nifi.processor.ProcessSessionFactory v; java.lang.Class v; java.lang.Object v, v, v; javax.net.ssl.SSLContext v, v; org.apache.http.client.config.RequestConfig v; org.apache.http.StatusLine v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Exception v; org.apache.http.impl.conn.BasicHttpClientConnectionManager v, v, v; java.lang.Throwable v, v, v; org.apache.nifi.provenance.ProvenanceReporter 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; org.apache.http.auth.AuthScope v; java.net.URI v; org.apache.http.conn.ssl.SSLConnectionSocketFactory v; boolean v, v, v, v, v, v, v, v, v; org.apache.nifi.flowfile.FlowFile v, v, v, v, v; java.util.List v; org.apache.http.client.config.RequestConfig$Builder v; org.apache.nifi.logging.ComponentLog v; org.apache.nifi.processor.exception.ProcessException v, v, v; org.apache.http.client.methods.CloseableHttpResponse v; org.apache.http.conn.socket.PlainConnectionSocketFactory v; org.apache.http.impl.client.CloseableHttpClient v; java.util.Iterator v; org.apache.nifi.processor.ProcessContext v; java.util.concurrent.TimeUnit v, v, v, v; org.apache.http.auth.UsernamePasswordCredentials v; org.apache.nifi.util.Tuple v, v; java.io.InputStream v; v := @this: org.apache.nifi.processors.standard.GetHTTP; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSessionFactory; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == null goto label; v = ; interfaceinvoke v.(v, v); v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("found FlowFile {} in input queue; transferring to success", v); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = v; label: v = new java.net.URI; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(); label: goto label; label: v := @caughtexception; label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(class "Lorg/apache/nifi/ssl/SSLContextService;"); if v != null goto label; v = new org.apache.http.impl.conn.BasicHttpClientConnectionManager; specialinvoke v.()>(); v = v; goto label; label: v = interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = new org.apache.nifi.processor.exception.ProcessException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = new org.apache.http.conn.ssl.SSLConnectionSocketFactory; specialinvoke v.(javax.net.ssl.SSLContext)>(v); v = staticinvoke (); v = virtualinvoke v.("https", v); v = staticinvoke (); v = virtualinvoke v.("http", v); v = virtualinvoke v.(); v = new org.apache.http.impl.conn.BasicHttpClientConnectionManager; specialinvoke v.(org.apache.http.config.Lookup)>(v); v = v; label: v = staticinvoke (); v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = -1; v = virtualinvoke v.(); lookupswitch(v) { case -1190396462: goto label; case -891986231: goto label; case 1309399625: goto label; case 1312628413: goto label; case 1544803905: goto label; default: goto label; }; label: v = virtualinvoke v.("standard"); if v == 0 goto label; v = 0; goto label; label: v = virtualinvoke v.("strict"); if v == 0 goto label; v = 1; goto label; label: v = virtualinvoke v.("netscape"); if v == 0 goto label; v = 2; goto label; label: v = virtualinvoke v.("ignore"); if v == 0 goto label; v = 3; goto label; label: v = virtualinvoke v.("default"); if v == 0 goto label; v = 4; label: tableswitch(v) { case 0: goto label; case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; default: goto label; }; label: virtualinvoke v.("standard"); goto label; label: virtualinvoke v.("standard-strict"); goto label; label: virtualinvoke v.("netscape"); goto label; label: virtualinvoke v.("ignoreCookies"); goto label; label: virtualinvoke v.("default"); label: v = staticinvoke (); virtualinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == null goto label; virtualinvoke v.(v); label: if v == null goto label; v = interfaceinvoke v.(); virtualinvoke v.(v); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = new org.apache.http.impl.client.BasicCredentialsProvider; specialinvoke v.()>(); virtualinvoke v.(v); if v == null goto label; v = ; v = new org.apache.http.auth.UsernamePasswordCredentials; specialinvoke v.(java.lang.String,java.lang.String)>(v, v); interfaceinvoke v.(v, v); label: staticinvoke (v, v, v); v = new org.apache.http.client.methods.HttpGet; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(); virtualinvoke v.(v); label: v = ; v = interfaceinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v) ("LastModified:\u0001"); v = interfaceinvoke v.(v); if v == null goto label; v = staticinvoke (v); v = virtualinvoke v.(); virtualinvoke v.("If-Modified-Since", v); label: v = dynamicinvoke "makeConcatWithConstants" (v) ("ETag:\u0001"); v = interfaceinvoke v.(v); if v == null goto label; v = staticinvoke (v); v = virtualinvoke v.(); virtualinvoke v.("If-None-Match", v); label: goto label; label: v := @caughtexception; v = new org.apache.nifi.processor.exception.ProcessException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == null goto label; virtualinvoke v.("Accept", v); label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(); virtualinvoke v.(v, v); goto label; label: v = virtualinvoke v.(); label: v = new org.apache.nifi.util.StopWatch; specialinvoke v.(boolean)>(1); v = virtualinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 304 goto label; v = newarray (java.lang.Object)[1]; v = staticinvoke (304); v[0] = v; interfaceinvoke v.("content not retrieved because server returned HTTP Status Code {}: Not Modified", v); interfaceinvoke v.(); interfaceinvoke v.(); label: virtualinvoke v.(); label: interfaceinvoke v.(); return; label: v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v >= 300 goto label; if v != 204 goto label; label: v = newarray (java.lang.Object)[3]; v = staticinvoke (v); v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("received status code {}:{} from {}", v); interfaceinvoke v.(); label: virtualinvoke v.(); label: interfaceinvoke v.(); return; label: v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u.remote.source"); v = interfaceinvoke v.(v, v, v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(v, v); v = interfaceinvoke v.("Content-Type"); if v == null goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, v); label: v = interfaceinvoke v.(); virtualinvoke v.(); v = virtualinvoke v.(v); v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(v); interfaceinvoke v.(v, v, v); v = ; interfaceinvoke v.(v, v); v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("Successfully received {} from {} at a rate of {}; transferred to success", v); specialinvoke v.(v, v, v, v, v); interfaceinvoke v.(); label: goto label; label: v := @caughtexception; interfaceinvoke v.(); interfaceinvoke v.(); v = newarray (java.lang.Object)[3]; v[0] = v; v = virtualinvoke v.(); v[1] = v; v[2] = v; interfaceinvoke v.("Failed to retrieve file from {} due to {}; rolling back session", v); v = new org.apache.nifi.processor.exception.ProcessException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v := @caughtexception; interfaceinvoke v.(); interfaceinvoke v.(); v = newarray (java.lang.Object)[2]; v = virtualinvoke v.(); v[0] = v; v[1] = v; interfaceinvoke v.("Failed to process due to {}; rolling back session", v); throw v; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; interfaceinvoke v.("Error closing client, continuing.", v); label: interfaceinvoke v.(); goto label; label: v := @caughtexception; interfaceinvoke v.(); throw v; label: return; catch java.net.URISyntaxException from label to label with label; catch java.lang.Exception from label to label with label; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private void updateStateMap(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession, org.apache.http.HttpResponse, org.apache.nifi.components.state.StateMap, java.lang.String) { org.apache.http.Header v, v; org.apache.nifi.processors.standard.GetHTTP v; byte v, v; org.apache.nifi.components.state.Scope v, v, v; java.util.Map v, v; boolean v, v; org.apache.nifi.components.state.StateMap v, v; java.util.HashMap v; long v, v, v; org.apache.nifi.processor.exception.ProcessException v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.ProcessContext v; java.io.IOException v; org.apache.nifi.processor.ProcessSession v; org.apache.nifi.util.Tuple v, v; org.apache.http.HttpResponse v; java.lang.Object v, v, v, v; v := @this: org.apache.nifi.processors.standard.GetHTTP; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSession; v := @parameter: org.apache.http.HttpResponse; v := @parameter: org.apache.nifi.components.state.StateMap; v := @parameter: java.lang.String; label: v = new java.util.HashMap; specialinvoke v.()>(); v = interfaceinvoke v.(); interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.("Last-Modified"); if v == null goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("LastModified:\u0001"); v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001:\u0001"); interfaceinvoke v.(v, v); label: v = interfaceinvoke v.("ETag"); if v == null goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("ETag:\u0001"); v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001:\u0001"); interfaceinvoke v.(v, v); label: v = ; v = interfaceinvoke v.(v, v, v); label: if v != 0 goto label; v = ; v = interfaceinvoke v.(v); interfaceinvoke v.(); v = interfaceinvoke v.(); interfaceinvoke v.(v); v = 0; if v == null goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("LastModified:\u0001"); v = interfaceinvoke v.(v); v = staticinvoke (v); v = virtualinvoke v.(); v = staticinvoke (v); v = v cmp v; if v >= 0 goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("LastModified:\u0001"); v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001:\u0001"); interfaceinvoke v.(v, v); v = 1; label: if v == null goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("ETag:\u0001"); v = interfaceinvoke v.(v); v = staticinvoke (v); v = virtualinvoke v.(); v = staticinvoke (v); v = v cmp v; if v >= 0 goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("ETag:\u0001"); v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001:\u0001"); interfaceinvoke v.(v, v); v = 1; label: if v == 0 goto label; v = ; v = interfaceinvoke v.(v, v, v); goto label; label: v := @caughtexception; v = new org.apache.nifi.processor.exception.ProcessException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: return; catch java.io.IOException from label to label with label; } protected static org.apache.nifi.util.Tuple parseStateValue(java.lang.String) { org.apache.nifi.util.Tuple v; int v, v; java.lang.String v, v, v; v := @parameter: java.lang.String; v = virtualinvoke v.(":"); v = virtualinvoke v.(0, v); v = v + 1; v = virtualinvoke v.(v); v = new org.apache.nifi.util.Tuple; specialinvoke v.(java.lang.Object,java.lang.Object)>(v, v); return v; } static void () { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.expression.AttributeExpression$ResultType v; org.apache.nifi.components.AllowableValue v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship 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, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.expression.ExpressionLanguageScope v, v; java.util.regex.Pattern v; org.apache.nifi.components.AllowableValue[] v; java.lang.String[] v; org.apache.nifi.components.Validator v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship$Builder v, v, v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("URL"); v = virtualinvoke v.("The URL to pull from"); v = virtualinvoke v.(1); v = ; v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = staticinvoke ("https?\\://.*"); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Follow Redirects"); v = virtualinvoke v.("If we receive a 3xx HTTP Status Code from the server, indicates whether or not we should follow the redirect that the server specifies"); v = virtualinvoke v.("false"); v = newarray (java.lang.String)[2]; v[0] = "true"; v[1] = "false"; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Connection Timeout"); v = virtualinvoke v.("How long to wait when attempting to connect to the remote server before giving up"); v = virtualinvoke v.(1); v = virtualinvoke v.("30 sec"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Accept Content-Type"); v = virtualinvoke v.("If specified, requests will only accept the provided Content-Type"); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Data Timeout"); v = virtualinvoke v.("How long to wait between receiving segments of data from the remote server before giving up and discarding the partial file"); v = virtualinvoke v.(1); v = virtualinvoke v.("30 sec"); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Filename"); v = virtualinvoke v.("The filename to assign to the file when pulled"); v = ; v = virtualinvoke v.(v); v = ; v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(1); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Username"); v = virtualinvoke v.("Username required to access the URL"); v = virtualinvoke v.(0); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); = v; v = new org.apache.nifi.components.PropertyDescriptor$Builder; specialinvoke v.()>(); v = virtualinvoke v.("Password"); v = virtualinvoke v.("Password required to access the URL"); v = virtualinvoke v.(0); v = virtualinvoke v.(1); v =