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 testCreateSuccessWithDefaults() {
          final String flowId = flow.getFlowMetadata().getIdentifier();
          when(flowManager.getFlow(flowId)).thenReturn(Optional.of(flow));
  
          final VersionedRemoteProcessGroup requestConfig = new VersionedRemoteProcessGroup();
          requestConfig.setTargetUris("http://host1,http://host2");
  
          final FDRemoteProcessGroup createdRemoteProcessGroup = service.create(flowId, group1.getIdentifier(), requestConfig);
          assertNotNull(createdRemoteProcessGroup);
          assertEquals(requestConfig.getTargetUris(), createdRemoteProcessGroup.getComponentConfiguration().getTargetUris());
      }
test_case.class_method_signature: TestStandardFDRemoteProcessGroupService.testCreateSuccessWithDefaults()
test_case.full_signature: @Test public void testCreateSuccessWithDefaults()
test_case.identifier: testCreateSuccessWithDefaults
test_case.invocations: getIdentifier getFlowMetadata thenReturn when getFlow of setTargetUris create getIdentifier assertNotNull assertEquals getTargetUris getTargetUris getComponentConfiguration
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testCreateSuccessWithDefaults()
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 create(final String flowId, final String processGroupId, final VersionedRemoteProcessGroup requestComponentConfig) {
          final String targetUris = requestComponentConfig.getTargetUris();
          if (StringUtils.isBlank(targetUris)) {
              throw new IllegalArgumentException("Cannot add a Remote Process Group without specifying the Target URI(s)");
          }
  
          validateRequestValues(requestComponentConfig);
  
          return createComponent(
                  flowId,
                  processGroupId,
                  null,
                  requestComponentConfig,
                  () -> {
                      final VersionedRemoteProcessGroup componentConfig = new VersionedRemoteProcessGroup();
                      componentConfig.setTransportProtocol(DEFAULT_TRANSPORT_PROTOCOL);
                      componentConfig.setCommunicationsTimeout(DEFAULT_COMMUNICATION_TIMEOUT);
                      componentConfig.setYieldDuration(DEFAULT_YIELD_DURATION);
                      componentConfig.setLocalNetworkInterface("");
                      componentConfig.setProxyHost("");
                      componentConfig.setInputPorts(new HashSet<>());
                      componentConfig.setOutputPorts(new HashSet<>());
  
                      final FDRemoteProcessGroup component = new FDRemoteProcessGroup();
                      component.setComponentConfiguration(componentConfig);
                      return component;
                  },
                  VersionedProcessGroup::getRemoteProcessGroups,
                  null);
      }
focal_method.class_method_signature: StandardFDRemoteProcessGroupService.create(final String flowId, final String processGroupId, final VersionedRemoteProcessGroup requestComponentConfig)
focal_method.full_signature: @Override public FDRemoteProcessGroup create(final String flowId, final String processGroupId, final VersionedRemoteProcessGroup requestComponentConfig)
focal_method.identifier: create
focal_method.invocations: getTargetUris isBlank validateRequestValues createComponent setTransportProtocol setCommunicationsTimeout setYieldDuration setLocalNetworkInterface setProxyHost setInputPorts setOutputPorts setComponentConfiguration
focal_method.modifiers: @Override public
focal_method.parameters: (final String flowId, final String processGroupId, final VersionedRemoteProcessGroup requestComponentConfig)
focal_method.return: FDRemoteProcessGroup
focal_method.signature: FDRemoteProcessGroup create(final String flowId, final String processGroupId, final VersionedRemoteProcessGroup requestComponentConfig)