test_class.declarator: processorService
test_class.modifier: private
test_class.original_string: private FDProcessorService processorService;
test_class.type: FDProcessorService
test_class.var_name: processorService
test_class.file: efm/efm-flow-designer/efm-flow-designer-framework/src/test/java/com/cloudera/cem/efm/service/component/TestStandardFDProcessorService.java
test_class.identifier: TestStandardFDProcessorService
test_class.superclass: extends BaseFDServiceTest
test_case.body: @Test(expected = ResourceNotFoundException.class)
      public void testUpdateProcessorWhenProcessorDoesNotExist() {
          when(flowManager.getFlow(flow.getFlowMetadata().getIdentifier())).thenReturn(Optional.of(flow));
  
          final VersionedProcessor requestProcessor = new VersionedProcessor();
          requestProcessor.setIdentifier("DOES-NOT-EXIST");
  
          processorService.update(flow.getFlowMetadata().getIdentifier(), requestProcessor);
      }
test_case.class_method_signature: TestStandardFDProcessorService.testUpdateProcessorWhenProcessorDoesNotExist()
test_case.full_signature: @Test(expected = ResourceNotFoundException.class) public void testUpdateProcessorWhenProcessorDoesNotExist()
test_case.identifier: testUpdateProcessorWhenProcessorDoesNotExist
test_case.invocations: thenReturn when getFlow getIdentifier getFlowMetadata of setIdentifier update getIdentifier getFlowMetadata
test_case.modifiers: @Test(expected = ResourceNotFoundException.class) public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testUpdateProcessorWhenProcessorDoesNotExist()
focal_class.declarator: LOGGER = LoggerFactory.getLogger(StandardFDProcessorService.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOGGER = LoggerFactory.getLogger(StandardFDProcessorService.class);
focal_class.type: Logger
focal_class.var_name: LOGGER
focal_class.declarator: validationErrorCache = new ConcurrentHashMap<>()
focal_class.modifier: private
focal_class.original_string: private ConcurrentMap<String, Collection<String>> validationErrorCache = new ConcurrentHashMap<>();
focal_class.type: ConcurrentMap<String, Collection<String>>
focal_class.var_name: validationErrorCache
focal_class.file: efm/efm-flow-designer/efm-flow-designer-framework/src/main/java/com/cloudera/cem/efm/service/component/StandardFDProcessorService.java
focal_class.identifier: StandardFDProcessorService
focal_class.interfaces: implements FDProcessorService
focal_class.class_method_signature: StandardFDProcessorService.StandardFDProcessorService(final FDFlowManager flowManager, final FDExtensionManagers extensionManagers, final ValidationService validationService)
focal_class.full_signature: @Autowired public  StandardFDProcessorService(final FDFlowManager flowManager, final FDExtensionManagers extensionManagers, final ValidationService validationService)
focal_class.identifier: StandardFDProcessorService
focal_class.modifiers: @Autowired public
focal_class.parameters: (final FDFlowManager flowManager, final FDExtensionManagers extensionManagers, final ValidationService validationService)
focal_class.signature:  StandardFDProcessorService(final FDFlowManager flowManager, final FDExtensionManagers extensionManagers, final ValidationService validationService)
focal_class.class_method_signature: StandardFDProcessorService.getProcessorTypes(final String flowId)
focal_class.full_signature: @Override public FDComponentTypes getProcessorTypes(final String flowId)
focal_class.identifier: getProcessorTypes
focal_class.modifiers: @Override public
focal_class.parameters: (final String flowId)
focal_class.return: FDComponentTypes
focal_class.signature: FDComponentTypes getProcessorTypes(final String flowId)
focal_class.class_method_signature: StandardFDProcessorService.getPropertyDescriptor(final String flowId, final String processorId, final String propertyName)
focal_class.full_signature: @Override public FDPropertyDescriptor getPropertyDescriptor(final String flowId, final String processorId, final String propertyName)
focal_class.identifier: getPropertyDescriptor
focal_class.modifiers: @Override public
focal_class.parameters: (final String flowId, final String processorId, final String propertyName)
focal_class.return: FDPropertyDescriptor
focal_class.signature: FDPropertyDescriptor getPropertyDescriptor(final String flowId, final String processorId, final String propertyName)
focal_class.class_method_signature: StandardFDProcessorService.getPropertyDescriptorFromExtensionManager(
              final FDExtensionManager extensionManager, final String type,
              final Bundle bundle, final String propertyName)
focal_class.full_signature: @Override protected Optional<PropertyDescriptor> getPropertyDescriptorFromExtensionManager(
              final FDExtensionManager extensionManager, final String type,
              final Bundle bundle, final String propertyName)
focal_class.identifier: getPropertyDescriptorFromExtensionManager
focal_class.modifiers: @Override protected
focal_class.parameters: (
              final FDExtensionManager extensionManager, final String type,
              final Bundle bundle, final String propertyName)
focal_class.return: Optional<PropertyDescriptor>
focal_class.signature: Optional<PropertyDescriptor> getPropertyDescriptorFromExtensionManager(
              final FDExtensionManager extensionManager, final String type,
              final Bundle bundle, final String propertyName)
focal_class.class_method_signature: StandardFDProcessorService.createDynamicPropertyDescriptorFromExtensionManager(
              final FDExtensionManager extensionManager, final String type,
              final Bundle bundle, final String propertyName)
focal_class.full_signature: @Override protected PropertyDescriptor createDynamicPropertyDescriptorFromExtensionManager(
              final FDExtensionManager extensionManager, final String type,
              final Bundle bundle, final String propertyName)
focal_class.identifier: createDynamicPropertyDescriptorFromExtensionManager
focal_class.modifiers: @Override protected
focal_class.parameters: (
              final FDExtensionManager extensionManager, final String type,
              final Bundle bundle, final String propertyName)
focal_class.return: PropertyDescriptor
focal_class.signature: PropertyDescriptor createDynamicPropertyDescriptorFromExtensionManager(
              final FDExtensionManager extensionManager, final String type,
              final Bundle bundle, final String propertyName)
focal_class.class_method_signature: StandardFDProcessorService.create(final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig)
focal_class.full_signature: @Override public FDProcessor create(final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig)
focal_class.identifier: create
focal_class.modifiers: @Override public
focal_class.parameters: (final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig)
focal_class.return: FDProcessor
focal_class.signature: FDProcessor create(final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig)
focal_class.class_method_signature: StandardFDProcessorService.validate(final FDProcessor processor, final VersionedProcessGroup group, final String flowId, final ControllerServiceLookup serviceLookup)
focal_class.full_signature: private Collection<String> validate(final FDProcessor processor, final VersionedProcessGroup group, final String flowId, final ControllerServiceLookup serviceLookup)
focal_class.identifier: validate
focal_class.modifiers: private
focal_class.parameters: (final FDProcessor processor, final VersionedProcessGroup group, final String flowId, final ControllerServiceLookup serviceLookup)
focal_class.return: Collection<String>
focal_class.signature: Collection<String> validate(final FDProcessor processor, final VersionedProcessGroup group, final String flowId, final ControllerServiceLookup serviceLookup)
focal_class.class_method_signature: StandardFDProcessorService.get(final String flowId, final String processorId)
focal_class.full_signature: @Override public FDProcessor get(final String flowId, final String processorId)
focal_class.identifier: get
focal_class.modifiers: @Override public
focal_class.parameters: (final String flowId, final String processorId)
focal_class.return: FDProcessor
focal_class.signature: FDProcessor get(final String flowId, final String processorId)
focal_class.class_method_signature: StandardFDProcessorService.update(final String flowId, final VersionedProcessor requestComponentConfig)
focal_class.full_signature: @Override public FDProcessor update(final String flowId, final VersionedProcessor requestComponentConfig)
focal_class.identifier: update
focal_class.modifiers: @Override public
focal_class.parameters: (final String flowId, final VersionedProcessor requestComponentConfig)
focal_class.return: FDProcessor
focal_class.signature: FDProcessor update(final String flowId, final VersionedProcessor requestComponentConfig)
focal_class.class_method_signature: StandardFDProcessorService.delete(final String flowId, final String processorId)
focal_class.full_signature: @Override public void delete(final String flowId, final String processorId)
focal_class.identifier: delete
focal_class.modifiers: @Override public
focal_class.parameters: (final String flowId, final String processorId)
focal_class.return: void
focal_class.signature: void delete(final String flowId, final String processorId)
focal_class.class_method_signature: StandardFDProcessorService.getComponentDefinition(final String agentClass, final VersionedProcessor componentConfig)
focal_class.full_signature: @Override public ProcessorDefinition getComponentDefinition(final String agentClass, final VersionedProcessor componentConfig)
focal_class.identifier: getComponentDefinition
focal_class.modifiers: @Override public
focal_class.parameters: (final String agentClass, final VersionedProcessor componentConfig)
focal_class.return: ProcessorDefinition
focal_class.signature: ProcessorDefinition getComponentDefinition(final String agentClass, final VersionedProcessor componentConfig)
focal_class.class_method_signature: StandardFDProcessorService.populateDynamicRelationships(final ProcessorDefinition processorDefinition)
focal_class.full_signature: private void populateDynamicRelationships(final ProcessorDefinition processorDefinition)
focal_class.identifier: populateDynamicRelationships
focal_class.modifiers: private
focal_class.parameters: (final ProcessorDefinition processorDefinition)
focal_class.return: void
focal_class.signature: void populateDynamicRelationships(final ProcessorDefinition processorDefinition)
focal_class.class_method_signature: StandardFDProcessorService.instantiateExtensionComponent(final VersionedProcessor componentConfig,
                                                          final ProcessorDefinition componentDefinition)
focal_class.full_signature: @Override protected FDProcessor instantiateExtensionComponent(final VersionedProcessor componentConfig,
                                                          final ProcessorDefinition componentDefinition)
focal_class.identifier: instantiateExtensionComponent
focal_class.modifiers: @Override protected
focal_class.parameters: (final VersionedProcessor componentConfig,
                                                          final ProcessorDefinition componentDefinition)
focal_class.return: FDProcessor
focal_class.signature: FDProcessor instantiateExtensionComponent(final VersionedProcessor componentConfig,
                                                          final ProcessorDefinition componentDefinition)
focal_class.class_method_signature: StandardFDProcessorService.configureComponentSpecifics(VersionedProcessor requestProcessor, VersionedProcessor resultProcessor)
focal_class.full_signature: @Override protected void configureComponentSpecifics(VersionedProcessor requestProcessor, VersionedProcessor resultProcessor)
focal_class.identifier: configureComponentSpecifics
focal_class.modifiers: @Override protected
focal_class.parameters: (VersionedProcessor requestProcessor, VersionedProcessor resultProcessor)
focal_class.return: void
focal_class.signature: void configureComponentSpecifics(VersionedProcessor requestProcessor, VersionedProcessor resultProcessor)
focal_class.class_method_signature: StandardFDProcessorService.validateRequestValues(final VersionedProcessor requestComponent)
focal_class.full_signature: private void validateRequestValues(final VersionedProcessor requestComponent)
focal_class.identifier: validateRequestValues
focal_class.modifiers: private
focal_class.parameters: (final VersionedProcessor requestComponent)
focal_class.return: void
focal_class.signature: void validateRequestValues(final VersionedProcessor requestComponent)
focal_class.superclass: extends BaseExtensionComponentService<VersionedProcessor, ProcessorDefinition, FDProcessor>
focal_method.body: @Override
      public FDProcessor update(final String flowId, final VersionedProcessor requestComponentConfig) {
          final FDFlow currentFlow = getFlowOrNotFound(flowId);
          validateRequestValues(requestComponentConfig);
  
          final FDProcessor processor = updateExtensionComponent(currentFlow, requestComponentConfig, VersionedProcessGroup::getProcessors, this::validate);
          final String groupId = processor.getComponentConfiguration().getGroupIdentifier();
          ComponentUtils.populateControllerServicePropertyDescriptors(currentFlow, groupId, processor.getComponentDefinition());
          return processor;
      }
focal_method.class_method_signature: StandardFDProcessorService.update(final String flowId, final VersionedProcessor requestComponentConfig)
focal_method.full_signature: @Override public FDProcessor update(final String flowId, final VersionedProcessor requestComponentConfig)
focal_method.identifier: update
focal_method.invocations: getFlowOrNotFound validateRequestValues updateExtensionComponent getGroupIdentifier getComponentConfiguration populateControllerServicePropertyDescriptors getComponentDefinition
focal_method.modifiers: @Override public
focal_method.parameters: (final String flowId, final VersionedProcessor requestComponentConfig)
focal_method.return: FDProcessor
focal_method.signature: FDProcessor update(final String flowId, final VersionedProcessor requestComponentConfig)