public class WEB-INF.classes.org.apache.nifi.web.api.FlowResource extends org.apache.nifi.web.api.ApplicationResource { private static final java.lang.String NIFI_REGISTRY_TYPE; private static final java.lang.String RECURSIVE; private static final java.lang.String VERSIONED_REPORTING_TASK_SNAPSHOT_FILENAME_PATTERN; private static final java.lang.String VERSIONED_REPORTING_TASK_SNAPSHOT_DATE_FORMAT; private org.apache.nifi.web.NiFiServiceFacade serviceFacade; private org.apache.nifi.authorization.Authorizer authorizer; private org.apache.nifi.web.api.ProcessorResource processorResource; private org.apache.nifi.web.api.InputPortResource inputPortResource; private org.apache.nifi.web.api.OutputPortResource outputPortResource; private org.apache.nifi.web.api.FunnelResource funnelResource; private org.apache.nifi.web.api.LabelResource labelResource; private org.apache.nifi.web.api.RemoteProcessGroupResource remoteProcessGroupResource; private org.apache.nifi.web.api.ConnectionResource connectionResource; private org.apache.nifi.web.api.TemplateResource templateResource; private org.apache.nifi.web.api.ProcessGroupResource processGroupResource; private org.apache.nifi.web.api.ControllerServiceResource controllerServiceResource; private org.apache.nifi.web.api.ReportingTaskResource reportingTaskResource; private org.apache.nifi.web.api.ParameterProviderResource parameterProviderResource; public void () { WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; specialinvoke v.()>(); return; } private void populateRemainingFlowContent(org.apache.nifi.web.api.dto.flow.ProcessGroupFlowDTO) { WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.lang.String[] v; java.lang.String v, v; org.apache.nifi.web.api.dto.flow.ProcessGroupFlowDTO v; org.apache.nifi.web.api.dto.flow.FlowDTO v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.dto.flow.ProcessGroupFlowDTO; v = virtualinvoke v.(); if v == null goto label; specialinvoke v.(v); label: v = newarray (java.lang.String)[3]; v[0] = "flow"; v[1] = "process-groups"; v = virtualinvoke v.(); v[2] = v; v = virtualinvoke v.(v); virtualinvoke v.(v); return; } private void populateRemainingFlowStructure(org.apache.nifi.web.api.dto.flow.FlowDTO) { org.apache.nifi.web.api.OutputPortResource v; org.apache.nifi.web.api.dto.ProcessGroupDTO v; org.apache.nifi.web.api.FunnelResource v; org.apache.nifi.web.api.LabelResource v; org.apache.nifi.web.api.InputPortResource v; org.apache.nifi.web.api.dto.flow.FlowDTO v; boolean v; java.util.Iterator v; org.apache.nifi.web.api.ProcessorResource v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v, v, v, v, v, v, v, v, v; org.apache.nifi.web.api.RemoteProcessGroupResource v; org.apache.nifi.web.api.ConnectionResource v; java.lang.Object v; org.apache.nifi.web.api.ProcessGroupResource v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.dto.flow.FlowDTO; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == null goto label; virtualinvoke v.(null); goto label; label: return; } private void authorizeFlow() { org.apache.nifi.authorization.AuthorizeAccess v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; org.apache.nifi.web.NiFiServiceFacade v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v = v.; v = staticinvoke (v); interfaceinvoke v.(v); return; } public javax.ws.rs.core.Response generateClientId() { javax.ws.rs.core.Response v; javax.ws.rs.core.Response$ResponseBuilder v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.lang.String v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getFlowConfig() { org.apache.nifi.web.api.entity.FlowConfigurationEntity v; org.apache.nifi.web.NiFiServiceFacade v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getCurrentUser() { java.lang.Throwable v; org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; javax.ws.rs.core.Response v, v; org.apache.nifi.authorization.user.NiFiUser v; javax.ws.rs.core.Response$ResponseBuilder v; javax.ws.rs.WebApplicationException v; org.apache.nifi.web.api.entity.CurrentUserEntity v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = staticinvoke (); if v != null goto label; v = new javax.ws.rs.WebApplicationException; v = new java.lang.Throwable; specialinvoke v.(java.lang.String)>("Unable to access details for current user."); specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getFlow(java.lang.String, boolean) { org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; org.apache.nifi.web.api.entity.ProcessGroupFlowEntity v; java.lang.String v; org.apache.nifi.web.api.dto.flow.ProcessGroupFlowDTO v; boolean v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; v := @parameter: boolean; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = v.; v = interfaceinvoke v.(v, v); v = virtualinvoke v.(); specialinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getFlowMetrics(java.lang.String, java.util.Set, java.lang.String, java.lang.String, java.lang.String) { javax.ws.rs.core.MediaType v; org.apache.nifi.web.ResourceNotFoundException v; java.lang.String v, v, v, v, v, v; boolean v, v; org.apache.nifi.web.NiFiServiceFacade v; java.util.Collection v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v, v; javax.ws.rs.core.StreamingOutput v, v; org.apache.nifi.web.api.request.FlowMetricsProducer v, v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v, v, v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; v := @parameter: java.util.Set; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(); if v != null goto label; v = staticinvoke (); goto label; label: v = v; label: v = v.; v = interfaceinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = staticinvoke (v, v, v); v = virtualinvoke v.(v); v = virtualinvoke v.("text/plain; version=0.0.4; charset=utf-8"); v = virtualinvoke v.(); return v; label: v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = staticinvoke (v, v, v, v); v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; label: v = new org.apache.nifi.web.ResourceNotFoundException; specialinvoke v.(java.lang.String)>("The specified producer is missing or invalid."); throw v; } public javax.ws.rs.core.Response getControllerServicesFromController(boolean, boolean) { org.apache.nifi.web.NiFiServiceFacade v; java.util.Date v; org.apache.nifi.web.api.ControllerServiceResource v; org.apache.nifi.web.api.entity.ControllerServicesEntity v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; java.util.function.Consumer v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; boolean v, v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: boolean; v := @parameter: boolean; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = v.; v = interfaceinvoke v.(null, 0, 0, v); if v == 0 goto label; v = staticinvoke (v); interfaceinvoke v.(v); label: v = v.; virtualinvoke v.(v); v = new org.apache.nifi.web.api.entity.ControllerServicesEntity; specialinvoke v.()>(); v = new java.util.Date; specialinvoke v.()>(); virtualinvoke v.(v); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getControllerServicesFromGroup(java.lang.String, boolean, boolean, boolean, boolean) { java.util.Date v; org.apache.nifi.web.api.ControllerServiceResource v; java.lang.String v; boolean v, v, v, v, v; org.apache.nifi.web.NiFiServiceFacade v; org.apache.nifi.web.api.entity.ControllerServicesEntity v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; java.util.function.Consumer v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = v.; v = interfaceinvoke v.(v, v, v, v); if v == 0 goto label; v = staticinvoke (v); interfaceinvoke v.(v); label: v = v.; virtualinvoke v.(v); v = new org.apache.nifi.web.api.entity.ControllerServicesEntity; specialinvoke v.()>(); v = new java.util.Date; specialinvoke v.()>(); virtualinvoke v.(v); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getParameterProviders() { org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; org.apache.nifi.web.api.ParameterProviderResource v; org.apache.nifi.web.api.entity.ParameterProvidersEntity v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = v.; v = interfaceinvoke v.(); v = v.; virtualinvoke v.(v); v = new org.apache.nifi.web.api.entity.ParameterProvidersEntity; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getReportingTasks() { org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; boolean v; org.apache.nifi.web.api.ReportingTaskResource v; org.apache.nifi.web.api.entity.ReportingTasksEntity v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = v.; v = interfaceinvoke v.(); v = v.; virtualinvoke v.(v); v = new org.apache.nifi.web.api.entity.ReportingTasksEntity; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getReportingTaskSnapshot(java.lang.String) { org.apache.nifi.web.NiFiServiceFacade v, v; org.apache.nifi.flow.VersionedReportingTaskSnapshot v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; java.lang.String v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: if v != null goto label; v = v.; v = interfaceinvoke v.(); goto label; label: v = v.; v = interfaceinvoke v.(v); label: v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response downloadReportingTaskSnapshot(java.lang.String) { java.lang.Object[] v, v; java.util.Date v; java.text.SimpleDateFormat v; java.lang.String v, v, v, v; boolean v; org.apache.nifi.web.NiFiServiceFacade v, v; org.apache.nifi.flow.VersionedReportingTaskSnapshot v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: if v != null goto label; v = v.; v = interfaceinvoke v.(); goto label; label: v = v.; v = interfaceinvoke v.(v); label: v = new java.text.SimpleDateFormat; specialinvoke v.(java.lang.String)>("yyyyMMddHHmmss"); v = newarray (java.lang.Object)[1]; v = new java.util.Date; specialinvoke v.()>(); v = virtualinvoke v.(v); v[0] = v; v = staticinvoke ("VersionedReportingTaskSnapshot-%s.json", v); v = virtualinvoke v.(v); v = newarray (java.lang.Object)[1]; v[0] = v; v = staticinvoke ("attachment; filename=\"%s\"", v); v = virtualinvoke v.("Content-Disposition", v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response scheduleComponents(javax.servlet.http.HttpServletRequest, java.lang.String, org.apache.nifi.web.api.entity.ScheduleComponentsEntity) { org.apache.nifi.authorization.AuthorizeAccess v; java.util.Map v, v; java.util.stream.Collector v; java.util.Set v, v; java.util.stream.Stream v, v, v; org.apache.nifi.controller.ScheduledState v, v, v, v, v, v, v, v, v; java.lang.Object[] v, v, v, v, v, v, v; java.util.function.Supplier v, v; javax.servlet.http.HttpServletRequest v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.web.NiFiServiceFacade v, v; org.apache.nifi.web.api.entity.ScheduleComponentsEntity v; java.util.function.BiFunction v; java.lang.Runnable v; boolean v, v, v, v, v, v; java.util.Collection v; javax.ws.rs.core.Response v, v; java.util.HashMap v; java.util.function.Function v, v, v; java.util.HashSet v; java.lang.Boolean v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.lang.IllegalArgumentException v, v, v, v, v, v; java.util.function.Consumer v; java.lang.Object v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: javax.servlet.http.HttpServletRequest; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.web.api.entity.ScheduleComponentsEntity; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Schedule Component must be specified."); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = newarray (java.lang.Object)[2]; v = virtualinvoke v.(); v[0] = v; v[1] = v; v = staticinvoke ("The process group id (%s) in the request body does not equal the process group id of the requested resource (%s).", v); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("The scheduled state must be specified."); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.("ENABLED"); if v == 0 goto label; v = ; goto label; label: v = virtualinvoke v.(); v = staticinvoke (v); label: goto label; label: v := @caughtexception; v = new java.lang.IllegalArgumentException; v = newarray (java.lang.Object)[1]; v = newarray (java.lang.Object)[2]; v = newarray (java.io.Serializable)[4]; v = ; v[0] = v; v = ; v[1] = v; v[2] = "ENABLED"; v = ; v[3] = v; v = staticinvoke (v); v[0] = v; v[1] = ", "; v = staticinvoke (v); v[0] = v; v = staticinvoke ("The scheduled must be one of [%s].", v); specialinvoke v.(java.lang.String)>(v); throw v; label: v = ; v = virtualinvoke v.(v); if v != 0 goto label; v = ; v = virtualinvoke v.(v); if v == 0 goto label; label: v = new java.lang.IllegalArgumentException; v = newarray (java.lang.Object)[1]; v = newarray (java.lang.Object)[2]; v = newarray (java.io.Serializable)[4]; v = ; v[0] = v; v = ; v[1] = v; v[2] = "ENABLED"; v = ; v[3] = v; v = staticinvoke (v); v[0] = v; v[1] = ", "; v = staticinvoke (v); v[0] = v; v = staticinvoke ("The scheduled must be one of [%s].", v); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v != null goto label; v = staticinvoke (v, v); v = staticinvoke (v, v); v = v.; v = staticinvoke (v, v, v); v = interfaceinvoke v.(v, v); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (v); interfaceinvoke v.(v); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("PUT", v); return v; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = staticinvoke (v); v = staticinvoke (v, v); v = interfaceinvoke v.(v); v = new java.util.HashSet; v = interfaceinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = v.; v = staticinvoke (v, v); v = staticinvoke (v, v, v, v, v); v = staticinvoke (v, v); v = virtualinvoke v.(v, v, v, v, v, v); return v; catch java.lang.IllegalArgumentException from label to label with label; } public javax.ws.rs.core.Response activateControllerServices(javax.servlet.http.HttpServletRequest, java.lang.String, org.apache.nifi.web.api.entity.ActivateControllerServicesEntity) { java.util.function.BiFunction v; java.lang.Runnable v; org.apache.nifi.authorization.AuthorizeAccess v; org.apache.nifi.web.api.entity.ActivateControllerServicesEntity v; java.util.Map v, v; java.util.stream.Collector v; java.util.EnumSet v, v; boolean v, v, v, v, v; java.util.Collection v; java.util.Set v, v; java.util.stream.Stream v; javax.ws.rs.core.Response v, v; org.apache.nifi.controller.service.ControllerServiceState v, v, v, v, v, v, v; java.lang.Object[] v, v, v; java.util.HashMap v; java.util.function.Function v, v, v; java.util.HashSet v; javax.servlet.http.HttpServletRequest v; java.lang.Boolean v; java.lang.String v, v, v, v, v, v, v, v, v, v; org.apache.nifi.web.NiFiServiceFacade v, v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.lang.IllegalArgumentException v, v, v, v, v, v; java.util.function.Consumer v; java.lang.Object v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: javax.servlet.http.HttpServletRequest; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.web.api.entity.ActivateControllerServicesEntity; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Controller service must be specified."); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = newarray (java.lang.Object)[2]; v = virtualinvoke v.(); v[0] = v; v[1] = v; v = staticinvoke ("The process group id (%s) in the request body does not equal the process group id of the requested resource (%s).", v); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("The controller service state must be specified."); throw v; label: v = virtualinvoke v.(); v = staticinvoke (v); label: goto label; label: v := @caughtexception; v = new java.lang.IllegalArgumentException; v = newarray (java.lang.Object)[1]; v = ; v = ; v = staticinvoke (v, v); v = staticinvoke (v, ", "); v[0] = v; v = staticinvoke ("The controller service state must be one of [%s].", v); specialinvoke v.(java.lang.String)>(v); throw v; label: v = ; v = virtualinvoke v.(v); if v != 0 goto label; v = ; v = virtualinvoke v.(v); if v == 0 goto label; label: v = new java.lang.IllegalArgumentException; v = newarray (java.lang.Object)[1]; v = ; v = ; v = staticinvoke (v, v); v = staticinvoke (v, ", "); v[0] = v; v = staticinvoke ("The scheduled must be one of [%s].", v); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v != null goto label; v = v.; v = staticinvoke (v, v); v = interfaceinvoke v.(v, v); v = new java.util.HashMap; specialinvoke v.()>(); v = staticinvoke (v); interfaceinvoke v.(v); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("PUT", v); return v; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = staticinvoke (v); v = staticinvoke (v, v); v = interfaceinvoke v.(v); v = new java.util.HashSet; v = interfaceinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = v.; v = staticinvoke (v, v); v = staticinvoke (v, v, v, v); v = staticinvoke (v, v); v = virtualinvoke v.(v, v, v, v, v, v); return v; catch java.lang.IllegalArgumentException from label to label with label; } public javax.ws.rs.core.Response searchFlow(java.lang.String, java.lang.String) { org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; javax.ws.rs.core.Response v; javax.ws.rs.core.Response$ResponseBuilder v, v; org.apache.nifi.web.api.dto.search.SearchResultsDTO v; java.lang.String v, v; org.apache.nifi.web.api.entity.SearchResultsEntity v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(); v = v.; v = interfaceinvoke v.(v, v); v = new org.apache.nifi.web.api.entity.SearchResultsEntity; specialinvoke v.()>(); virtualinvoke v.(v); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getControllerStatus() throws java.lang.InterruptedException { org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; javax.ws.rs.core.Response v, v; org.apache.nifi.web.api.dto.status.ControllerStatusDTO v; org.apache.nifi.web.api.entity.ControllerStatusEntity v; javax.ws.rs.core.Response$ResponseBuilder v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = v.; v = interfaceinvoke v.(); v = new org.apache.nifi.web.api.entity.ControllerStatusEntity; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getClusterSummary() { org.apache.nifi.web.api.dto.ClusterSummaryDTO v; java.lang.Integer v, v; java.util.Map v; int v, v, v; org.apache.nifi.cluster.coordination.ClusterCoordinator v; java.lang.Boolean v, v; org.apache.nifi.cluster.coordination.node.NodeConnectionState v; java.lang.String v; boolean v, v, v, v; java.util.Iterator v; java.util.Collection v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; org.apache.nifi.web.api.entity.ClusteSummaryEntity v; javax.ws.rs.core.Response v; javax.ws.rs.core.Response$ResponseBuilder v; java.lang.Object v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; specialinvoke v.(); v = new org.apache.nifi.web.api.dto.ClusterSummaryDTO; specialinvoke v.()>(); v = virtualinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = 0; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = v + v; goto label; label: v = ; v = interfaceinvoke v.(v); if v != null goto label; v = 0; goto label; label: v = interfaceinvoke v.(); label: v = staticinvoke (v); virtualinvoke v.(v); v = staticinvoke (v); virtualinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u / \u0001"); virtualinvoke v.(v); label: v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); v = new org.apache.nifi.web.api.entity.ClusteSummaryEntity; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getBulletins() { org.apache.nifi.web.NiFiServiceFacade v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; org.apache.nifi.web.api.entity.ControllerBulletinsEntity v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getBanners() { javax.ws.rs.core.Response v; org.apache.nifi.util.NiFiProperties v; org.apache.nifi.web.api.dto.BannerDTO v; javax.ws.rs.core.Response$ResponseBuilder v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.lang.String v; org.apache.nifi.web.api.entity.BannerEntity v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = new org.apache.nifi.web.api.dto.BannerDTO; specialinvoke v.()>(); virtualinvoke v.(v); virtualinvoke v.(v); v = new org.apache.nifi.web.api.entity.BannerEntity; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getProcessorTypes(java.lang.String, java.lang.String, java.lang.String) throws java.lang.InterruptedException { org.apache.nifi.web.api.entity.ProcessorTypesEntity v; org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; java.lang.String v, v, v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = new org.apache.nifi.web.api.entity.ProcessorTypesEntity; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(v, v, v); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getControllerServiceTypes(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String) throws java.lang.InterruptedException { java.lang.String v, v, v, v, v, v, v; org.apache.nifi.web.api.entity.ControllerServiceTypesEntity v; boolean v; org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; java.lang.IllegalArgumentException v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(); if v == null goto label; if v == null goto label; if v == null goto label; if v != null goto label; label: v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("When specifying the serviceType the serviceBundleGroup, serviceBundleArtifact, and serviceBundleVersion must be specified."); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = new org.apache.nifi.web.api.entity.ControllerServiceTypesEntity; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(v, v, v, v, v, v, v); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getReportingTaskTypes(java.lang.String, java.lang.String, java.lang.String) throws java.lang.InterruptedException { org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; org.apache.nifi.web.api.entity.ReportingTaskTypesEntity v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; java.lang.String v, v, v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = new org.apache.nifi.web.api.entity.ReportingTaskTypesEntity; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(v, v, v); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getRuntimeManifest() throws java.lang.InterruptedException { org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; org.apache.nifi.c.protocol.component.api.RuntimeManifest v; org.apache.nifi.web.api.entity.RuntimeManifestEntity v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = new org.apache.nifi.web.api.entity.RuntimeManifestEntity; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getParameterProviderTypes(java.lang.String, java.lang.String, java.lang.String) throws java.lang.InterruptedException { org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; org.apache.nifi.web.api.entity.ParameterProviderTypesEntity v; java.lang.String v, v, v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = new org.apache.nifi.web.api.entity.ParameterProviderTypesEntity; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(v, v, v); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getPrioritizers() throws java.lang.InterruptedException { org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; org.apache.nifi.web.api.entity.PrioritizerTypesEntity v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = new org.apache.nifi.web.api.entity.PrioritizerTypesEntity; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getAboutInfo() { org.apache.nifi.bundle.Bundle v; org.apache.nifi.bundle.BundleCoordinate v; java.util.Date v, v; java.lang.String[] v; org.apache.nifi.bundle.BundleDetails v; org.apache.nifi.web.api.dto.AboutDTO v; java.lang.String v, v, v, v, v, v; org.apache.nifi.nar.NarClassLoaders v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; javax.ws.rs.core.Response v; org.apache.nifi.util.NiFiProperties v; javax.ws.rs.core.Response$ResponseBuilder v; org.apache.nifi.web.api.entity.AboutEntity v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; specialinvoke v.(); v = new org.apache.nifi.web.api.dto.AboutDTO; specialinvoke v.()>(); virtualinvoke v.("NiFi"); v = newarray (java.lang.String)[0]; v = virtualinvoke v.(v); virtualinvoke v.(v); v = new java.util.Date; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.("nifi.content.viewer.url"); virtualinvoke v.(v); v = staticinvoke (); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); label: v = new org.apache.nifi.web.api.entity.AboutEntity; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getRegistryClients() { org.apache.nifi.web.NiFiServiceFacade v; javax.ws.rs.core.Response v; javax.ws.rs.core.Response$ResponseBuilder v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; org.apache.nifi.web.api.entity.FlowRegistryClientsEntity v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; specialinvoke v.(); v = v.; v = interfaceinvoke v.(); v = new org.apache.nifi.web.api.entity.FlowRegistryClientsEntity; specialinvoke v.()>(); virtualinvoke v.(v); v = specialinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } private org.apache.nifi.web.api.entity.FlowRegistryClientEntity populateRemainingRegistryClientEntityContent(org.apache.nifi.web.api.entity.FlowRegistryClientEntity) { WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.lang.String[] v; java.util.Map v; org.apache.nifi.web.api.entity.FlowRegistryClientEntity v; java.lang.Object v; java.lang.String v, v, v; org.apache.nifi.web.api.dto.FlowRegistryClientDTO v, v, v, v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.entity.FlowRegistryClientEntity; v = newarray (java.lang.String)[3]; v[0] = "controller"; v[1] = "registry-clients"; v = virtualinvoke v.(); v[2] = v; v = virtualinvoke v.(v); virtualinvoke v.(v); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.("org.apache.nifi.registry.flow.NifiRegistryFlowRegistryClient"); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.("url"); virtualinvoke v.(v); label: return v; } private org.apache.nifi.web.api.entity.FlowRegistryClientsEntity populateRemainingRegistryClientEntityContent(org.apache.nifi.web.api.entity.FlowRegistryClientsEntity) { java.util.Iterator v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; java.lang.Object v; org.apache.nifi.web.api.entity.FlowRegistryClientsEntity v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.entity.FlowRegistryClientsEntity; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); specialinvoke v.(v); goto label; label: return v; } public javax.ws.rs.core.Response getBuckets(java.lang.String) throws org.apache.nifi.registry.client.NiFiRegistryException { org.apache.nifi.web.NiFiServiceFacade v; java.util.SortedSet v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; javax.ws.rs.core.Response v; javax.ws.rs.core.Response$ResponseBuilder v; java.lang.String v; org.apache.nifi.web.api.entity.FlowRegistryBucketsEntity v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; specialinvoke v.(); v = v.; v = interfaceinvoke v.(v); v = specialinvoke v.(v); v = new org.apache.nifi.web.api.entity.FlowRegistryBucketsEntity; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } private java.util.SortedSet sortBuckets(java.util.Set) { WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; java.util.Comparator v; java.util.TreeSet v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.util.Set; v = new java.util.TreeSet; v = staticinvoke (v); specialinvoke v.(java.util.Comparator)>(v); interfaceinvoke v.(v); return v; } private java.lang.String getBucketName(org.apache.nifi.web.api.entity.FlowRegistryBucketEntity) { WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.lang.String v; org.apache.nifi.web.api.entity.FlowRegistryBucketEntity v; org.apache.nifi.web.api.dto.FlowRegistryBucketDTO v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.entity.FlowRegistryBucketEntity; v = virtualinvoke v.(); if v != null goto label; v = null; goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); label: return v; } public javax.ws.rs.core.Response getFlows(java.lang.String, java.lang.String) { org.apache.nifi.web.NiFiServiceFacade v; java.util.SortedSet v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; javax.ws.rs.core.Response v; javax.ws.rs.core.Response$ResponseBuilder v; java.lang.String v, v; org.apache.nifi.web.api.entity.VersionedFlowsEntity v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(); v = v.; v = interfaceinvoke v.(v, v); v = specialinvoke v.(v); v = new org.apache.nifi.web.api.entity.VersionedFlowsEntity; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } private java.util.SortedSet sortFlows(java.util.Set) { WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; java.util.Comparator v; java.util.TreeSet v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.util.Set; v = new java.util.TreeSet; v = staticinvoke (v); specialinvoke v.(java.util.Comparator)>(v); interfaceinvoke v.(v); return v; } private java.lang.String getFlowName(org.apache.nifi.web.api.entity.VersionedFlowEntity) { org.apache.nifi.web.api.entity.VersionedFlowEntity v; org.apache.nifi.web.api.dto.VersionedFlowDTO v, v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.lang.String v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.entity.VersionedFlowEntity; v = virtualinvoke v.(); if v != null goto label; v = ""; goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); label: return v; } public javax.ws.rs.core.Response getDetails(java.lang.String, java.lang.String, java.lang.String) { org.apache.nifi.web.api.entity.VersionedFlowEntity v; org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; javax.ws.rs.core.Response v; javax.ws.rs.core.Response$ResponseBuilder v; java.lang.String v, v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(); v = v.; v = interfaceinvoke v.(v, v, v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getVersionDifferences(java.lang.String, java.lang.String, java.lang.String, int, int, int, int) { org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; javax.ws.rs.core.MediaType v; javax.ws.rs.core.Response v; org.apache.nifi.web.api.entity.FlowComparisonEntity v, v; javax.ws.rs.core.Response$ResponseBuilder v, v; int v, v, v, v; java.lang.String v, v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: int; v := @parameter: int; v := @parameter: int; v := @parameter: int; specialinvoke v.(); v = v.; v = interfaceinvoke v.(v, v, v, v, v); v = staticinvoke (v, v, v); v = virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getVersions(java.lang.String, java.lang.String, java.lang.String) { org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; javax.ws.rs.core.Response v; org.apache.nifi.web.api.entity.VersionedFlowSnapshotMetadataSetEntity v; javax.ws.rs.core.Response$ResponseBuilder v; java.lang.String v, v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(); v = v.; v = interfaceinvoke v.(v, v, v); v = new org.apache.nifi.web.api.entity.VersionedFlowSnapshotMetadataSetEntity; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } private static org.apache.nifi.web.api.entity.FlowComparisonEntity limitDifferences(org.apache.nifi.web.api.entity.FlowComparisonEntity, int, int) { java.util.function.BiFunction v; java.util.Set v; java.util.function.Function v; java.util.HashSet v; java.util.List v; org.apache.nifi.web.api.entity.FlowComparisonEntity v, v; int v, v; v := @parameter: org.apache.nifi.web.api.entity.FlowComparisonEntity; v := @parameter: int; v := @parameter: int; v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke (); v = staticinvoke (v, v, v, v, v); v = new org.apache.nifi.web.api.entity.FlowComparisonEntity; specialinvoke v.()>(); v = new java.util.HashSet; specialinvoke v.(java.util.Collection)>(v); virtualinvoke v.(v); return v; } private static org.apache.nifi.web.api.dto.ComponentDifferenceDTO limitDifferences(org.apache.nifi.web.api.dto.ComponentDifferenceDTO, java.util.List) { java.util.List v; org.apache.nifi.web.api.dto.ComponentDifferenceDTO v, v; java.lang.String v, v, v, v; v := @parameter: org.apache.nifi.web.api.dto.ComponentDifferenceDTO; v := @parameter: java.util.List; v = new org.apache.nifi.web.api.dto.ComponentDifferenceDTO; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v); return v; } public javax.ws.rs.core.Response getBulletinBoard(org.apache.nifi.web.api.request.LongParameter, org.apache.nifi.web.api.request.BulletinBoardPatternParameter, org.apache.nifi.web.api.request.BulletinBoardPatternParameter, org.apache.nifi.web.api.request.BulletinBoardPatternParameter, org.apache.nifi.web.api.request.BulletinBoardPatternParameter, org.apache.nifi.web.api.request.IntegerParameter) throws java.lang.InterruptedException { org.apache.nifi.web.api.dto.BulletinQueryDTO v; org.apache.nifi.web.api.request.BulletinBoardPatternParameter v, v, v, v; java.lang.Integer v; org.apache.nifi.web.api.entity.BulletinBoardEntity v; java.lang.Long v; org.apache.nifi.web.api.request.IntegerParameter v; java.lang.String v, v, v, v; boolean v; org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; org.apache.nifi.web.api.dto.BulletinBoardDTO v; org.apache.nifi.web.api.request.LongParameter v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.request.LongParameter; v := @parameter: org.apache.nifi.web.api.request.BulletinBoardPatternParameter; v := @parameter: org.apache.nifi.web.api.request.BulletinBoardPatternParameter; v := @parameter: org.apache.nifi.web.api.request.BulletinBoardPatternParameter; v := @parameter: org.apache.nifi.web.api.request.BulletinBoardPatternParameter; v := @parameter: org.apache.nifi.web.api.request.IntegerParameter; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = new org.apache.nifi.web.api.dto.BulletinQueryDTO; specialinvoke v.()>(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; v = interfaceinvoke v.(v); v = new org.apache.nifi.web.api.entity.BulletinBoardEntity; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getProcessorStatus(java.lang.Boolean, java.lang.String, java.lang.String) throws java.lang.InterruptedException { org.apache.nifi.web.api.dto.status.ProcessorStatusDTO v; java.lang.Boolean v, v; java.lang.String v, v; org.apache.nifi.cluster.manager.NodeResponse v; boolean v, v, v; org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.lang.IllegalArgumentException v; javax.ws.rs.core.Response v, v, v; org.apache.nifi.web.api.entity.ProcessorStatusEntity v; javax.ws.rs.core.Response$ResponseBuilder v; org.apache.nifi.web.api.entity.Entity v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.Boolean; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(); v = ; v = virtualinvoke v.(v); if v == 0 goto label; if v == null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Nodewise requests cannot be directed at a specific node."); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; if v != null goto label; v = virtualinvoke v.("GET"); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(null); label: v = virtualinvoke v.(); return v; label: v = virtualinvoke v.("GET", v); return v; label: v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getInputPortStatus(java.lang.Boolean, java.lang.String, java.lang.String) throws java.lang.InterruptedException { org.apache.nifi.web.api.dto.status.PortStatusDTO v; java.lang.Boolean v, v; java.lang.String v, v; org.apache.nifi.cluster.manager.NodeResponse v; boolean v, v, v; org.apache.nifi.web.NiFiServiceFacade v; org.apache.nifi.web.api.entity.PortStatusEntity v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.lang.IllegalArgumentException v; javax.ws.rs.core.Response v, v, v; javax.ws.rs.core.Response$ResponseBuilder v; org.apache.nifi.web.api.entity.Entity v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.Boolean; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(); v = ; v = virtualinvoke v.(v); if v == 0 goto label; if v == null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Nodewise requests cannot be directed at a specific node."); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; if v != null goto label; v = virtualinvoke v.("GET"); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(null); label: v = virtualinvoke v.(); return v; label: v = virtualinvoke v.("GET", v); return v; label: v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getOutputPortStatus(java.lang.Boolean, java.lang.String, java.lang.String) throws java.lang.InterruptedException { org.apache.nifi.web.api.dto.status.PortStatusDTO v; java.lang.Boolean v, v; java.lang.String v, v; org.apache.nifi.cluster.manager.NodeResponse v; boolean v, v, v; org.apache.nifi.web.NiFiServiceFacade v; org.apache.nifi.web.api.entity.PortStatusEntity v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.lang.IllegalArgumentException v; javax.ws.rs.core.Response v, v, v; javax.ws.rs.core.Response$ResponseBuilder v; org.apache.nifi.web.api.entity.Entity v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.Boolean; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(); v = ; v = virtualinvoke v.(v); if v == 0 goto label; if v == null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Nodewise requests cannot be directed at a specific node."); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; if v != null goto label; v = virtualinvoke v.("GET"); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(null); label: v = virtualinvoke v.(); return v; label: v = virtualinvoke v.("GET", v); return v; label: v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getRemoteProcessGroupStatus(java.lang.Boolean, java.lang.String, java.lang.String) throws java.lang.InterruptedException { org.apache.nifi.web.api.entity.RemoteProcessGroupStatusEntity v; java.lang.Boolean v, v; java.lang.String v, v; org.apache.nifi.cluster.manager.NodeResponse v; boolean v, v, v; org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.lang.IllegalArgumentException v; javax.ws.rs.core.Response v, v, v; javax.ws.rs.core.Response$ResponseBuilder v; org.apache.nifi.web.api.dto.status.RemoteProcessGroupStatusDTO v; org.apache.nifi.web.api.entity.Entity v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.Boolean; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(); v = ; v = virtualinvoke v.(v); if v == 0 goto label; if v == null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Nodewise requests cannot be directed at a specific node."); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; if v != null goto label; v = virtualinvoke v.("GET"); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(null); label: v = virtualinvoke v.(); return v; label: v = virtualinvoke v.("GET", v); return v; label: v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getProcessGroupStatus(java.lang.Boolean, java.lang.Boolean, java.lang.String, java.lang.String) throws java.lang.InterruptedException { org.apache.nifi.web.api.dto.status.ProcessGroupStatusDTO v; org.apache.nifi.web.api.entity.ProcessGroupStatusEntity v; java.lang.Boolean v, v, v; java.lang.String v, v; org.apache.nifi.cluster.manager.NodeResponse v; boolean v, v, v, v; org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.lang.IllegalArgumentException v; javax.ws.rs.core.Response v, v, v; javax.ws.rs.core.Response$ResponseBuilder v; org.apache.nifi.web.api.entity.Entity v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.Boolean; v := @parameter: java.lang.Boolean; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(); v = ; v = virtualinvoke v.(v); if v == 0 goto label; if v == null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Nodewise requests cannot be directed at a specific node."); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; if v != null goto label; v = virtualinvoke v.("GET"); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(null); label: v = virtualinvoke v.(); return v; label: v = virtualinvoke v.("GET", v); return v; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v, v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getConnectionStatus(java.lang.Boolean, java.lang.String, java.lang.String) throws java.lang.InterruptedException { org.apache.nifi.web.api.entity.ConnectionStatusEntity v; java.lang.Boolean v, v; java.lang.String v, v; org.apache.nifi.cluster.manager.NodeResponse v; boolean v, v, v; org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.lang.IllegalArgumentException v; javax.ws.rs.core.Response v, v, v; javax.ws.rs.core.Response$ResponseBuilder v; org.apache.nifi.web.api.dto.status.ConnectionStatusDTO v; org.apache.nifi.web.api.entity.Entity v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.Boolean; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(); v = ; v = virtualinvoke v.(v); if v == 0 goto label; if v == null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Nodewise requests cannot be directed at a specific node."); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; if v != null goto label; v = virtualinvoke v.("GET"); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(null); label: v = virtualinvoke v.(); return v; label: v = virtualinvoke v.("GET", v); return v; label: v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getConnectionStatistics(java.lang.Boolean, java.lang.String, java.lang.String) throws java.lang.InterruptedException { org.apache.nifi.web.api.entity.ConnectionStatisticsEntity v; java.lang.Boolean v, v; java.lang.String v, v; org.apache.nifi.cluster.manager.NodeResponse v; boolean v, v, v; org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.lang.IllegalArgumentException v; javax.ws.rs.core.Response v, v, v; javax.ws.rs.core.Response$ResponseBuilder v; org.apache.nifi.web.api.entity.Entity v; org.apache.nifi.web.api.dto.status.ConnectionStatisticsDTO v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.Boolean; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(); v = ; v = virtualinvoke v.(v); if v == 0 goto label; if v == null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Nodewise requests cannot be directed at a specific node."); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; if v != null goto label; v = virtualinvoke v.("GET"); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(null); label: v = virtualinvoke v.(); return v; label: v = virtualinvoke v.("GET", v); return v; label: v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getProcessorStatusHistory(java.lang.String) throws java.lang.InterruptedException { org.apache.nifi.web.NiFiServiceFacade v; org.apache.nifi.web.api.entity.StatusHistoryEntity v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; java.lang.String v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getProcessGroupStatusHistory(java.lang.String) throws java.lang.InterruptedException { org.apache.nifi.web.NiFiServiceFacade v; org.apache.nifi.web.api.entity.StatusHistoryEntity v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; java.lang.String v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getRemoteProcessGroupStatusHistory(java.lang.String) throws java.lang.InterruptedException { org.apache.nifi.web.NiFiServiceFacade v; org.apache.nifi.web.api.entity.StatusHistoryEntity v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; java.lang.String v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getConnectionStatusHistory(java.lang.String) throws java.lang.InterruptedException { org.apache.nifi.web.NiFiServiceFacade v; org.apache.nifi.web.api.entity.StatusHistoryEntity v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; java.lang.String v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getParameterContexts() { org.apache.nifi.web.NiFiServiceFacade v; java.util.Date v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; org.apache.nifi.web.api.entity.ParameterContextsEntity v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; specialinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: v = v.; v = interfaceinvoke v.(); v = new org.apache.nifi.web.api.entity.ParameterContextsEntity; specialinvoke v.()>(); virtualinvoke v.(v); v = new java.util.Date; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response queryHistory(org.apache.nifi.web.api.request.IntegerParameter, org.apache.nifi.web.api.request.IntegerParameter, java.lang.String, java.lang.String, org.apache.nifi.web.api.request.DateTimeParameter, org.apache.nifi.web.api.request.DateTimeParameter, java.lang.String, java.lang.String) { org.apache.nifi.web.api.request.DateTimeParameter v, v; java.util.Date v, v, v, v; java.lang.Integer v, v, v, v; org.apache.nifi.web.api.request.IntegerParameter v, v; boolean v, v, v; org.apache.nifi.web.api.dto.action.HistoryQueryDTO v; org.apache.nifi.web.api.entity.HistoryEntity v; javax.ws.rs.core.Response v; javax.ws.rs.core.Response$ResponseBuilder v; int v, v; java.lang.String v, v, v, v; org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.lang.IllegalArgumentException v, v, v, v, v, v; org.apache.nifi.web.api.dto.action.HistoryDTO v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.request.IntegerParameter; v := @parameter: org.apache.nifi.web.api.request.IntegerParameter; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.web.api.request.DateTimeParameter; v := @parameter: org.apache.nifi.web.api.request.DateTimeParameter; v := @parameter: java.lang.String; v := @parameter: java.lang.String; specialinvoke v.(); if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("The desired offset must be specified."); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v >= 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("The desired offset must be an integer value greater than or equal to 0."); throw v; label: if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("The desired row count must be specified."); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v >= 1 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("The desired row count must be an integer value greater than 0."); throw v; label: if v == null goto label; v = virtualinvoke v.("asc"); if v != 0 goto label; v = virtualinvoke v.("desc"); if v != 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("The sort order must be \'asc\' or \'desc\'."); throw v; label: if v == null goto label; if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("The start date/time must come before the end date/time."); throw v; label: v = new org.apache.nifi.web.api.dto.action.HistoryQueryDTO; specialinvoke v.()>(); virtualinvoke v.(v); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: if v == null goto label; virtualinvoke v.(v); label: if v == null goto label; virtualinvoke v.(v); label: v = v.; v = interfaceinvoke v.(v); v = new org.apache.nifi.web.api.entity.HistoryEntity; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getAction(org.apache.nifi.web.api.request.IntegerParameter) { org.apache.nifi.web.NiFiServiceFacade v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.lang.IllegalArgumentException v; java.lang.Integer v; javax.ws.rs.core.Response v; javax.ws.rs.core.Response$ResponseBuilder v; org.apache.nifi.web.api.entity.ActionEntity v; org.apache.nifi.web.api.request.IntegerParameter v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.request.IntegerParameter; specialinvoke v.(); if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("The action id must be specified."); throw v; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getComponentHistory(java.lang.String) { org.apache.nifi.web.NiFiServiceFacade v, v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; org.apache.nifi.web.api.entity.ComponentHistoryEntity v; org.apache.nifi.authorization.AuthorizeAccess v; javax.ws.rs.core.Response v; org.apache.nifi.web.api.dto.ComponentHistoryDTO v; javax.ws.rs.core.Response$ResponseBuilder v; java.lang.String v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; v = v.; v = staticinvoke (v, v); interfaceinvoke v.(v); v = new org.apache.nifi.web.api.entity.ComponentHistoryEntity; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(v); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response getTemplates() { org.apache.nifi.web.NiFiServiceFacade v; org.apache.nifi.web.api.entity.TemplatesEntity v; java.util.Date v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; java.util.Set v; org.apache.nifi.web.api.TemplateResource v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.("GET"); return v; label: specialinvoke v.(); v = v.; v = interfaceinvoke v.(); v = v.; virtualinvoke v.(v); v = new org.apache.nifi.web.api.entity.TemplatesEntity; specialinvoke v.()>(); virtualinvoke v.(v); v = new java.util.Date; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response searchCluster(java.lang.String) { org.apache.nifi.web.api.dto.ClusterDTO v; java.lang.Integer v; java.util.ArrayList v; org.apache.nifi.cluster.coordination.node.NodeConnectionState v; java.lang.String v, v, v, v, v, v; boolean v, v, v, v, v; org.apache.nifi.web.NiFiServiceFacade v; java.util.Iterator v; java.util.Collection v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; org.apache.nifi.web.api.dto.search.NodeSearchResultDTO v; org.apache.nifi.web.api.entity.ClusterSearchResultsEntity v; javax.ws.rs.core.Response v; javax.ws.rs.core.Response$ResponseBuilder v, v; java.lang.Object v; org.apache.nifi.web.IllegalClusterResourceRequestException v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: java.lang.String; specialinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = new org.apache.nifi.web.IllegalClusterResourceRequestException; specialinvoke v.(java.lang.String)>("Only a node connected to a cluster can process the request."); throw v; label: v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001:\u0001"); v = staticinvoke (v); if v != 0 goto label; v = staticinvoke (v, v); if v == 0 goto label; label: v = new org.apache.nifi.web.api.dto.search.NodeSearchResultDTO; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v); interfaceinvoke v.(v); goto label; label: v = new org.apache.nifi.web.api.entity.ClusterSearchResultsEntity; specialinvoke v.()>(); virtualinvoke v.(v); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; } public void setServiceFacade(org.apache.nifi.web.NiFiServiceFacade) { WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; org.apache.nifi.web.NiFiServiceFacade v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.NiFiServiceFacade; v. = v; return; } public void setProcessorResource(org.apache.nifi.web.api.ProcessorResource) { org.apache.nifi.web.api.ProcessorResource v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.ProcessorResource; v. = v; return; } public void setInputPortResource(org.apache.nifi.web.api.InputPortResource) { WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; org.apache.nifi.web.api.InputPortResource v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.InputPortResource; v. = v; return; } public void setOutputPortResource(org.apache.nifi.web.api.OutputPortResource) { org.apache.nifi.web.api.OutputPortResource v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.OutputPortResource; v. = v; return; } public void setFunnelResource(org.apache.nifi.web.api.FunnelResource) { org.apache.nifi.web.api.FunnelResource v; WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.FunnelResource; v. = v; return; } public void setLabelResource(org.apache.nifi.web.api.LabelResource) { WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; org.apache.nifi.web.api.LabelResource v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.LabelResource; v. = v; return; } public void setRemoteProcessGroupResource(org.apache.nifi.web.api.RemoteProcessGroupResource) { WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; org.apache.nifi.web.api.RemoteProcessGroupResource v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.RemoteProcessGroupResource; v. = v; return; } public void setConnectionResource(org.apache.nifi.web.api.ConnectionResource) { WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; org.apache.nifi.web.api.ConnectionResource v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.ConnectionResource; v. = v; return; } public void setTemplateResource(org.apache.nifi.web.api.TemplateResource) { WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; org.apache.nifi.web.api.TemplateResource v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.TemplateResource; v. = v; return; } public void setProcessGroupResource(org.apache.nifi.web.api.ProcessGroupResource) { WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; org.apache.nifi.web.api.ProcessGroupResource v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.ProcessGroupResource; v. = v; return; } public void setControllerServiceResource(org.apache.nifi.web.api.ControllerServiceResource) { WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; org.apache.nifi.web.api.ControllerServiceResource v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.ControllerServiceResource; v. = v; return; } public void setReportingTaskResource(org.apache.nifi.web.api.ReportingTaskResource) { WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; org.apache.nifi.web.api.ReportingTaskResource v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.ReportingTaskResource; v. = v; return; } public void setParameterProviderResource(org.apache.nifi.web.api.ParameterProviderResource) { WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; org.apache.nifi.web.api.ParameterProviderResource v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.web.api.ParameterProviderResource; v. = v; return; } public void setAuthorizer(org.apache.nifi.authorization.Authorizer) { WEB-INF.classes.org.apache.nifi.web.api.FlowResource v; org.apache.nifi.authorization.Authorizer v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.FlowResource; v := @parameter: org.apache.nifi.authorization.Authorizer; v. = v; return; } }