public class StandardNiFiServiceFacade extends java.lang.Object implements NiFiServiceFacade
Constructor and Description |
---|
StandardNiFiServiceFacade() |
Modifier and Type | Method and Description |
---|---|
ActivateControllerServicesEntity |
activateControllerServices(NiFiUser user,
java.lang.String processGroupId,
ControllerServiceState state,
java.util.Map<java.lang.String,Revision> serviceRevisions)
Enables or disables the controller services with the given IDs & Revisions on behalf of the given user
|
ActivateControllerServicesEntity |
activateControllerServices(java.lang.String processGroupId,
ControllerServiceState state,
java.util.Map<java.lang.String,Revision> serviceRevisions)
Enables or disables the controller services with the given IDs & Revisions on behalf of the currently logged in user
|
void |
authorizeAccess(AuthorizeAccess authorizeAccess)
Authorizes access to the service facade.
|
void |
clearControllerServiceState(java.lang.String controllerServiceId)
Clears the state for the specified controller service.
|
void |
clearProcessorState(java.lang.String processorId)
Clears the state for the specified processor.
|
void |
clearReportingTaskState(java.lang.String reportingTaskId)
Clears the state for the specified reporting task.
|
FlowEntity |
copySnippet(java.lang.String groupId,
java.lang.String snippetId,
java.lang.Double originX,
java.lang.Double originY,
java.lang.String idGenerationSeed)
Creates a new snippet based off the existing snippet.
|
AccessPolicyEntity |
createAccessPolicy(Revision revision,
AccessPolicyDTO accessPolicyDTO)
Creates an access policy.
|
BulletinEntity |
createBulletin(BulletinDTO bulletinDTO,
java.lang.Boolean canRead)
Create a system bulletin
|
ConnectionEntity |
createConnection(Revision revision,
java.lang.String groupId,
ConnectionDTO connectionDTO)
Creates a new Relationship target.
|
ControllerServiceEntity |
createControllerService(Revision revision,
java.lang.String groupId,
ControllerServiceDTO controllerServiceDTO)
Creates a controller service.
|
DropRequestDTO |
createFlowFileDropRequest(java.lang.String connectionId,
java.lang.String dropRequestId)
Creates a new flow file drop request.
|
ListingRequestDTO |
createFlowFileListingRequest(java.lang.String connectionId,
java.lang.String listingRequestId)
Creates a new flow file listing request.
|
FunnelEntity |
createFunnel(Revision revision,
java.lang.String groupId,
FunnelDTO funnelDTO)
Creates a funnel.
|
PortEntity |
createInputPort(Revision revision,
java.lang.String groupId,
PortDTO inputPortDTO)
Creates a new input port.
|
LabelEntity |
createLabel(Revision revision,
java.lang.String groupId,
LabelDTO labelDTO)
Creates a label.
|
PortEntity |
createOutputPort(Revision revision,
java.lang.String groupId,
PortDTO outputPortDTO)
Creates a new output port.
|
ProcessGroupEntity |
createProcessGroup(Revision revision,
java.lang.String parentGroupId,
ProcessGroupDTO processGroupDTO)
Creates a new process group.
|
ProcessorEntity |
createProcessor(Revision revision,
java.lang.String groupId,
ProcessorDTO processorDTO)
Creates a new Processor.
|
RemoteProcessGroupEntity |
createRemoteProcessGroup(Revision revision,
java.lang.String groupId,
RemoteProcessGroupDTO remoteProcessGroupDTO)
Creates a new remote process group.
|
ReportingTaskEntity |
createReportingTask(Revision revision,
ReportingTaskDTO reportingTaskDTO)
Creates a reporting task.
|
SnippetEntity |
createSnippet(SnippetDTO snippetDTO)
Creates a new snippet.
|
TemplateDTO |
createTemplate(java.lang.String name,
java.lang.String description,
java.lang.String snippetId,
java.lang.String groupId,
java.util.Optional<java.lang.String> idGenerationSeed)
Creates a new Template based off the specified snippet.
|
FlowEntity |
createTemplateInstance(java.lang.String groupId,
java.lang.Double originX,
java.lang.Double originY,
java.lang.String templateEncodingVersion,
FlowSnippetDTO requestSnippet,
java.lang.String idGenerationSeed)
Instantiate the corresponding template.
|
UserEntity |
createUser(Revision revision,
UserDTO userDTO)
Creates a user.
|
UserGroupEntity |
createUserGroup(Revision revision,
UserGroupDTO userGroupDTO)
Creates a user group.
|
AccessPolicyEntity |
deleteAccessPolicy(Revision revision,
java.lang.String accessPolicyId)
Deletes the specified access policy.
|
void |
deleteActions(java.util.Date endDate)
Purges all actions up to the specified end date.
|
ConnectionEntity |
deleteConnection(Revision revision,
java.lang.String connectionId)
Deletes the specified relationship target.
|
ControllerServiceEntity |
deleteControllerService(Revision revision,
java.lang.String controllerServiceId)
Deletes the specified label.
|
DropRequestDTO |
deleteFlowFileDropRequest(java.lang.String connectionId,
java.lang.String dropRequestId)
Cancels/removes the specified flow file drop request.
|
ListingRequestDTO |
deleteFlowFileListingRequest(java.lang.String connectionId,
java.lang.String listingRequestId)
Deletes a new flow file listing request.
|
FunnelEntity |
deleteFunnel(Revision revision,
java.lang.String funnelId)
Deletes the specified funnel.
|
PortEntity |
deleteInputPort(Revision revision,
java.lang.String inputPortId)
Deletes the specified input port.
|
LabelEntity |
deleteLabel(Revision revision,
java.lang.String labelId)
Deletes the specified label.
|
void |
deleteLineage(java.lang.String lineageId)
Deletes the lineage with the specified id.
|
void |
deleteNode(java.lang.String nodeId)
Deletes the node.
|
PortEntity |
deleteOutputPort(Revision revision,
java.lang.String outputPortId)
Determines if the output port could be deleted.
|
ProcessGroupEntity |
deleteProcessGroup(Revision revision,
java.lang.String groupId)
Deletes the specified process group.
|
ProcessorEntity |
deleteProcessor(Revision revision,
java.lang.String processorId)
Deletes the specified processor.
|
void |
deleteProvenance(java.lang.String queryId)
Deletes provenance.
|
RemoteProcessGroupEntity |
deleteRemoteProcessGroup(Revision revision,
java.lang.String remoteProcessGroupId)
Deletes the specified remote process group.
|
ReportingTaskEntity |
deleteReportingTask(Revision revision,
java.lang.String reportingTaskId)
Deletes the specified reporting task.
|
SnippetEntity |
deleteSnippet(java.util.Set<Revision> revisions,
java.lang.String snippetId)
Removes the specified snippet.
|
void |
deleteTemplate(java.lang.String id)
Deletes the specified template.
|
UserEntity |
deleteUser(Revision revision,
java.lang.String userId)
Deletes the specified user.
|
UserGroupEntity |
deleteUserGroup(Revision revision,
java.lang.String userGroupId)
Deletes the specified user group.
|
TemplateDTO |
exportTemplate(java.lang.String id)
Gets the template, includes contents, with the specified id.
|
AccessPolicyEntity |
getAccessPolicy(RequestAction requestAction,
java.lang.String resource)
Gets the access policy for the specified action, resource type, and component id.
|
AccessPolicyEntity |
getAccessPolicy(java.lang.String accessPolicyId)
Gets the access policy with the specified ID.
|
ActionEntity |
getAction(java.lang.Integer actionId)
Returns the details for the specified action id.
|
HistoryDTO |
getActions(HistoryQueryDTO historyQueryDto)
Returns actions that meet the specified criteria.
|
java.util.Set<AffectedComponentDTO> |
getActiveComponentsAffectedByVariableRegistryUpdate(VariableRegistryDTO variableRegistryDto)
Determines which components are active and will be affected by updating the given Variable Registry.
|
BulletinBoardDTO |
getBulletinBoard(BulletinQueryDTO query) |
ClusterDTO |
getCluster() |
ComponentHistoryDTO |
getComponentHistory(java.lang.String componentId)
Gets the history for the specified property for the specified component.
|
java.util.Set<AffectedComponentEntity> |
getComponentsAffectedByVariableRegistryUpdate(VariableRegistryDTO variableRegistryDto)
Determines which components will be affected by updating the given Variable Registry.
|
ConnectionEntity |
getConnection(java.lang.String connectionId)
Gets the specified Connection transfer object.
|
java.util.Set<ConnectionEntity> |
getConnections(java.lang.String groupId)
Gets the Connection transfer objects for the specified source processor.
|
ConnectionStatusEntity |
getConnectionStatus(java.lang.String connectionId)
Gets the status of the specified connection.
|
StatusHistoryEntity |
getConnectionStatusHistory(java.lang.String connectionId)
Gets the status history of the specified connection.
|
DownloadableContent |
getContent(java.lang.Long eventId,
java.lang.String uri,
ContentDirection contentDirection)
Gets the content for the specified claim.
|
DownloadableContent |
getContent(java.lang.String connectionId,
java.lang.String flowFileUuid,
java.lang.String uri)
Gets the content for the specified flowfile in the specified connection.
|
ControllerBulletinsEntity |
getControllerBulletins()
Gets the controller level bulletins.
|
ControllerConfigurationEntity |
getControllerConfiguration()
Gets the configuration for this controller.
|
ControllerServiceEntity |
getControllerService(java.lang.String controllerServiceId)
Gets the specified controller service.
|
PropertyDescriptorDTO |
getControllerServicePropertyDescriptor(java.lang.String id,
java.lang.String property)
Get the descriptor for the specified property of the specified controller service.
|
ControllerServiceReferencingComponentsEntity |
getControllerServiceReferencingComponents(java.lang.String controllerServiceId)
Gets the references for specified controller service.
|
java.util.Set<ControllerServiceEntity> |
getControllerServices(java.lang.String groupId,
boolean includeAncestorGroups,
boolean includeDescendantGroups)
Gets all controller services that belong to the given group and its parent/ancestor groups
|
java.util.Set<ControllerServiceEntity> |
getControllerServices(java.lang.String groupId,
boolean includeAncestorGroups,
boolean includeDescendantGroups,
NiFiUser user)
Gets all controller services that belong to the given group and its parent/ancestor groups
|
ComponentStateDTO |
getControllerServiceState(java.lang.String controllerServiceId)
Gets the state for the specified controller service.
|
java.util.Set<DocumentedTypeDTO> |
getControllerServiceTypes(java.lang.String serviceType,
java.lang.String serviceBundleGroup,
java.lang.String serviceBundleArtifact,
java.lang.String serviceBundleVersion,
java.lang.String bundleGroup,
java.lang.String bundleArtifact,
java.lang.String type)
Returns the list of controller service types.
|
ControllerStatusDTO |
getControllerStatus()
Returns the controller status.
|
CountersDTO |
getCounters()
Returns the counters.
|
CurrentUserEntity |
getCurrentUser() |
FlowConfigurationEntity |
getFlowConfiguration()
Gets the configuration for the flow.
|
FlowFileDTO |
getFlowFile(java.lang.String connectionId,
java.lang.String flowFileUuid)
Gets the specified flowfile from the specified connection.
|
DropRequestDTO |
getFlowFileDropRequest(java.lang.String connectionId,
java.lang.String dropRequestId)
Gets the specified flow file drop request.
|
ListingRequestDTO |
getFlowFileListingRequest(java.lang.String connectionId,
java.lang.String listingRequestId)
Gets a new flow file listing request.
|
FunnelEntity |
getFunnel(java.lang.String funnelId)
Gets the specified funnel.
|
java.util.Set<FunnelEntity> |
getFunnels(java.lang.String groupId)
Gets all of the funnels.
|
PortEntity |
getInputPort(java.lang.String inputPortId)
Gets an input port.
|
java.util.Set<PortEntity> |
getInputPorts(java.lang.String groupId)
Gets all input ports in a given group.
|
PortStatusEntity |
getInputPortStatus(java.lang.String inputPortId)
Gets the input port status.
|
LabelEntity |
getLabel(java.lang.String labelId)
Gets the specified label.
|
java.util.Set<LabelEntity> |
getLabels(java.lang.String groupId)
Gets all of the labels.
|
LineageDTO |
getLineage(java.lang.String lineageId)
Gets the lineage with the specified id.
|
NodeDTO |
getNode(java.lang.String nodeId)
Returns the contents of the node.
|
java.lang.String |
getNodeId() |
PortEntity |
getOutputPort(java.lang.String outputPortId)
Gets an output port.
|
java.util.Set<PortEntity> |
getOutputPorts(java.lang.String groupId)
Gets all output ports in a given group.
|
PortStatusEntity |
getOutputPortStatus(java.lang.String outputPortId)
Gets the output port status.
|
ProcessGroupEntity |
getProcessGroup(java.lang.String groupId)
Returns the process group.
|
ProcessGroupFlowEntity |
getProcessGroupFlow(java.lang.String groupId)
Returns the flow.
|
java.util.Set<ProcessGroupEntity> |
getProcessGroups(java.lang.String parentGroupId)
Gets all process groups in the specified parent group.
|
ProcessGroupStatusEntity |
getProcessGroupStatus(java.lang.String groupId,
boolean recursive)
Returns the process group status.
|
StatusHistoryEntity |
getProcessGroupStatusHistory(java.lang.String groupId)
Gets the process group status history.
|
ProcessorEntity |
getProcessor(java.lang.String id)
Gets the Processor transfer object for the specified id.
|
PropertyDescriptorDTO |
getProcessorPropertyDescriptor(java.lang.String id,
java.lang.String property)
Get the descriptor for the specified property of the specified processor.
|
java.util.Set<ProcessorEntity> |
getProcessors(java.lang.String groupId,
boolean includeDescendants)
Gets all the Processor transfer objects for this controller.
|
ComponentStateDTO |
getProcessorState(java.lang.String processorId)
Gets the state for the specified processor.
|
ProcessorStatusEntity |
getProcessorStatus(java.lang.String id)
Gets the processor status.
|
StatusHistoryEntity |
getProcessorStatusHistory(java.lang.String id)
Gets the processor status history.
|
java.util.Set<DocumentedTypeDTO> |
getProcessorTypes(java.lang.String bundleGroup,
java.lang.String bundleArtifact,
java.lang.String type)
Returns the list of processor types.
|
ProvenanceDTO |
getProvenance(java.lang.String queryId,
java.lang.Boolean summarize,
java.lang.Boolean incrementalResults)
Retrieves provenance.
|
ProvenanceEventDTO |
getProvenanceEvent(java.lang.Long id)
Gets the provenance event with the specified id.
|
ProvenanceOptionsDTO |
getProvenanceSearchOptions()
Returns the available options for searching provenance.
|
RemoteProcessGroupEntity |
getRemoteProcessGroup(java.lang.String remoteProcessGroupId)
Gets a remote process group.
|
java.util.Set<RemoteProcessGroupEntity> |
getRemoteProcessGroups(java.lang.String groupId)
Gets all remote process groups in the a given parent group.
|
RemoteProcessGroupStatusEntity |
getRemoteProcessGroupStatus(java.lang.String id)
Gets the remote process group status.
|
StatusHistoryEntity |
getRemoteProcessGroupStatusHistory(java.lang.String id)
Gets the remote process group status history.
|
ReportingTaskEntity |
getReportingTask(java.lang.String reportingTaskId)
Gets the specified reporting task.
|
PropertyDescriptorDTO |
getReportingTaskPropertyDescriptor(java.lang.String id,
java.lang.String property)
Get the descriptor for the specified property of the specified reporting task.
|
java.util.Set<ReportingTaskEntity> |
getReportingTasks()
Gets all reporting tasks.
|
ComponentStateDTO |
getReportingTaskState(java.lang.String reportingTaskId)
Gets the state for the specified reporting task.
|
java.util.Set<DocumentedTypeDTO> |
getReportingTaskTypes(java.lang.String bundleGroup,
java.lang.String bundleArtifact,
java.lang.String type)
Returns the list of reporting task types.
|
java.util.List<ResourceDTO> |
getResources() |
java.util.Set<Revision> |
getRevisionsFromGroup(java.lang.String groupId,
java.util.function.Function<ProcessGroup,java.util.Set<java.lang.String>> getComponents)
Gets the current revisions for the components based on the specified function.
|
java.util.Set<Revision> |
getRevisionsFromSnippet(java.lang.String snippetId)
Gets the revisions from the specified snippet.
|
ControllerDTO |
getSiteToSiteDetails() |
SystemDiagnosticsDTO |
getSystemDiagnostics() |
TemplateDTO |
getTemplate(java.lang.String id)
Gets the template with the specified id.
|
java.util.Set<TemplateEntity> |
getTemplates()
Gets all templates.
|
UserEntity |
getUser(java.lang.String userId)
Gets the user with the specified ID.
|
UserGroupEntity |
getUserGroup(java.lang.String userGroupId)
Gets the user group with the specified ID.
|
java.util.Set<UserGroupEntity> |
getUserGroups()
Gets all user groups.
|
java.util.Set<UserEntity> |
getUsers()
Gets all the users.
|
VariableRegistryEntity |
getVariableRegistry(java.lang.String groupId,
boolean includeAncestorGroups)
Returns the Variable Registry for the Process Group with the given ID
|
java.util.Set<DocumentedTypeDTO> |
getWorkQueuePrioritizerTypes()
Returns the list of prioritizer types.
|
TemplateDTO |
importTemplate(TemplateDTO templateDTO,
java.lang.String groupId,
java.util.Optional<java.lang.String> idGenerationSeed)
Imports the specified Template.
|
boolean |
isClustered() |
VariableRegistryEntity |
populateAffectedComponents(VariableRegistryDTO variableRegistryDto)
Returns a Variable Registry that includes the variables in the given DTO but has the affected components populated
|
ScheduleComponentsEntity |
scheduleComponents(NiFiUser user,
java.lang.String processGroupId,
ScheduledState state,
java.util.Map<java.lang.String,Revision> componentRevisions)
Schedules all applicable components under the specified ProcessGroup on behalf of the given user.
|
ScheduleComponentsEntity |
scheduleComponents(java.lang.String processGroupId,
ScheduledState state,
java.util.Map<java.lang.String,Revision> componentRevisions)
Schedules all applicable components under the specified ProcessGroup on behalf of the currently logged in user.
|
SearchResultsDTO |
searchController(java.lang.String query)
Searches the controller for the specified query string.
|
void |
setAccessPolicyDAO(AccessPolicyDAO accessPolicyDAO) |
void |
setAuditService(AuditService auditService) |
void |
setAuthorizableLookup(AuthorizableLookup authorizableLookup) |
void |
setAuthorizer(Authorizer authorizer) |
void |
setBulletinRepository(BulletinRepository bulletinRepository) |
void |
setClusterCoordinator(ClusterCoordinator coordinator) |
void |
setConnectionDAO(ConnectionDAO connectionDAO) |
void |
setControllerFacade(ControllerFacade controllerFacade) |
void |
setControllerServiceDAO(ControllerServiceDAO controllerServiceDAO) |
void |
setDtoFactory(DtoFactory dtoFactory) |
void |
setEntityFactory(EntityFactory entityFactory) |
void |
setFunnelDAO(FunnelDAO funnelDAO) |
void |
setHeartbeatMonitor(HeartbeatMonitor heartbeatMonitor) |
void |
setInputPortDAO(PortDAO inputPortDAO) |
void |
setLabelDAO(LabelDAO labelDAO) |
void |
setLeaderElectionManager(LeaderElectionManager leaderElectionManager) |
void |
setOutputPortDAO(PortDAO outputPortDAO) |
void |
setProcessGroupDAO(ProcessGroupDAO processGroupDAO) |
void |
setProcessorDAO(ProcessorDAO processorDAO) |
void |
setProperties(NiFiProperties properties) |
void |
setRemoteProcessGroupDAO(RemoteProcessGroupDAO remoteProcessGroupDAO) |
void |
setReportingTaskDAO(ReportingTaskDAO reportingTaskDAO) |
void |
setRevisionManager(RevisionManager revisionManager) |
void |
setSnippetDAO(SnippetDAO snippetDAO) |
void |
setSnippetUtils(SnippetUtils snippetUtils) |
void |
setTemplateDAO(TemplateDAO templateDAO) |
void |
setUserDAO(UserDAO userDAO) |
void |
setUserGroupDAO(UserGroupDAO userGroupDAO) |
LineageDTO |
submitLineage(LineageDTO lineage)
Submits a lineage request.
|
ProvenanceDTO |
submitProvenance(ProvenanceDTO query)
Submits a provenance request.
|
ProvenanceEventDTO |
submitReplay(java.lang.Long eventId)
Submits a new replay request.
|
AccessPolicyEntity |
updateAccessPolicy(Revision revision,
AccessPolicyDTO accessPolicyDTO)
Updates the specified access policy.
|
ConnectionEntity |
updateConnection(Revision revision,
ConnectionDTO connectionDTO)
Updates the specified Relationship target.
|
ControllerConfigurationEntity |
updateControllerConfiguration(Revision revision,
ControllerConfigurationDTO controllerConfigurationDTO)
Updates the configuration for this controller.
|
ControllerServiceEntity |
updateControllerService(Revision revision,
ControllerServiceDTO controllerServiceDTO)
Updates the specified controller service.
|
ControllerServiceReferencingComponentsEntity |
updateControllerServiceReferencingComponents(java.util.Map<java.lang.String,Revision> referenceRevisions,
java.lang.String controllerServiceId,
ScheduledState scheduledState,
ControllerServiceState controllerServiceState)
Updates the referencing components for the specified controller service.
|
CounterDTO |
updateCounter(java.lang.String counterId)
Updates the specified counter by setting its value to 0.
|
FunnelEntity |
updateFunnel(Revision revision,
FunnelDTO funnelDTO)
Updates the specified funnel.
|
PortEntity |
updateInputPort(Revision revision,
PortDTO inputPortDTO)
Updates the specified input port.
|
LabelEntity |
updateLabel(Revision revision,
LabelDTO labelDTO)
Updates the specified label.
|
NodeDTO |
updateNode(NodeDTO nodeDTO)
Updates the contents of the node.
|
PortEntity |
updateOutputPort(Revision revision,
PortDTO outputPortDTO)
Updates the specified output port.
|
ProcessGroupEntity |
updateProcessGroup(Revision revision,
ProcessGroupDTO processGroupDTO)
Updates the specified process group.
|
ProcessorEntity |
updateProcessor(Revision revision,
ProcessorDTO processorDTO)
Updates the specified Processor.
|
RemoteProcessGroupEntity |
updateRemoteProcessGroup(Revision revision,
RemoteProcessGroupDTO remoteProcessGroupDTO)
Updates the specified remote process group.
|
RemoteProcessGroupPortEntity |
updateRemoteProcessGroupInputPort(Revision revision,
java.lang.String remoteProcessGroupId,
RemoteProcessGroupPortDTO remoteProcessGroupPortDTO)
Updates the specified remote process groups input port.
|
RemoteProcessGroupPortEntity |
updateRemoteProcessGroupOutputPort(Revision revision,
java.lang.String remoteProcessGroupId,
RemoteProcessGroupPortDTO remoteProcessGroupPortDTO)
Updates the specified remote process groups output port.
|
ReportingTaskEntity |
updateReportingTask(Revision revision,
ReportingTaskDTO reportingTaskDTO)
Updates the specified reporting task.
|
SnippetEntity |
updateSnippet(java.util.Set<Revision> revisions,
SnippetDTO snippetDto)
If group id is specified, moves the specified snippet to the specified group.
|
UserEntity |
updateUser(Revision revision,
UserDTO userDTO)
Updates the specified user.
|
UserGroupEntity |
updateUserGroup(Revision revision,
UserGroupDTO userGroupDTO)
Updates the specified user group.
|
VariableRegistryEntity |
updateVariableRegistry(NiFiUser user,
Revision revision,
VariableRegistryDTO variableRegistryDto)
Updates the variable registry on behalf of the given user
|
VariableRegistryEntity |
updateVariableRegistry(Revision revision,
VariableRegistryDTO variableRegistryDto)
Updates the variable registry on behalf of the user currently logged in
|
void |
verifyActivateControllerServices(java.lang.String groupId,
ControllerServiceState state,
java.util.Set<java.lang.String> serviceIds)
Verifies the controller services with the given ID's can be enabled or disabled
|
void |
verifyCanAddTemplate(java.lang.String groupId,
java.lang.String name)
Verifies a template with the specified name can be created.
|
void |
verifyCanClearControllerServiceState(java.lang.String controllerServiceId)
Verifies the controller service state could be cleared.
|
void |
verifyCanClearProcessorState(java.lang.String processorId)
Verifies the processor state could be cleared.
|
void |
verifyCanClearReportingTaskState(java.lang.String reportingTaskId)
Verifies the reporting task state could be cleared.
|
void |
verifyComponentTypes(FlowSnippetDTO snippet)
Verifies the types of components in a template.
|
void |
verifyCreateConnection(java.lang.String groupId,
ConnectionDTO connectionDTO)
Determines if this connection can be created.
|
void |
verifyCreateControllerService(ControllerServiceDTO controllerServiceDTO)
Verifies the specified controller service can be created.
|
void |
verifyCreateProcessor(ProcessorDTO processorDTO)
Verifies the specified processor can be created.
|
void |
verifyCreateReportingTask(ReportingTaskDTO reportingTaskDTO)
Verifies the specified reporting task can be created.
|
void |
verifyDeleteConnection(java.lang.String connectionId)
Determines if this connection can be removed.
|
void |
verifyDeleteControllerService(java.lang.String controllerServiceId)
Verifies the specified controller service can be removed.
|
void |
verifyDeleteFunnel(java.lang.String funnelId)
Verifies the specified funnel can be deleted.
|
void |
verifyDeleteInputPort(java.lang.String inputPortId)
Determines if the input port could be deleted.
|
void |
verifyDeleteOutputPort(java.lang.String outputPortId)
Determines if the output port could be deleted.
|
void |
verifyDeleteProcessGroup(java.lang.String groupId)
Verifies the specified process group can be removed.
|
void |
verifyDeleteProcessor(java.lang.String processorId)
Verifies the specified processor can be removed.
|
void |
verifyDeleteRemoteProcessGroup(java.lang.String remoteProcessGroupId)
Verifies the remote process group can be deleted.
|
void |
verifyDeleteReportingTask(java.lang.String reportingTaskId)
Verifies the specified reporting task can be removed.
|
void |
verifyDeleteSnippet(java.lang.String snippetId,
java.util.Set<java.lang.String> affectedComponentIds)
Determines if this snippet can be removed.
|
void |
verifyListQueue(java.lang.String connectionId)
Determines if this connection can be listed.
|
void |
verifyRevision(Revision revision,
NiFiUser user)
Claims the specified revision for the specified user.
|
void |
verifyRevisions(java.util.Set<Revision> revisions,
NiFiUser user)
Claims the specified revisions for the specified user.
|
void |
verifyScheduleComponents(java.lang.String groupId,
ScheduledState state,
java.util.Set<java.lang.String> componentIds)
Verifies the contents of the specified process group can be scheduled or unscheduled.
|
void |
verifyUpdateConnection(ConnectionDTO connectionDTO)
Determines if this connection can be updated.
|
void |
verifyUpdateControllerService(ControllerServiceDTO controllerServiceDTO)
Verifies the specified controller service can be updated.
|
void |
verifyUpdateControllerServiceReferencingComponents(java.lang.String controllerServiceId,
ScheduledState scheduledState,
ControllerServiceState controllerServiceState)
Verifies the referencing components of the specified controller service can be updated.
|
void |
verifyUpdateInputPort(PortDTO inputPortDTO)
Determines if the input port could be updated.
|
void |
verifyUpdateOutputPort(PortDTO outputPortDTO)
Determines if the output port could be updated.
|
void |
verifyUpdateProcessGroup(ProcessGroupDTO processGroupDTO)
Verifies that the Process Group identified by the given DTO can be updated in the manner appropriate according
to the DTO
|
void |
verifyUpdateProcessor(ProcessorDTO processorDTO)
Verifies the specified processor can be updated.
|
void |
verifyUpdateRemoteProcessGroup(RemoteProcessGroupDTO remoteProcessGroupDTO)
Verifies the specified remote process group can be updated.
|
void |
verifyUpdateRemoteProcessGroupInputPort(java.lang.String remoteProcessGroupId,
RemoteProcessGroupPortDTO remoteProcessGroupPortDTO)
Verifies the specified remote process group can update the specified remote input port.
|
void |
verifyUpdateRemoteProcessGroupOutputPort(java.lang.String remoteProcessGroupId,
RemoteProcessGroupPortDTO remoteProcessGroupPortDTO)
Verifies the specified remote process group can update the specified remote output port.
|
void |
verifyUpdateReportingTask(ReportingTaskDTO reportingTaskDTO)
Verifies the specified reporting task can be updated.
|
void |
verifyUpdateSnippet(SnippetDTO snippetDto,
java.util.Set<java.lang.String> affectedComponentIds)
Determines if this snippet can be updated.
|
public void authorizeAccess(AuthorizeAccess authorizeAccess)
NiFiServiceFacade
authorizeAccess
in interface NiFiServiceFacade
authorizeAccess
- authorize access callbackpublic void verifyRevision(Revision revision, NiFiUser user)
NiFiServiceFacade
verifyRevision
in interface NiFiServiceFacade
revision
- revisionuser
- userpublic void verifyRevisions(java.util.Set<Revision> revisions, NiFiUser user)
NiFiServiceFacade
verifyRevisions
in interface NiFiServiceFacade
revisions
- revisionsuser
- userpublic java.util.Set<Revision> getRevisionsFromGroup(java.lang.String groupId, java.util.function.Function<ProcessGroup,java.util.Set<java.lang.String>> getComponents)
NiFiServiceFacade
getRevisionsFromGroup
in interface NiFiServiceFacade
groupId
- groupgetComponents
- callbackpublic java.util.Set<Revision> getRevisionsFromSnippet(java.lang.String snippetId)
NiFiServiceFacade
getRevisionsFromSnippet
in interface NiFiServiceFacade
snippetId
- snippetpublic void verifyListQueue(java.lang.String connectionId)
NiFiServiceFacade
verifyListQueue
in interface NiFiServiceFacade
connectionId
- connectionpublic void verifyCreateConnection(java.lang.String groupId, ConnectionDTO connectionDTO)
NiFiServiceFacade
verifyCreateConnection
in interface NiFiServiceFacade
groupId
- groupconnectionDTO
- connectionpublic void verifyUpdateConnection(ConnectionDTO connectionDTO)
NiFiServiceFacade
verifyUpdateConnection
in interface NiFiServiceFacade
connectionDTO
- connectionpublic void verifyDeleteConnection(java.lang.String connectionId)
NiFiServiceFacade
verifyDeleteConnection
in interface NiFiServiceFacade
connectionId
- connectionpublic void verifyDeleteFunnel(java.lang.String funnelId)
NiFiServiceFacade
verifyDeleteFunnel
in interface NiFiServiceFacade
funnelId
- funnelpublic void verifyUpdateInputPort(PortDTO inputPortDTO)
NiFiServiceFacade
verifyUpdateInputPort
in interface NiFiServiceFacade
inputPortDTO
- The id of the input portpublic void verifyDeleteInputPort(java.lang.String inputPortId)
NiFiServiceFacade
verifyDeleteInputPort
in interface NiFiServiceFacade
inputPortId
- The id of the input portpublic void verifyUpdateOutputPort(PortDTO outputPortDTO)
NiFiServiceFacade
verifyUpdateOutputPort
in interface NiFiServiceFacade
outputPortDTO
- The id of the output portpublic void verifyDeleteOutputPort(java.lang.String outputPortId)
NiFiServiceFacade
verifyDeleteOutputPort
in interface NiFiServiceFacade
outputPortId
- The id of the output portpublic void verifyCreateProcessor(ProcessorDTO processorDTO)
NiFiServiceFacade
verifyCreateProcessor
in interface NiFiServiceFacade
processorDTO
- processorpublic void verifyUpdateProcessor(ProcessorDTO processorDTO)
NiFiServiceFacade
verifyUpdateProcessor
in interface NiFiServiceFacade
processorDTO
- processorpublic void verifyDeleteProcessor(java.lang.String processorId)
NiFiServiceFacade
verifyDeleteProcessor
in interface NiFiServiceFacade
processorId
- processorpublic void verifyScheduleComponents(java.lang.String groupId, ScheduledState state, java.util.Set<java.lang.String> componentIds)
NiFiServiceFacade
verifyScheduleComponents
in interface NiFiServiceFacade
groupId
- The ProcessGroup idstate
- scheduled statecomponentIds
- the componentspublic void verifyActivateControllerServices(java.lang.String groupId, ControllerServiceState state, java.util.Set<java.lang.String> serviceIds)
NiFiServiceFacade
verifyActivateControllerServices
in interface NiFiServiceFacade
groupId
- the ID of the process groupstate
- the stateserviceIds
- the id's of the servicespublic void verifyDeleteProcessGroup(java.lang.String groupId)
NiFiServiceFacade
verifyDeleteProcessGroup
in interface NiFiServiceFacade
groupId
- The id of the process grouppublic void verifyUpdateRemoteProcessGroup(RemoteProcessGroupDTO remoteProcessGroupDTO)
NiFiServiceFacade
verifyUpdateRemoteProcessGroup
in interface NiFiServiceFacade
remoteProcessGroupDTO
- The RemoteProcessGroupDTOpublic void verifyUpdateRemoteProcessGroupInputPort(java.lang.String remoteProcessGroupId, RemoteProcessGroupPortDTO remoteProcessGroupPortDTO)
NiFiServiceFacade
verifyUpdateRemoteProcessGroupInputPort
in interface NiFiServiceFacade
remoteProcessGroupId
- The id of the remote process groupremoteProcessGroupPortDTO
- The RemoteProcessGroupPortDTOpublic void verifyUpdateRemoteProcessGroupOutputPort(java.lang.String remoteProcessGroupId, RemoteProcessGroupPortDTO remoteProcessGroupPortDTO)
NiFiServiceFacade
verifyUpdateRemoteProcessGroupOutputPort
in interface NiFiServiceFacade
remoteProcessGroupId
- The id of the remote process groupremoteProcessGroupPortDTO
- The RemoteProcessGroupPortDTOpublic void verifyDeleteRemoteProcessGroup(java.lang.String remoteProcessGroupId)
NiFiServiceFacade
verifyDeleteRemoteProcessGroup
in interface NiFiServiceFacade
remoteProcessGroupId
- The id of the remote process grouppublic void verifyCreateControllerService(ControllerServiceDTO controllerServiceDTO)
NiFiServiceFacade
verifyCreateControllerService
in interface NiFiServiceFacade
controllerServiceDTO
- servicepublic void verifyUpdateControllerService(ControllerServiceDTO controllerServiceDTO)
NiFiServiceFacade
verifyUpdateControllerService
in interface NiFiServiceFacade
controllerServiceDTO
- servicepublic void verifyUpdateControllerServiceReferencingComponents(java.lang.String controllerServiceId, ScheduledState scheduledState, ControllerServiceState controllerServiceState)
NiFiServiceFacade
verifyUpdateControllerServiceReferencingComponents
in interface NiFiServiceFacade
controllerServiceId
- idscheduledState
- schedule statecontrollerServiceState
- service statepublic void verifyDeleteControllerService(java.lang.String controllerServiceId)
NiFiServiceFacade
verifyDeleteControllerService
in interface NiFiServiceFacade
controllerServiceId
- idpublic void verifyCreateReportingTask(ReportingTaskDTO reportingTaskDTO)
NiFiServiceFacade
verifyCreateReportingTask
in interface NiFiServiceFacade
reportingTaskDTO
- taskpublic void verifyUpdateReportingTask(ReportingTaskDTO reportingTaskDTO)
NiFiServiceFacade
verifyUpdateReportingTask
in interface NiFiServiceFacade
reportingTaskDTO
- taskpublic void verifyDeleteReportingTask(java.lang.String reportingTaskId)
NiFiServiceFacade
verifyDeleteReportingTask
in interface NiFiServiceFacade
reportingTaskId
- idpublic AccessPolicyEntity updateAccessPolicy(Revision revision, AccessPolicyDTO accessPolicyDTO)
NiFiServiceFacade
updateAccessPolicy
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionaccessPolicyDTO
- The access policy DTOpublic UserEntity updateUser(Revision revision, UserDTO userDTO)
NiFiServiceFacade
updateUser
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionuserDTO
- The user DTOpublic UserGroupEntity updateUserGroup(Revision revision, UserGroupDTO userGroupDTO)
NiFiServiceFacade
updateUserGroup
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionuserGroupDTO
- The user group DTOpublic ConnectionEntity updateConnection(Revision revision, ConnectionDTO connectionDTO)
NiFiServiceFacade
updateConnection
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionconnectionDTO
- The Connection DTOpublic ProcessorEntity updateProcessor(Revision revision, ProcessorDTO processorDTO)
NiFiServiceFacade
updateProcessor
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionprocessorDTO
- The processorDTOpublic LabelEntity updateLabel(Revision revision, LabelDTO labelDTO)
NiFiServiceFacade
updateLabel
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionlabelDTO
- The label DTOpublic FunnelEntity updateFunnel(Revision revision, FunnelDTO funnelDTO)
NiFiServiceFacade
updateFunnel
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionfunnelDTO
- The funnel DTOpublic void verifyUpdateSnippet(SnippetDTO snippetDto, java.util.Set<java.lang.String> affectedComponentIds)
NiFiServiceFacade
verifyUpdateSnippet
in interface NiFiServiceFacade
snippetDto
- snippetpublic SnippetEntity updateSnippet(java.util.Set<Revision> revisions, SnippetDTO snippetDto)
NiFiServiceFacade
updateSnippet
in interface NiFiServiceFacade
revisions
- revisionssnippetDto
- snippetpublic PortEntity updateInputPort(Revision revision, PortDTO inputPortDTO)
NiFiServiceFacade
updateInputPort
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisioninputPortDTO
- The input PortDTOpublic PortEntity updateOutputPort(Revision revision, PortDTO outputPortDTO)
NiFiServiceFacade
updateOutputPort
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionoutputPortDTO
- The output PortDTOpublic RemoteProcessGroupEntity updateRemoteProcessGroup(Revision revision, RemoteProcessGroupDTO remoteProcessGroupDTO)
NiFiServiceFacade
updateRemoteProcessGroup
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionremoteProcessGroupDTO
- The RemoteProcessGroupDTOpublic RemoteProcessGroupPortEntity updateRemoteProcessGroupInputPort(Revision revision, java.lang.String remoteProcessGroupId, RemoteProcessGroupPortDTO remoteProcessGroupPortDTO)
NiFiServiceFacade
updateRemoteProcessGroupInputPort
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionremoteProcessGroupId
- The id of the remote process groupremoteProcessGroupPortDTO
- The RemoteProcessGroupPortDTOpublic RemoteProcessGroupPortEntity updateRemoteProcessGroupOutputPort(Revision revision, java.lang.String remoteProcessGroupId, RemoteProcessGroupPortDTO remoteProcessGroupPortDTO)
NiFiServiceFacade
updateRemoteProcessGroupOutputPort
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionremoteProcessGroupId
- The id of the remote process groupremoteProcessGroupPortDTO
- The RemoteProcessGroupPortDTOpublic java.util.Set<AffectedComponentDTO> getActiveComponentsAffectedByVariableRegistryUpdate(VariableRegistryDTO variableRegistryDto)
NiFiServiceFacade
getActiveComponentsAffectedByVariableRegistryUpdate
in interface NiFiServiceFacade
variableRegistryDto
- the variable registrypublic java.util.Set<AffectedComponentEntity> getComponentsAffectedByVariableRegistryUpdate(VariableRegistryDTO variableRegistryDto)
NiFiServiceFacade
getComponentsAffectedByVariableRegistryUpdate
in interface NiFiServiceFacade
variableRegistryDto
- the variable registrypublic VariableRegistryEntity updateVariableRegistry(Revision revision, VariableRegistryDTO variableRegistryDto)
NiFiServiceFacade
updateVariableRegistry
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionvariableRegistryDto
- the Variable Registrypublic VariableRegistryEntity updateVariableRegistry(NiFiUser user, Revision revision, VariableRegistryDTO variableRegistryDto)
NiFiServiceFacade
updateVariableRegistry
in interface NiFiServiceFacade
user
- the user who performed the actionrevision
- Revision to compare with current base revisionvariableRegistryDto
- the Variable Registrypublic ProcessGroupEntity updateProcessGroup(Revision revision, ProcessGroupDTO processGroupDTO)
NiFiServiceFacade
updateProcessGroup
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionprocessGroupDTO
- The ProcessGroupDTOpublic void verifyUpdateProcessGroup(ProcessGroupDTO processGroupDTO)
NiFiServiceFacade
verifyUpdateProcessGroup
in interface NiFiServiceFacade
processGroupDTO
- the DTO that indicates the updates to occurpublic ScheduleComponentsEntity scheduleComponents(java.lang.String processGroupId, ScheduledState state, java.util.Map<java.lang.String,Revision> componentRevisions)
NiFiServiceFacade
scheduleComponents
in interface NiFiServiceFacade
processGroupId
- The ProcessGroup idstate
- schedule statecomponentRevisions
- components and their revisionpublic ScheduleComponentsEntity scheduleComponents(NiFiUser user, java.lang.String processGroupId, ScheduledState state, java.util.Map<java.lang.String,Revision> componentRevisions)
NiFiServiceFacade
scheduleComponents
in interface NiFiServiceFacade
user
- the user performing the actionprocessGroupId
- The ProcessGroup idstate
- schedule statecomponentRevisions
- components and their revisionpublic ActivateControllerServicesEntity activateControllerServices(java.lang.String processGroupId, ControllerServiceState state, java.util.Map<java.lang.String,Revision> serviceRevisions)
NiFiServiceFacade
activateControllerServices
in interface NiFiServiceFacade
processGroupId
- the ID of the process groupstate
- the desired state of the servicesserviceRevisions
- a mapping of Controller Service ID to current Revisionpublic ActivateControllerServicesEntity activateControllerServices(NiFiUser user, java.lang.String processGroupId, ControllerServiceState state, java.util.Map<java.lang.String,Revision> serviceRevisions)
NiFiServiceFacade
activateControllerServices
in interface NiFiServiceFacade
user
- the user performing the actionprocessGroupId
- the ID of the process groupstate
- the desired state of the servicesserviceRevisions
- a mapping of Controller Service ID to current Revisionpublic ControllerConfigurationEntity updateControllerConfiguration(Revision revision, ControllerConfigurationDTO controllerConfigurationDTO)
NiFiServiceFacade
updateControllerConfiguration
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisioncontrollerConfigurationDTO
- Controller configuration DTOpublic NodeDTO updateNode(NodeDTO nodeDTO)
NiFiServiceFacade
updateNode
in interface NiFiServiceFacade
nodeDTO
- a node transfer objectpublic CounterDTO updateCounter(java.lang.String counterId)
NiFiServiceFacade
updateCounter
in interface NiFiServiceFacade
counterId
- idpublic void verifyCanClearProcessorState(java.lang.String processorId)
NiFiServiceFacade
verifyCanClearProcessorState
in interface NiFiServiceFacade
processorId
- the processor idpublic void clearProcessorState(java.lang.String processorId)
NiFiServiceFacade
clearProcessorState
in interface NiFiServiceFacade
processorId
- the processor idpublic void verifyCanClearControllerServiceState(java.lang.String controllerServiceId)
NiFiServiceFacade
verifyCanClearControllerServiceState
in interface NiFiServiceFacade
controllerServiceId
- the controller service idpublic void clearControllerServiceState(java.lang.String controllerServiceId)
NiFiServiceFacade
clearControllerServiceState
in interface NiFiServiceFacade
controllerServiceId
- the controller service idpublic void verifyCanClearReportingTaskState(java.lang.String reportingTaskId)
NiFiServiceFacade
verifyCanClearReportingTaskState
in interface NiFiServiceFacade
reportingTaskId
- the reporting task idpublic void clearReportingTaskState(java.lang.String reportingTaskId)
NiFiServiceFacade
clearReportingTaskState
in interface NiFiServiceFacade
reportingTaskId
- the reporting task idpublic ConnectionEntity deleteConnection(Revision revision, java.lang.String connectionId)
NiFiServiceFacade
deleteConnection
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionconnectionId
- The ID of the connectionpublic DropRequestDTO deleteFlowFileDropRequest(java.lang.String connectionId, java.lang.String dropRequestId)
NiFiServiceFacade
deleteFlowFileDropRequest
in interface NiFiServiceFacade
connectionId
- The ID of the connectiondropRequestId
- The flow file drop requestpublic ListingRequestDTO deleteFlowFileListingRequest(java.lang.String connectionId, java.lang.String listingRequestId)
NiFiServiceFacade
deleteFlowFileListingRequest
in interface NiFiServiceFacade
connectionId
- The ID of the connectionlistingRequestId
- The ID of the listing requestpublic ProcessorEntity deleteProcessor(Revision revision, java.lang.String processorId)
NiFiServiceFacade
deleteProcessor
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionprocessorId
- The processor id to deletepublic LabelEntity deleteLabel(Revision revision, java.lang.String labelId)
NiFiServiceFacade
deleteLabel
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionlabelId
- The label idpublic UserEntity deleteUser(Revision revision, java.lang.String userId)
NiFiServiceFacade
deleteUser
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionuserId
- The user IDpublic UserGroupEntity deleteUserGroup(Revision revision, java.lang.String userGroupId)
NiFiServiceFacade
deleteUserGroup
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionuserGroupId
- The user group IDpublic AccessPolicyEntity deleteAccessPolicy(Revision revision, java.lang.String accessPolicyId)
NiFiServiceFacade
deleteAccessPolicy
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionaccessPolicyId
- The access policy IDpublic FunnelEntity deleteFunnel(Revision revision, java.lang.String funnelId)
NiFiServiceFacade
deleteFunnel
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionfunnelId
- The funnel idpublic void verifyDeleteSnippet(java.lang.String snippetId, java.util.Set<java.lang.String> affectedComponentIds)
NiFiServiceFacade
verifyDeleteSnippet
in interface NiFiServiceFacade
snippetId
- idaffectedComponentIds
- affected componentspublic SnippetEntity deleteSnippet(java.util.Set<Revision> revisions, java.lang.String snippetId)
NiFiServiceFacade
deleteSnippet
in interface NiFiServiceFacade
revisions
- revisionssnippetId
- snippetpublic PortEntity deleteInputPort(Revision revision, java.lang.String inputPortId)
NiFiServiceFacade
deleteInputPort
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisioninputPortId
- The id of the input portpublic PortEntity deleteOutputPort(Revision revision, java.lang.String outputPortId)
NiFiServiceFacade
deleteOutputPort
in interface NiFiServiceFacade
revision
- revisionoutputPortId
- The id of the output portpublic ProcessGroupEntity deleteProcessGroup(Revision revision, java.lang.String groupId)
NiFiServiceFacade
deleteProcessGroup
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisiongroupId
- The id of the process grouppublic RemoteProcessGroupEntity deleteRemoteProcessGroup(Revision revision, java.lang.String remoteProcessGroupId)
NiFiServiceFacade
deleteRemoteProcessGroup
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionremoteProcessGroupId
- The id of the remote process grouppublic void deleteTemplate(java.lang.String id)
NiFiServiceFacade
deleteTemplate
in interface NiFiServiceFacade
id
- The id of the templatepublic ConnectionEntity createConnection(Revision revision, java.lang.String groupId, ConnectionDTO connectionDTO)
NiFiServiceFacade
createConnection
in interface NiFiServiceFacade
revision
- revisiongroupId
- groupconnectionDTO
- The Connection DTOpublic DropRequestDTO createFlowFileDropRequest(java.lang.String connectionId, java.lang.String dropRequestId)
NiFiServiceFacade
createFlowFileDropRequest
in interface NiFiServiceFacade
connectionId
- The ID of the connectiondropRequestId
- The ID of the drop requestpublic ListingRequestDTO createFlowFileListingRequest(java.lang.String connectionId, java.lang.String listingRequestId)
NiFiServiceFacade
createFlowFileListingRequest
in interface NiFiServiceFacade
connectionId
- The ID of the connectionlistingRequestId
- The ID of the listing requestpublic ProcessorEntity createProcessor(Revision revision, java.lang.String groupId, ProcessorDTO processorDTO)
NiFiServiceFacade
createProcessor
in interface NiFiServiceFacade
revision
- revisiongroupId
- Group idprocessorDTO
- The processor DTOpublic LabelEntity createLabel(Revision revision, java.lang.String groupId, LabelDTO labelDTO)
NiFiServiceFacade
createLabel
in interface NiFiServiceFacade
revision
- revisiongroupId
- grouplabelDTO
- The label DTOpublic BulletinEntity createBulletin(BulletinDTO bulletinDTO, java.lang.Boolean canRead)
NiFiServiceFacade
createBulletin
in interface NiFiServiceFacade
bulletinDTO
- bulletin to send to userscanRead
- allow users to read bulletinpublic FunnelEntity createFunnel(Revision revision, java.lang.String groupId, FunnelDTO funnelDTO)
NiFiServiceFacade
createFunnel
in interface NiFiServiceFacade
revision
- revisiongroupId
- groupfunnelDTO
- funnelpublic AccessPolicyEntity createAccessPolicy(Revision revision, AccessPolicyDTO accessPolicyDTO)
NiFiServiceFacade
createAccessPolicy
in interface NiFiServiceFacade
revision
- The starting revisionaccessPolicyDTO
- The access policy DTOpublic UserEntity createUser(Revision revision, UserDTO userDTO)
NiFiServiceFacade
createUser
in interface NiFiServiceFacade
revision
- The starting revisionuserDTO
- The user DTOpublic UserGroupEntity createUserGroup(Revision revision, UserGroupDTO userGroupDTO)
NiFiServiceFacade
createUserGroup
in interface NiFiServiceFacade
revision
- The starting revisionuserGroupDTO
- The user group DTOpublic FlowEntity copySnippet(java.lang.String groupId, java.lang.String snippetId, java.lang.Double originX, java.lang.Double originY, java.lang.String idGenerationSeed)
NiFiServiceFacade
copySnippet
in interface NiFiServiceFacade
groupId
- group idsnippetId
- snippet idoriginX
- xoriginY
- yidGenerationSeed
- the seed to use for generating UUID's. May be null.public SnippetEntity createSnippet(SnippetDTO snippetDTO)
NiFiServiceFacade
createSnippet
in interface NiFiServiceFacade
snippetDTO
- snippetpublic PortEntity createInputPort(Revision revision, java.lang.String groupId, PortDTO inputPortDTO)
NiFiServiceFacade
createInputPort
in interface NiFiServiceFacade
revision
- revisiongroupId
- The id of the group this port should be create ininputPortDTO
- The input PortDTOpublic PortEntity createOutputPort(Revision revision, java.lang.String groupId, PortDTO outputPortDTO)
NiFiServiceFacade
createOutputPort
in interface NiFiServiceFacade
revision
- revisiongroupId
- The id of the group this port should be create inoutputPortDTO
- The output PortDTOpublic ProcessGroupEntity createProcessGroup(Revision revision, java.lang.String parentGroupId, ProcessGroupDTO processGroupDTO)
NiFiServiceFacade
createProcessGroup
in interface NiFiServiceFacade
revision
- revisionparentGroupId
- The id of the parent groupprocessGroupDTO
- The ProcessGroupDTOpublic RemoteProcessGroupEntity createRemoteProcessGroup(Revision revision, java.lang.String groupId, RemoteProcessGroupDTO remoteProcessGroupDTO)
NiFiServiceFacade
createRemoteProcessGroup
in interface NiFiServiceFacade
revision
- revisiongroupId
- The id of the parent groupremoteProcessGroupDTO
- The RemoteProcessGroupDTOpublic void verifyCanAddTemplate(java.lang.String groupId, java.lang.String name)
NiFiServiceFacade
verifyCanAddTemplate
in interface NiFiServiceFacade
groupId
- the id of the group for the templatename
- name of proposed templatepublic void verifyComponentTypes(FlowSnippetDTO snippet)
NiFiServiceFacade
verifyComponentTypes
in interface NiFiServiceFacade
snippet
- proposed templatepublic TemplateDTO createTemplate(java.lang.String name, java.lang.String description, java.lang.String snippetId, java.lang.String groupId, java.util.Optional<java.lang.String> idGenerationSeed)
NiFiServiceFacade
createTemplate
in interface NiFiServiceFacade
name
- namedescription
- descriptionsnippetId
- idgroupId
- id of the process groupidGenerationSeed
- the seed to use for generating a UUIDpublic TemplateDTO importTemplate(TemplateDTO templateDTO, java.lang.String groupId, java.util.Optional<java.lang.String> idGenerationSeed)
NiFiServiceFacade
importTemplate
in interface NiFiServiceFacade
templateDTO
- The template dtogroupId
- id of the process groupidGenerationSeed
- the seed to use for generating a UUIDpublic FlowEntity createTemplateInstance(java.lang.String groupId, java.lang.Double originX, java.lang.Double originY, java.lang.String templateEncodingVersion, FlowSnippetDTO requestSnippet, java.lang.String idGenerationSeed)
NiFiServiceFacade
createTemplateInstance
in interface NiFiServiceFacade
groupId
- group idoriginX
- xoriginY
- ytemplateEncodingVersion
- template encoding versionrequestSnippet
- template snippetidGenerationSeed
- the ID to use for generating UUID's. May be null.public ControllerServiceEntity createControllerService(Revision revision, java.lang.String groupId, ControllerServiceDTO controllerServiceDTO)
NiFiServiceFacade
createControllerService
in interface NiFiServiceFacade
revision
- revisiongroupId
- the ID of the Process Group to add the Controller Service tocontrollerServiceDTO
- The controller service DTOpublic ControllerServiceEntity updateControllerService(Revision revision, ControllerServiceDTO controllerServiceDTO)
NiFiServiceFacade
updateControllerService
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisioncontrollerServiceDTO
- The controller service DTOpublic ControllerServiceReferencingComponentsEntity updateControllerServiceReferencingComponents(java.util.Map<java.lang.String,Revision> referenceRevisions, java.lang.String controllerServiceId, ScheduledState scheduledState, ControllerServiceState controllerServiceState)
NiFiServiceFacade
updateControllerServiceReferencingComponents
in interface NiFiServiceFacade
referenceRevisions
- revisionscontrollerServiceId
- idscheduledState
- statecontrollerServiceState
- the value of statepublic ControllerServiceEntity deleteControllerService(Revision revision, java.lang.String controllerServiceId)
NiFiServiceFacade
deleteControllerService
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisioncontrollerServiceId
- The controller service idpublic ReportingTaskEntity createReportingTask(Revision revision, ReportingTaskDTO reportingTaskDTO)
NiFiServiceFacade
createReportingTask
in interface NiFiServiceFacade
revision
- revisionreportingTaskDTO
- The reporting task DTOpublic ReportingTaskEntity updateReportingTask(Revision revision, ReportingTaskDTO reportingTaskDTO)
NiFiServiceFacade
updateReportingTask
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionreportingTaskDTO
- The reporting task DTOpublic ReportingTaskEntity deleteReportingTask(Revision revision, java.lang.String reportingTaskId)
NiFiServiceFacade
deleteReportingTask
in interface NiFiServiceFacade
revision
- Revision to compare with current base revisionreportingTaskId
- The reporting task idpublic void deleteActions(java.util.Date endDate)
NiFiServiceFacade
deleteActions
in interface NiFiServiceFacade
endDate
- The end datepublic ProvenanceDTO submitProvenance(ProvenanceDTO query)
NiFiServiceFacade
submitProvenance
in interface NiFiServiceFacade
query
- querypublic void deleteProvenance(java.lang.String queryId)
NiFiServiceFacade
deleteProvenance
in interface NiFiServiceFacade
queryId
- identifierpublic LineageDTO submitLineage(LineageDTO lineage)
NiFiServiceFacade
submitLineage
in interface NiFiServiceFacade
lineage
- lineagepublic void deleteLineage(java.lang.String lineageId)
NiFiServiceFacade
deleteLineage
in interface NiFiServiceFacade
lineageId
- lineagepublic ProvenanceEventDTO submitReplay(java.lang.Long eventId)
NiFiServiceFacade
submitReplay
in interface NiFiServiceFacade
eventId
- idpublic SearchResultsDTO searchController(java.lang.String query)
NiFiServiceFacade
searchController
in interface NiFiServiceFacade
query
- querypublic DownloadableContent getContent(java.lang.String connectionId, java.lang.String flowFileUuid, java.lang.String uri)
NiFiServiceFacade
getContent
in interface NiFiServiceFacade
connectionId
- connectionflowFileUuid
- flowfileuri
- uripublic DownloadableContent getContent(java.lang.Long eventId, java.lang.String uri, ContentDirection contentDirection)
NiFiServiceFacade
getContent
in interface NiFiServiceFacade
eventId
- iduri
- uricontentDirection
- directionpublic ProvenanceDTO getProvenance(java.lang.String queryId, java.lang.Boolean summarize, java.lang.Boolean incrementalResults)
NiFiServiceFacade
getProvenance
in interface NiFiServiceFacade
queryId
- identifiersummarize
- whether to summarize the event dtosincrementalResults
- whether to return any events if the search has not finishedpublic LineageDTO getLineage(java.lang.String lineageId)
NiFiServiceFacade
getLineage
in interface NiFiServiceFacade
lineageId
- idpublic ProvenanceOptionsDTO getProvenanceSearchOptions()
NiFiServiceFacade
getProvenanceSearchOptions
in interface NiFiServiceFacade
public ProvenanceEventDTO getProvenanceEvent(java.lang.Long id)
NiFiServiceFacade
getProvenanceEvent
in interface NiFiServiceFacade
id
- idpublic ProcessGroupStatusEntity getProcessGroupStatus(java.lang.String groupId, boolean recursive)
NiFiServiceFacade
getProcessGroupStatus
in interface NiFiServiceFacade
groupId
- grouppublic ControllerStatusDTO getControllerStatus()
NiFiServiceFacade
getControllerStatus
in interface NiFiServiceFacade
public ComponentStateDTO getProcessorState(java.lang.String processorId)
NiFiServiceFacade
getProcessorState
in interface NiFiServiceFacade
processorId
- the processor idpublic ComponentStateDTO getControllerServiceState(java.lang.String controllerServiceId)
NiFiServiceFacade
getControllerServiceState
in interface NiFiServiceFacade
controllerServiceId
- the controller service idpublic ComponentStateDTO getReportingTaskState(java.lang.String reportingTaskId)
NiFiServiceFacade
getReportingTaskState
in interface NiFiServiceFacade
reportingTaskId
- the reporting task idpublic CountersDTO getCounters()
NiFiServiceFacade
getCounters
in interface NiFiServiceFacade
public java.util.Set<ConnectionEntity> getConnections(java.lang.String groupId)
NiFiServiceFacade
getConnections
in interface NiFiServiceFacade
groupId
- grouppublic ConnectionEntity getConnection(java.lang.String connectionId)
NiFiServiceFacade
getConnection
in interface NiFiServiceFacade
connectionId
- The ID of the connectionpublic DropRequestDTO getFlowFileDropRequest(java.lang.String connectionId, java.lang.String dropRequestId)
NiFiServiceFacade
getFlowFileDropRequest
in interface NiFiServiceFacade
connectionId
- The ID of the connectiondropRequestId
- The flow file drop requestpublic ListingRequestDTO getFlowFileListingRequest(java.lang.String connectionId, java.lang.String listingRequestId)
NiFiServiceFacade
getFlowFileListingRequest
in interface NiFiServiceFacade
connectionId
- The ID of the connectionlistingRequestId
- The ID of the listing requestpublic FlowFileDTO getFlowFile(java.lang.String connectionId, java.lang.String flowFileUuid)
NiFiServiceFacade
getFlowFile
in interface NiFiServiceFacade
connectionId
- The ID of the connectionflowFileUuid
- The UUID of the flowfilepublic ConnectionStatusEntity getConnectionStatus(java.lang.String connectionId)
NiFiServiceFacade
getConnectionStatus
in interface NiFiServiceFacade
connectionId
- connectionpublic StatusHistoryEntity getConnectionStatusHistory(java.lang.String connectionId)
NiFiServiceFacade
getConnectionStatusHistory
in interface NiFiServiceFacade
connectionId
- connectionpublic java.util.Set<ProcessorEntity> getProcessors(java.lang.String groupId, boolean includeDescendants)
NiFiServiceFacade
getProcessors
in interface NiFiServiceFacade
groupId
- groupincludeDescendants
- if processors from descendent groups should be includedpublic TemplateDTO exportTemplate(java.lang.String id)
NiFiServiceFacade
exportTemplate
in interface NiFiServiceFacade
id
- idpublic TemplateDTO getTemplate(java.lang.String id)
NiFiServiceFacade
getTemplate
in interface NiFiServiceFacade
id
- idpublic java.util.Set<TemplateEntity> getTemplates()
NiFiServiceFacade
getTemplates
in interface NiFiServiceFacade
public java.util.Set<DocumentedTypeDTO> getWorkQueuePrioritizerTypes()
NiFiServiceFacade
getWorkQueuePrioritizerTypes
in interface NiFiServiceFacade
public java.util.Set<DocumentedTypeDTO> getProcessorTypes(java.lang.String bundleGroup, java.lang.String bundleArtifact, java.lang.String type)
NiFiServiceFacade
getProcessorTypes
in interface NiFiServiceFacade
bundleGroup
- if specified, must be member of bundle groupbundleArtifact
- if specified, must be member of bundle artifacttype
- if specified, type must matchpublic java.util.Set<DocumentedTypeDTO> getControllerServiceTypes(java.lang.String serviceType, java.lang.String serviceBundleGroup, java.lang.String serviceBundleArtifact, java.lang.String serviceBundleVersion, java.lang.String bundleGroup, java.lang.String bundleArtifact, java.lang.String type)
NiFiServiceFacade
getControllerServiceTypes
in interface NiFiServiceFacade
serviceType
- Filters only service types that implement this typeserviceBundleGroup
- if serviceType specified, the bundle group of the serviceTypeserviceBundleArtifact
- if serviceType specified, the bundle artifact of the serviceTypeserviceBundleVersion
- if serviceType specified, the bundle version of the serviceTypebundleGroup
- if specified, must be member of bundle groupbundleArtifact
- if specified, must be member of bundle artifacttype
- if specified, type must matchpublic java.util.Set<DocumentedTypeDTO> getReportingTaskTypes(java.lang.String bundleGroup, java.lang.String bundleArtifact, java.lang.String type)
NiFiServiceFacade
getReportingTaskTypes
in interface NiFiServiceFacade
bundleGroup
- if specified, must be member of bundle groupbundleArtifact
- if specified, must be member of bundle artifacttype
- if specified, type must matchpublic ProcessorEntity getProcessor(java.lang.String id)
NiFiServiceFacade
getProcessor
in interface NiFiServiceFacade
id
- Id of the processor to returnpublic PropertyDescriptorDTO getProcessorPropertyDescriptor(java.lang.String id, java.lang.String property)
NiFiServiceFacade
getProcessorPropertyDescriptor
in interface NiFiServiceFacade
id
- idproperty
- propertypublic ProcessorStatusEntity getProcessorStatus(java.lang.String id)
NiFiServiceFacade
getProcessorStatus
in interface NiFiServiceFacade
id
- idpublic StatusHistoryEntity getProcessorStatusHistory(java.lang.String id)
NiFiServiceFacade
getProcessorStatusHistory
in interface NiFiServiceFacade
id
- idpublic BulletinBoardDTO getBulletinBoard(BulletinQueryDTO query)
getBulletinBoard
in interface NiFiServiceFacade
query
- querypublic SystemDiagnosticsDTO getSystemDiagnostics()
getSystemDiagnostics
in interface NiFiServiceFacade
public java.util.List<ResourceDTO> getResources()
getResources
in interface NiFiServiceFacade
public ControllerDTO getSiteToSiteDetails()
getSiteToSiteDetails
in interface NiFiServiceFacade
public ControllerConfigurationEntity getControllerConfiguration()
NiFiServiceFacade
getControllerConfiguration
in interface NiFiServiceFacade
public ControllerBulletinsEntity getControllerBulletins()
NiFiServiceFacade
getControllerBulletins
in interface NiFiServiceFacade
public FlowConfigurationEntity getFlowConfiguration()
NiFiServiceFacade
getFlowConfiguration
in interface NiFiServiceFacade
public AccessPolicyEntity getAccessPolicy(java.lang.String accessPolicyId)
NiFiServiceFacade
getAccessPolicy
in interface NiFiServiceFacade
accessPolicyId
- access policy IDpublic AccessPolicyEntity getAccessPolicy(RequestAction requestAction, java.lang.String resource)
NiFiServiceFacade
getAccessPolicy
in interface NiFiServiceFacade
resource
- resourcepublic UserEntity getUser(java.lang.String userId)
NiFiServiceFacade
getUser
in interface NiFiServiceFacade
userId
- The user IDpublic java.util.Set<UserEntity> getUsers()
NiFiServiceFacade
getUsers
in interface NiFiServiceFacade
public UserGroupEntity getUserGroup(java.lang.String userGroupId)
NiFiServiceFacade
getUserGroup
in interface NiFiServiceFacade
userGroupId
- The user group IDpublic java.util.Set<UserGroupEntity> getUserGroups()
NiFiServiceFacade
getUserGroups
in interface NiFiServiceFacade
public java.util.Set<LabelEntity> getLabels(java.lang.String groupId)
NiFiServiceFacade
getLabels
in interface NiFiServiceFacade
groupId
- grouppublic LabelEntity getLabel(java.lang.String labelId)
NiFiServiceFacade
getLabel
in interface NiFiServiceFacade
labelId
- The label idpublic java.util.Set<FunnelEntity> getFunnels(java.lang.String groupId)
NiFiServiceFacade
getFunnels
in interface NiFiServiceFacade
groupId
- grouppublic FunnelEntity getFunnel(java.lang.String funnelId)
NiFiServiceFacade
getFunnel
in interface NiFiServiceFacade
funnelId
- The funnel idpublic java.util.Set<PortEntity> getInputPorts(java.lang.String groupId)
NiFiServiceFacade
getInputPorts
in interface NiFiServiceFacade
groupId
- The id of the grouppublic java.util.Set<PortEntity> getOutputPorts(java.lang.String groupId)
NiFiServiceFacade
getOutputPorts
in interface NiFiServiceFacade
groupId
- The id of the grouppublic java.util.Set<ProcessGroupEntity> getProcessGroups(java.lang.String parentGroupId)
NiFiServiceFacade
getProcessGroups
in interface NiFiServiceFacade
parentGroupId
- The id of the parent grouppublic java.util.Set<RemoteProcessGroupEntity> getRemoteProcessGroups(java.lang.String groupId)
NiFiServiceFacade
getRemoteProcessGroups
in interface NiFiServiceFacade
groupId
- The id of the parent grouppublic PortEntity getInputPort(java.lang.String inputPortId)
NiFiServiceFacade
getInputPort
in interface NiFiServiceFacade
inputPortId
- The input port idpublic PortStatusEntity getInputPortStatus(java.lang.String inputPortId)
NiFiServiceFacade
getInputPortStatus
in interface NiFiServiceFacade
inputPortId
- input portpublic PortEntity getOutputPort(java.lang.String outputPortId)
NiFiServiceFacade
getOutputPort
in interface NiFiServiceFacade
outputPortId
- The output port idpublic PortStatusEntity getOutputPortStatus(java.lang.String outputPortId)
NiFiServiceFacade
getOutputPortStatus
in interface NiFiServiceFacade
outputPortId
- output portpublic RemoteProcessGroupEntity getRemoteProcessGroup(java.lang.String remoteProcessGroupId)
NiFiServiceFacade
getRemoteProcessGroup
in interface NiFiServiceFacade
remoteProcessGroupId
- The id of the remote process grouppublic RemoteProcessGroupStatusEntity getRemoteProcessGroupStatus(java.lang.String id)
NiFiServiceFacade
getRemoteProcessGroupStatus
in interface NiFiServiceFacade
id
- remote process grouppublic StatusHistoryEntity getRemoteProcessGroupStatusHistory(java.lang.String id)
NiFiServiceFacade
getRemoteProcessGroupStatusHistory
in interface NiFiServiceFacade
id
- The id of the remote process grouppublic CurrentUserEntity getCurrentUser()
getCurrentUser
in interface NiFiServiceFacade
public ProcessGroupFlowEntity getProcessGroupFlow(java.lang.String groupId)
NiFiServiceFacade
getProcessGroupFlow
in interface NiFiServiceFacade
groupId
- grouppublic ProcessGroupEntity getProcessGroup(java.lang.String groupId)
NiFiServiceFacade
getProcessGroup
in interface NiFiServiceFacade
groupId
- grouppublic VariableRegistryEntity getVariableRegistry(java.lang.String groupId, boolean includeAncestorGroups)
NiFiServiceFacade
getVariableRegistry
in interface NiFiServiceFacade
groupId
- the ID of the Process GroupincludeAncestorGroups
- whether or not to include the variables that are defined in the the process group's parent group & its parent group, etc.public VariableRegistryEntity populateAffectedComponents(VariableRegistryDTO variableRegistryDto)
NiFiServiceFacade
populateAffectedComponents
in interface NiFiServiceFacade
variableRegistryDto
- the Variable Registry that contains the variables of interestpublic java.util.Set<ControllerServiceEntity> getControllerServices(java.lang.String groupId, boolean includeAncestorGroups, boolean includeDescendantGroups)
NiFiServiceFacade
getControllerServices
in interface NiFiServiceFacade
groupId
- the id of the process group of interestincludeAncestorGroups
- if true, parent and ancestor groups' services will be returned as wellincludeDescendantGroups
- if true, child and descendant groups' services will be returned as wellpublic java.util.Set<ControllerServiceEntity> getControllerServices(java.lang.String groupId, boolean includeAncestorGroups, boolean includeDescendantGroups, NiFiUser user)
NiFiServiceFacade
getControllerServices
in interface NiFiServiceFacade
groupId
- the id of the process group of interestincludeAncestorGroups
- if true, parent and ancestor groups' services will be returned as wellincludeDescendantGroups
- if true, child and descendant groups' services will be returned as welluser
- the user that is retrieving the Controller Servicespublic ControllerServiceEntity getControllerService(java.lang.String controllerServiceId)
NiFiServiceFacade
getControllerService
in interface NiFiServiceFacade
controllerServiceId
- idpublic PropertyDescriptorDTO getControllerServicePropertyDescriptor(java.lang.String id, java.lang.String property)
NiFiServiceFacade
getControllerServicePropertyDescriptor
in interface NiFiServiceFacade
id
- idproperty
- propertypublic ControllerServiceReferencingComponentsEntity getControllerServiceReferencingComponents(java.lang.String controllerServiceId)
NiFiServiceFacade
getControllerServiceReferencingComponents
in interface NiFiServiceFacade
controllerServiceId
- idpublic java.util.Set<ReportingTaskEntity> getReportingTasks()
NiFiServiceFacade
getReportingTasks
in interface NiFiServiceFacade
public ReportingTaskEntity getReportingTask(java.lang.String reportingTaskId)
NiFiServiceFacade
getReportingTask
in interface NiFiServiceFacade
reportingTaskId
- idpublic PropertyDescriptorDTO getReportingTaskPropertyDescriptor(java.lang.String id, java.lang.String property)
NiFiServiceFacade
getReportingTaskPropertyDescriptor
in interface NiFiServiceFacade
id
- idproperty
- propertypublic StatusHistoryEntity getProcessGroupStatusHistory(java.lang.String groupId)
NiFiServiceFacade
getProcessGroupStatusHistory
in interface NiFiServiceFacade
groupId
- idpublic HistoryDTO getActions(HistoryQueryDTO historyQueryDto)
NiFiServiceFacade
getActions
in interface NiFiServiceFacade
historyQueryDto
- querypublic ActionEntity getAction(java.lang.Integer actionId)
NiFiServiceFacade
getAction
in interface NiFiServiceFacade
actionId
- idpublic ComponentHistoryDTO getComponentHistory(java.lang.String componentId)
NiFiServiceFacade
getComponentHistory
in interface NiFiServiceFacade
componentId
- idpublic boolean isClustered()
isClustered
in interface NiFiServiceFacade
public java.lang.String getNodeId()
getNodeId
in interface NiFiServiceFacade
public ClusterDTO getCluster()
getCluster
in interface NiFiServiceFacade
public NodeDTO getNode(java.lang.String nodeId)
NiFiServiceFacade
getNode
in interface NiFiServiceFacade
nodeId
- a node identifierpublic void deleteNode(java.lang.String nodeId)
NiFiServiceFacade
deleteNode
in interface NiFiServiceFacade
nodeId
- a node identifierpublic void setProperties(NiFiProperties properties)
public void setControllerFacade(ControllerFacade controllerFacade)
public void setRemoteProcessGroupDAO(RemoteProcessGroupDAO remoteProcessGroupDAO)
public void setLabelDAO(LabelDAO labelDAO)
public void setFunnelDAO(FunnelDAO funnelDAO)
public void setSnippetDAO(SnippetDAO snippetDAO)
public void setProcessorDAO(ProcessorDAO processorDAO)
public void setConnectionDAO(ConnectionDAO connectionDAO)
public void setAuditService(AuditService auditService)
public void setRevisionManager(RevisionManager revisionManager)
public void setDtoFactory(DtoFactory dtoFactory)
public void setEntityFactory(EntityFactory entityFactory)
public void setInputPortDAO(PortDAO inputPortDAO)
public void setOutputPortDAO(PortDAO outputPortDAO)
public void setProcessGroupDAO(ProcessGroupDAO processGroupDAO)
public void setControllerServiceDAO(ControllerServiceDAO controllerServiceDAO)
public void setReportingTaskDAO(ReportingTaskDAO reportingTaskDAO)
public void setTemplateDAO(TemplateDAO templateDAO)
public void setSnippetUtils(SnippetUtils snippetUtils)
public void setAuthorizableLookup(AuthorizableLookup authorizableLookup)
public void setAuthorizer(Authorizer authorizer)
public void setUserDAO(UserDAO userDAO)
public void setUserGroupDAO(UserGroupDAO userGroupDAO)
public void setAccessPolicyDAO(AccessPolicyDAO accessPolicyDAO)
public void setClusterCoordinator(ClusterCoordinator coordinator)
public void setHeartbeatMonitor(HeartbeatMonitor heartbeatMonitor)
public void setBulletinRepository(BulletinRepository bulletinRepository)
public void setLeaderElectionManager(LeaderElectionManager leaderElectionManager)