public class WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest extends java.lang.Object
{
private final java.lang.String requestId;
private final java.lang.String processGroupId;
private final org.apache.nifi.authorization.user.NiFiUser user;
private volatile java.util.Date submissionTime;
private volatile java.util.Date lastUpdated;
private volatile boolean complete;
private final java.util.concurrent.atomic.AtomicReference failureReason;
private org.apache.nifi.web.api.dto.RevisionDTO processGroupRevision;
private java.util.Map affectedComponents;
private final org.apache.nifi.registry.variable.VariableRegistryUpdateStep identifyComponentsStep;
private final org.apache.nifi.registry.variable.VariableRegistryUpdateStep stopProcessors;
private final org.apache.nifi.registry.variable.VariableRegistryUpdateStep disableServices;
private final org.apache.nifi.registry.variable.VariableRegistryUpdateStep applyUpdates;
private final org.apache.nifi.registry.variable.VariableRegistryUpdateStep enableServices;
private final org.apache.nifi.registry.variable.VariableRegistryUpdateStep startProcessors;
public void <init>(java.lang.String, java.lang.String, java.util.Set, org.apache.nifi.authorization.user.NiFiUser)
{
java.util.Date v, v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
java.util.concurrent.atomic.AtomicReference v;
java.util.function.Function v, v;
org.apache.nifi.registry.variable.VariableRegistryUpdateStep v, v, v, v, v, v;
org.apache.nifi.authorization.user.NiFiUser v;
java.lang.String v, v;
java.util.stream.Collector v;
java.util.Set v;
java.util.stream.Stream v;
java.lang.Object v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.util.Set;
v := @parameter: org.apache.nifi.authorization.user.NiFiUser;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: java.util.Date submissionTime> = v;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: java.util.Date lastUpdated> = v;
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: boolean complete> = 0;
v = new java.util.concurrent.atomic.AtomicReference;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>()>();
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: java.util.concurrent.atomic.AtomicReference failureReason> = v;
v = new org.apache.nifi.registry.variable.VariableRegistryUpdateStep;
specialinvoke v.<org.apache.nifi.registry.variable.VariableRegistryUpdateStep: void <init>(java.lang.String)>("Identifying components affected");
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: org.apache.nifi.registry.variable.VariableRegistryUpdateStep identifyComponentsStep> = v;
v = new org.apache.nifi.registry.variable.VariableRegistryUpdateStep;
specialinvoke v.<org.apache.nifi.registry.variable.VariableRegistryUpdateStep: void <init>(java.lang.String)>("Stopping affected Processors");
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: org.apache.nifi.registry.variable.VariableRegistryUpdateStep stopProcessors> = v;
v = new org.apache.nifi.registry.variable.VariableRegistryUpdateStep;
specialinvoke v.<org.apache.nifi.registry.variable.VariableRegistryUpdateStep: void <init>(java.lang.String)>("Disabling affected Controller Services");
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: org.apache.nifi.registry.variable.VariableRegistryUpdateStep disableServices> = v;
v = new org.apache.nifi.registry.variable.VariableRegistryUpdateStep;
specialinvoke v.<org.apache.nifi.registry.variable.VariableRegistryUpdateStep: void <init>(java.lang.String)>("Applying Updates");
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: org.apache.nifi.registry.variable.VariableRegistryUpdateStep applyUpdates> = v;
v = new org.apache.nifi.registry.variable.VariableRegistryUpdateStep;
specialinvoke v.<org.apache.nifi.registry.variable.VariableRegistryUpdateStep: void <init>(java.lang.String)>("Re-Enabling affected Controller Services");
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: org.apache.nifi.registry.variable.VariableRegistryUpdateStep enableServices> = v;
v = new org.apache.nifi.registry.variable.VariableRegistryUpdateStep;
specialinvoke v.<org.apache.nifi.registry.variable.VariableRegistryUpdateStep: void <init>(java.lang.String)>("Restarting affected Processors");
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: org.apache.nifi.registry.variable.VariableRegistryUpdateStep startProcessors> = v;
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: java.lang.String requestId> = v;
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: java.lang.String processGroupId> = v;
v = interfaceinvoke v.<java.util.Set: java.util.stream.Stream stream()>();
v = staticinvoke <WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest$getId__67: java.util.function.Function bootstrap$()>();
v = staticinvoke <java.util.function.Function: java.util.function.Function identity()>();
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toMap(java.util.function.Function,java.util.function.Function)>(v, v);
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: java.util.Map affectedComponents> = v;
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: org.apache.nifi.authorization.user.NiFiUser user> = v;
return;
}
public java.lang.String getProcessGroupId()
{
java.lang.String v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v = v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: java.lang.String processGroupId>;
return v;
}
public java.lang.String getRequestId()
{
java.lang.String v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v = v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: java.lang.String requestId>;
return v;
}
public java.util.Date getSubmissionTime()
{
java.util.Date v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v = v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: java.util.Date submissionTime>;
return v;
}
public org.apache.nifi.authorization.user.NiFiUser getUser()
{
org.apache.nifi.authorization.user.NiFiUser v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v = v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: org.apache.nifi.authorization.user.NiFiUser user>;
return v;
}
public java.util.Date getLastUpdated()
{
java.util.Date v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v = v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: java.util.Date lastUpdated>;
return v;
}
public void setLastUpdated(java.util.Date)
{
java.util.Date v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v := @parameter: java.util.Date;
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: java.util.Date lastUpdated> = v;
return;
}
public org.apache.nifi.registry.variable.VariableRegistryUpdateStep getIdentifyRelevantComponentsStep()
{
org.apache.nifi.registry.variable.VariableRegistryUpdateStep v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v = v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: org.apache.nifi.registry.variable.VariableRegistryUpdateStep identifyComponentsStep>;
return v;
}
public org.apache.nifi.registry.variable.VariableRegistryUpdateStep getStopProcessorsStep()
{
org.apache.nifi.registry.variable.VariableRegistryUpdateStep v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v = v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: org.apache.nifi.registry.variable.VariableRegistryUpdateStep stopProcessors>;
return v;
}
public org.apache.nifi.registry.variable.VariableRegistryUpdateStep getDisableServicesStep()
{
org.apache.nifi.registry.variable.VariableRegistryUpdateStep v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v = v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: org.apache.nifi.registry.variable.VariableRegistryUpdateStep disableServices>;
return v;
}
public org.apache.nifi.registry.variable.VariableRegistryUpdateStep getApplyUpdatesStep()
{
org.apache.nifi.registry.variable.VariableRegistryUpdateStep v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v = v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: org.apache.nifi.registry.variable.VariableRegistryUpdateStep applyUpdates>;
return v;
}
public org.apache.nifi.registry.variable.VariableRegistryUpdateStep getEnableServicesStep()
{
org.apache.nifi.registry.variable.VariableRegistryUpdateStep v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v = v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: org.apache.nifi.registry.variable.VariableRegistryUpdateStep enableServices>;
return v;
}
public org.apache.nifi.registry.variable.VariableRegistryUpdateStep getStartProcessorsStep()
{
org.apache.nifi.registry.variable.VariableRegistryUpdateStep v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v = v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: org.apache.nifi.registry.variable.VariableRegistryUpdateStep startProcessors>;
return v;
}
public boolean isComplete()
{
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v = v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: boolean complete>;
return v;
}
public void setComplete(boolean)
{
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v := @parameter: boolean;
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: boolean complete> = v;
return;
}
public java.lang.String getFailureReason()
{
java.lang.Object v;
java.util.concurrent.atomic.AtomicReference v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v = v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: java.util.concurrent.atomic.AtomicReference failureReason>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
return v;
}
public void setFailureReason(java.lang.String)
{
java.lang.String v;
java.util.concurrent.atomic.AtomicReference v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v := @parameter: java.lang.String;
v = v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: java.util.concurrent.atomic.AtomicReference failureReason>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
return;
}
public org.apache.nifi.web.api.dto.RevisionDTO getProcessGroupRevision()
{
org.apache.nifi.web.api.dto.RevisionDTO v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v = v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: org.apache.nifi.web.api.dto.RevisionDTO processGroupRevision>;
return v;
}
public void setProcessGroupRevision(org.apache.nifi.web.api.dto.RevisionDTO)
{
org.apache.nifi.web.api.dto.RevisionDTO v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v := @parameter: org.apache.nifi.web.api.dto.RevisionDTO;
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: org.apache.nifi.web.api.dto.RevisionDTO processGroupRevision> = v;
return;
}
public java.util.Map getAffectedComponents()
{
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
java.util.Map v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v = v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: java.util.Map affectedComponents>;
return v;
}
public void cancel()
{
java.util.concurrent.atomic.AtomicReference v;
WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.registry.variable.VariableRegistryUpdateRequest;
v = v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: java.util.concurrent.atomic.AtomicReference failureReason>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: boolean compareAndSet(java.lang.Object,java.lang.Object)>(null, "Update was cancelled");
v.<org.apache.nifi.registry.variable.VariableRegistryUpdateRequest: boolean complete> = 1;
return;
}
}