test_class.declarator: service
test_class.modifier: private
test_class.original_string: private FDRemoteProcessGroupService service;
test_class.type: FDRemoteProcessGroupService
test_class.var_name: service
test_class.file: efm/efm-flow-designer/efm-flow-designer-framework/src/test/java/com/cloudera/cem/efm/service/component/TestStandardFDRemoteProcessGroupService.java
test_class.identifier: TestStandardFDRemoteProcessGroupService
test_class.superclass: extends BaseFDServiceTest
test_case.body: @Test
      public void testUpdateSuccess() {
          final String flowId = flow.getFlowMetadata().getIdentifier();
          when(flowManager.getFlow(flowId)).thenReturn(Optional.of(flow));
  
          final String updatedTargetUris = "http://updated";
          final String updatedCommsTimeout = "1 seconds";
          final String updatedYieldDuration = "1 seconds";
          final String updatedTransportProtocol = "HTTP";
  
          assertNotEquals(updatedTargetUris, remoteProcessGroup.getTargetUris());
          assertNotEquals(updatedCommsTimeout, remoteProcessGroup.getCommunicationsTimeout());
          assertNotEquals(updatedYieldDuration, remoteProcessGroup.getYieldDuration());
          assertNotEquals(updatedTransportProtocol, remoteProcessGroup.getTransportProtocol());
  
          final VersionedRemoteProcessGroup requestConfig = new VersionedRemoteProcessGroup();
          requestConfig.setIdentifier(remoteProcessGroup.getIdentifier());
          requestConfig.setTargetUris(updatedTargetUris);
          requestConfig.setCommunicationsTimeout(updatedCommsTimeout);
          requestConfig.setYieldDuration(updatedYieldDuration);
          requestConfig.setTransportProtocol(updatedTransportProtocol);
  
          final FDRemoteProcessGroup updatedRemoteProcessGroup = service.update(flowId, requestConfig);
          assertNotNull(updatedRemoteProcessGroup);
          assertEquals(requestConfig.getIdentifier(), updatedRemoteProcessGroup.getComponentConfiguration().getIdentifier());
          assertEquals(updatedTargetUris, updatedRemoteProcessGroup.getComponentConfiguration().getTargetUris());
          assertEquals(updatedCommsTimeout, updatedRemoteProcessGroup.getComponentConfiguration().getCommunicationsTimeout());
          assertEquals(updatedYieldDuration, updatedRemoteProcessGroup.getComponentConfiguration().getYieldDuration());
          assertEquals(updatedTransportProtocol, updatedRemoteProcessGroup.getComponentConfiguration().getTransportProtocol());
      }
test_case.class_method_signature: TestStandardFDRemoteProcessGroupService.testUpdateSuccess()
test_case.full_signature: @Test public void testUpdateSuccess()
test_case.identifier: testUpdateSuccess
test_case.invocations: getIdentifier getFlowMetadata thenReturn when getFlow of assertNotEquals getTargetUris assertNotEquals getCommunicationsTimeout assertNotEquals getYieldDuration assertNotEquals getTransportProtocol setIdentifier getIdentifier setTargetUris setCommunicationsTimeout setYieldDuration setTransportProtocol update assertNotNull assertEquals getIdentifier getIdentifier getComponentConfiguration assertEquals getTargetUris getComponentConfiguration assertEquals getCommunicationsTimeout getComponentConfiguration assertEquals getYieldDuration getComponentConfiguration assertEquals getTransportProtocol getComponentConfiguration
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testUpdateSuccess()
focal_class.declarator: TRANSPORT_PROTOCOL_RAW = "RAW"
focal_class.modifier: static final
focal_class.original_string: static final String TRANSPORT_PROTOCOL_RAW = "RAW";
focal_class.type: String
focal_class.var_name: TRANSPORT_PROTOCOL_RAW
focal_class.declarator: TRANSPORT_PROOTOCOL_HTTP = "HTTP"
focal_class.modifier: static final
focal_class.original_string: static final String TRANSPORT_PROOTOCOL_HTTP = "HTTP";
focal_class.type: String
focal_class.var_name: TRANSPORT_PROOTOCOL_HTTP
focal_class.declarator: DEFAULT_TRANSPORT_PROTOCOL = TRANSPORT_PROTOCOL_RAW
focal_class.modifier: static final
focal_class.original_string: static final String DEFAULT_TRANSPORT_PROTOCOL = TRANSPORT_PROTOCOL_RAW;
focal_class.type: String
focal_class.var_name: DEFAULT_TRANSPORT_PROTOCOL
focal_class.declarator: DEFAULT_YIELD_DURATION = "10 sec"
focal_class.modifier: static final
focal_class.original_string: static final String DEFAULT_YIELD_DURATION = "10 sec";
focal_class.type: String
focal_class.var_name: DEFAULT_YIELD_DURATION
focal_class.declarator: DEFAULT_COMMUNICATION_TIMEOUT = "30 secs"
focal_class.modifier: static final
focal_class.original_string: static final String DEFAULT_COMMUNICATION_TIMEOUT = "30 secs";
focal_class.type: String
focal_class.var_name: DEFAULT_COMMUNICATION_TIMEOUT
focal_class.file: efm/efm-flow-designer/efm-flow-designer-framework/src/main/java/com/cloudera/cem/efm/service/component/StandardFDRemoteProcessGroupService.java
focal_class.identifier: StandardFDRemoteProcessGroupService
focal_class.interfaces: implements FDRemoteProcessGroupService
focal_class.class_method_signature: StandardFDRemoteProcessGroupService.StandardFDRemoteProcessGroupService(final FDFlowManager flowManager, final ValidationService validationService)
focal_class.full_signature: public  StandardFDRemoteProcessGroupService(final FDFlowManager flowManager, final ValidationService validationService)
focal_class.identifier: StandardFDRemoteProcessGroupService
focal_class.modifiers: public
focal_class.parameters: (final FDFlowManager flowManager, final ValidationService validationService)
focal_class.signature:  StandardFDRemoteProcessGroupService(final FDFlowManager flowManager, final ValidationService validationService)
focal_class.class_method_signature: StandardFDRemoteProcessGroupService.create(final String flowId, final String processGroupId, final VersionedRemoteProcessGroup requestComponentConfig)
focal_class.full_signature: @Override public FDRemoteProcessGroup create(final String flowId, final String processGroupId, final VersionedRemoteProcessGroup requestComponentConfig)
focal_class.identifier: create
focal_class.modifiers: @Override public
focal_class.parameters: (final String flowId, final String processGroupId, final VersionedRemoteProcessGroup requestComponentConfig)
focal_class.return: FDRemoteProcessGroup
focal_class.signature: FDRemoteProcessGroup create(final String flowId, final String processGroupId, final VersionedRemoteProcessGroup requestComponentConfig)
focal_class.class_method_signature: StandardFDRemoteProcessGroupService.get(final String flowId, final String componentId)
focal_class.full_signature: @Override public FDRemoteProcessGroup get(final String flowId, final String componentId)
focal_class.identifier: get
focal_class.modifiers: @Override public
focal_class.parameters: (final String flowId, final String componentId)
focal_class.return: FDRemoteProcessGroup
focal_class.signature: FDRemoteProcessGroup get(final String flowId, final String componentId)
focal_class.class_method_signature: StandardFDRemoteProcessGroupService.update(final String flowId, final VersionedRemoteProcessGroup requestComponentConfig)
focal_class.full_signature: @Override public FDRemoteProcessGroup update(final String flowId, final VersionedRemoteProcessGroup requestComponentConfig)
focal_class.identifier: update
focal_class.modifiers: @Override public
focal_class.parameters: (final String flowId, final VersionedRemoteProcessGroup requestComponentConfig)
focal_class.return: FDRemoteProcessGroup
focal_class.signature: FDRemoteProcessGroup update(final String flowId, final VersionedRemoteProcessGroup requestComponentConfig)
focal_class.class_method_signature: StandardFDRemoteProcessGroupService.delete(final String flowId, final String componentId)
focal_class.full_signature: @Override public void delete(final String flowId, final String componentId)
focal_class.identifier: delete
focal_class.modifiers: @Override public
focal_class.parameters: (final String flowId, final String componentId)
focal_class.return: void
focal_class.signature: void delete(final String flowId, final String componentId)
focal_class.class_method_signature: StandardFDRemoteProcessGroupService.instantiateComponent(final VersionedRemoteProcessGroup componentConfig)
focal_class.full_signature: @Override protected FDRemoteProcessGroup instantiateComponent(final VersionedRemoteProcessGroup componentConfig)
focal_class.identifier: instantiateComponent
focal_class.modifiers: @Override protected
focal_class.parameters: (final VersionedRemoteProcessGroup componentConfig)
focal_class.return: FDRemoteProcessGroup
focal_class.signature: FDRemoteProcessGroup instantiateComponent(final VersionedRemoteProcessGroup componentConfig)
focal_class.class_method_signature: StandardFDRemoteProcessGroupService.configureComponentSpecifics(final VersionedRemoteProcessGroup requestComponent, final VersionedRemoteProcessGroup resultComponent)
focal_class.full_signature: @Override protected void configureComponentSpecifics(final VersionedRemoteProcessGroup requestComponent, final VersionedRemoteProcessGroup resultComponent)
focal_class.identifier: configureComponentSpecifics
focal_class.modifiers: @Override protected
focal_class.parameters: (final VersionedRemoteProcessGroup requestComponent, final VersionedRemoteProcessGroup resultComponent)
focal_class.return: void
focal_class.signature: void configureComponentSpecifics(final VersionedRemoteProcessGroup requestComponent, final VersionedRemoteProcessGroup resultComponent)
focal_class.class_method_signature: StandardFDRemoteProcessGroupService.validateRequestValues(final VersionedRemoteProcessGroup requestComponent)
focal_class.full_signature: private void validateRequestValues(final VersionedRemoteProcessGroup requestComponent)
focal_class.identifier: validateRequestValues
focal_class.modifiers: private
focal_class.parameters: (final VersionedRemoteProcessGroup requestComponent)
focal_class.return: void
focal_class.signature: void validateRequestValues(final VersionedRemoteProcessGroup requestComponent)
focal_class.class_method_signature: StandardFDRemoteProcessGroupService.validateTargetUris(final String targetUris)
focal_class.full_signature: private static void validateTargetUris(final String targetUris)
focal_class.identifier: validateTargetUris
focal_class.modifiers: private static
focal_class.parameters: (final String targetUris)
focal_class.return: void
focal_class.signature: void validateTargetUris(final String targetUris)
focal_class.class_method_signature: StandardFDRemoteProcessGroupService.validateUriString(String s)
focal_class.full_signature: private static void validateUriString(String s)
focal_class.identifier: validateUriString
focal_class.modifiers: private static
focal_class.parameters: (String s)
focal_class.return: void
focal_class.signature: void validateUriString(String s)
focal_class.superclass: extends BaseComponentService<VersionedRemoteProcessGroup,FDRemoteProcessGroup>
focal_method.body: @Override
      public FDRemoteProcessGroup update(final String flowId, final VersionedRemoteProcessGroup requestComponentConfig) {
          validateRequestValues(requestComponentConfig);
          return updateComponent(flowId, requestComponentConfig, VersionedProcessGroup::getRemoteProcessGroups, null);
      }
focal_method.class_method_signature: StandardFDRemoteProcessGroupService.update(final String flowId, final VersionedRemoteProcessGroup requestComponentConfig)
focal_method.full_signature: @Override public FDRemoteProcessGroup update(final String flowId, final VersionedRemoteProcessGroup requestComponentConfig)
focal_method.identifier: update
focal_method.invocations: validateRequestValues updateComponent
focal_method.modifiers: @Override public
focal_method.parameters: (final String flowId, final VersionedRemoteProcessGroup requestComponentConfig)
focal_method.return: FDRemoteProcessGroup
focal_method.signature: FDRemoteProcessGroup update(final String flowId, final VersionedRemoteProcessGroup requestComponentConfig)