public class WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO extends java.lang.Object implements org.apache.nifi.web.dao.ComponentStateDAO
{
private org.apache.nifi.components.state.StateManagerProvider stateManagerProvider;
public void <init>()
{
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
private org.apache.nifi.components.state.StateMap getState(java.lang.String, org.apache.nifi.components.state.Scope)
{
java.lang.IllegalStateException v;
java.lang.Object[] v, v;
org.apache.nifi.components.state.StateManager v;
java.io.IOException v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO v;
org.apache.nifi.components.state.StateMap v;
org.apache.nifi.components.state.StateManagerProvider v;
org.apache.nifi.components.state.Scope v;
org.apache.nifi.web.ResourceNotFoundException v;
java.lang.String v, v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.components.state.Scope;
label:
v = v.<org.apache.nifi.web.dao.impl.StandardComponentStateDAO: org.apache.nifi.components.state.StateManagerProvider stateManagerProvider>;
v = interfaceinvoke v.<org.apache.nifi.components.state.StateManagerProvider: org.apache.nifi.components.state.StateManager getStateManager(java.lang.String)>(v);
if v != null goto label;
v = new org.apache.nifi.web.ResourceNotFoundException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("State for the specified component %s could not be found.", v);
specialinvoke v.<org.apache.nifi.web.ResourceNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.nifi.components.state.StateManager: org.apache.nifi.components.state.StateMap getState(org.apache.nifi.components.state.Scope)>(v);
label:
return v;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Unable to get the state for the specified component %s: %s", v);
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.io.IOException from label to label with label;
}
private void clearState(java.lang.String)
{
java.lang.IllegalStateException v;
java.lang.Object[] v, v;
org.apache.nifi.components.state.StateManager v;
java.io.IOException v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO v;
org.apache.nifi.components.state.StateManagerProvider v;
org.apache.nifi.components.state.Scope v, v;
org.apache.nifi.web.ResourceNotFoundException v;
java.lang.String v, v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO;
v := @parameter: java.lang.String;
label:
v = v.<org.apache.nifi.web.dao.impl.StandardComponentStateDAO: org.apache.nifi.components.state.StateManagerProvider stateManagerProvider>;
v = interfaceinvoke v.<org.apache.nifi.components.state.StateManagerProvider: org.apache.nifi.components.state.StateManager getStateManager(java.lang.String)>(v);
if v != null goto label;
v = new org.apache.nifi.web.ResourceNotFoundException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("State for the specified component %s could not be found.", v);
specialinvoke v.<org.apache.nifi.web.ResourceNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
v = <org.apache.nifi.components.state.Scope: org.apache.nifi.components.state.Scope CLUSTER>;
interfaceinvoke v.<org.apache.nifi.components.state.StateManager: void clear(org.apache.nifi.components.state.Scope)>(v);
v = <org.apache.nifi.components.state.Scope: org.apache.nifi.components.state.Scope LOCAL>;
interfaceinvoke v.<org.apache.nifi.components.state.StateManager: void clear(org.apache.nifi.components.state.Scope)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
v = newarray (java.lang.Object)[2];
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Unable to clear the state for the specified component %s: %s", v);
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch java.io.IOException from label to label with label;
}
public org.apache.nifi.components.state.StateMap getState(org.apache.nifi.controller.ProcessorNode, org.apache.nifi.components.state.Scope)
{
org.apache.nifi.controller.ProcessorNode v;
org.apache.nifi.components.state.Scope v;
java.lang.String v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO v;
org.apache.nifi.components.state.StateMap v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO;
v := @parameter: org.apache.nifi.controller.ProcessorNode;
v := @parameter: org.apache.nifi.components.state.Scope;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getIdentifier()>();
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardComponentStateDAO: org.apache.nifi.components.state.StateMap getState(java.lang.String,org.apache.nifi.components.state.Scope)>(v, v);
return v;
}
public void clearState(org.apache.nifi.controller.ProcessorNode)
{
org.apache.nifi.controller.ProcessorNode v;
java.lang.String v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO;
v := @parameter: org.apache.nifi.controller.ProcessorNode;
v = virtualinvoke v.<org.apache.nifi.controller.ProcessorNode: java.lang.String getIdentifier()>();
specialinvoke v.<org.apache.nifi.web.dao.impl.StandardComponentStateDAO: void clearState(java.lang.String)>(v);
return;
}
public org.apache.nifi.components.state.StateMap getState(org.apache.nifi.controller.service.ControllerServiceNode, org.apache.nifi.components.state.Scope)
{
org.apache.nifi.components.state.Scope v;
org.apache.nifi.controller.service.ControllerServiceNode v;
java.lang.String v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO v;
org.apache.nifi.components.state.StateMap v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO;
v := @parameter: org.apache.nifi.controller.service.ControllerServiceNode;
v := @parameter: org.apache.nifi.components.state.Scope;
v = interfaceinvoke v.<org.apache.nifi.controller.service.ControllerServiceNode: java.lang.String getIdentifier()>();
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardComponentStateDAO: org.apache.nifi.components.state.StateMap getState(java.lang.String,org.apache.nifi.components.state.Scope)>(v, v);
return v;
}
public void clearState(org.apache.nifi.controller.service.ControllerServiceNode)
{
java.lang.String v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO v;
org.apache.nifi.controller.service.ControllerServiceNode v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO;
v := @parameter: org.apache.nifi.controller.service.ControllerServiceNode;
v = interfaceinvoke v.<org.apache.nifi.controller.service.ControllerServiceNode: java.lang.String getIdentifier()>();
specialinvoke v.<org.apache.nifi.web.dao.impl.StandardComponentStateDAO: void clearState(java.lang.String)>(v);
return;
}
public org.apache.nifi.components.state.StateMap getState(org.apache.nifi.controller.ReportingTaskNode, org.apache.nifi.components.state.Scope)
{
org.apache.nifi.components.state.Scope v;
org.apache.nifi.controller.ReportingTaskNode v;
java.lang.String v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO v;
org.apache.nifi.components.state.StateMap v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO;
v := @parameter: org.apache.nifi.controller.ReportingTaskNode;
v := @parameter: org.apache.nifi.components.state.Scope;
v = interfaceinvoke v.<org.apache.nifi.controller.ReportingTaskNode: java.lang.String getIdentifier()>();
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardComponentStateDAO: org.apache.nifi.components.state.StateMap getState(java.lang.String,org.apache.nifi.components.state.Scope)>(v, v);
return v;
}
public void clearState(org.apache.nifi.controller.ReportingTaskNode)
{
org.apache.nifi.controller.ReportingTaskNode v;
java.lang.String v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO;
v := @parameter: org.apache.nifi.controller.ReportingTaskNode;
v = interfaceinvoke v.<org.apache.nifi.controller.ReportingTaskNode: java.lang.String getIdentifier()>();
specialinvoke v.<org.apache.nifi.web.dao.impl.StandardComponentStateDAO: void clearState(java.lang.String)>(v);
return;
}
public org.apache.nifi.components.state.StateMap getState(org.apache.nifi.controller.ParameterProviderNode, org.apache.nifi.components.state.Scope)
{
org.apache.nifi.components.state.Scope v;
org.apache.nifi.controller.ParameterProviderNode v;
java.lang.String v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO v;
org.apache.nifi.components.state.StateMap v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO;
v := @parameter: org.apache.nifi.controller.ParameterProviderNode;
v := @parameter: org.apache.nifi.components.state.Scope;
v = interfaceinvoke v.<org.apache.nifi.controller.ParameterProviderNode: java.lang.String getIdentifier()>();
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardComponentStateDAO: org.apache.nifi.components.state.StateMap getState(java.lang.String,org.apache.nifi.components.state.Scope)>(v, v);
return v;
}
public void clearState(org.apache.nifi.controller.ParameterProviderNode)
{
org.apache.nifi.controller.ParameterProviderNode v;
java.lang.String v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO;
v := @parameter: org.apache.nifi.controller.ParameterProviderNode;
v = interfaceinvoke v.<org.apache.nifi.controller.ParameterProviderNode: java.lang.String getIdentifier()>();
specialinvoke v.<org.apache.nifi.web.dao.impl.StandardComponentStateDAO: void clearState(java.lang.String)>(v);
return;
}
public org.apache.nifi.components.state.StateMap getState(org.apache.nifi.groups.RemoteProcessGroup, org.apache.nifi.components.state.Scope)
{
org.apache.nifi.components.state.Scope v;
org.apache.nifi.groups.RemoteProcessGroup v;
java.lang.String v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO v;
org.apache.nifi.components.state.StateMap v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO;
v := @parameter: org.apache.nifi.groups.RemoteProcessGroup;
v := @parameter: org.apache.nifi.components.state.Scope;
v = interfaceinvoke v.<org.apache.nifi.groups.RemoteProcessGroup: java.lang.String getIdentifier()>();
v = specialinvoke v.<org.apache.nifi.web.dao.impl.StandardComponentStateDAO: org.apache.nifi.components.state.StateMap getState(java.lang.String,org.apache.nifi.components.state.Scope)>(v, v);
return v;
}
public void setStateManagerProvider(org.apache.nifi.components.state.StateManagerProvider)
{
org.apache.nifi.components.state.StateManagerProvider v;
WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO v;
v := @this: WEB-INF.classes.org.apache.nifi.web.dao.impl.StandardComponentStateDAO;
v := @parameter: org.apache.nifi.components.state.StateManagerProvider;
v.<org.apache.nifi.web.dao.impl.StandardComponentStateDAO: org.apache.nifi.components.state.StateManagerProvider stateManagerProvider> = v;
return;
}
}