@Test public void testGetHbaseStorageServiceConfigsWhenDataLake722() { TemplatePreparationObject preparationObject = getTemplatePreparationObject(true, true, "7.2.2"); String inputJson = getBlueprintText("input/clouderamanager.bp"); CmTemplateProcessor cmTemplateProcessor = new CmTemplateProcessor(inputJson); List<ApiClusterTemplateConfig> serviceConfigs = underTest.getServiceConfigs(cmTemplateProcessor, preparationObject); assertEquals(1, serviceConfigs.size()); assertEquals("hdfs_rootdir", serviceConfigs.get(0).getName()); assertEquals("s3a: }
@Override public List<ApiClusterTemplateConfig> getServiceConfigs(CmTemplateProcessor templateProcessor, TemplatePreparationObject source) { List<ApiClusterTemplateConfig> hbaseConfigs = new ArrayList<>(1); ConfigUtils.getStorageLocationForServiceProperty(source, HBASE_ROOT_DIR) .ifPresent(location -> hbaseConfigs.add(config(HBASE_ROOT_DIR_TEMPLATE_PARAM, location.getValue()))); return hbaseConfigs; }
HbaseCloudStorageServiceConfigProvider implements CmTemplateComponentConfigProvider { @Override public List<ApiClusterTemplateConfig> getServiceConfigs(CmTemplateProcessor templateProcessor, TemplatePreparationObject source) { List<ApiClusterTemplateConfig> hbaseConfigs = new ArrayList<>(1); ConfigUtils.getStorageLocationForServiceProperty(source, HBASE_ROOT_DIR) .ifPresent(location -> hbaseConfigs.add(config(HBASE_ROOT_DIR_TEMPLATE_PARAM, location.getValue()))); return hbaseConfigs; } }
HbaseCloudStorageServiceConfigProvider implements CmTemplateComponentConfigProvider { @Override public List<ApiClusterTemplateConfig> getServiceConfigs(CmTemplateProcessor templateProcessor, TemplatePreparationObject source) { List<ApiClusterTemplateConfig> hbaseConfigs = new ArrayList<>(1); ConfigUtils.getStorageLocationForServiceProperty(source, HBASE_ROOT_DIR) .ifPresent(location -> hbaseConfigs.add(config(HBASE_ROOT_DIR_TEMPLATE_PARAM, location.getValue()))); return hbaseConfigs; }  }
HbaseCloudStorageServiceConfigProvider implements CmTemplateComponentConfigProvider { @Override public List<ApiClusterTemplateConfig> getServiceConfigs(CmTemplateProcessor templateProcessor, TemplatePreparationObject source) { List<ApiClusterTemplateConfig> hbaseConfigs = new ArrayList<>(1); ConfigUtils.getStorageLocationForServiceProperty(source, HBASE_ROOT_DIR) .ifPresent(location -> hbaseConfigs.add(config(HBASE_ROOT_DIR_TEMPLATE_PARAM, location.getValue()))); return hbaseConfigs; }  @Override List<ApiClusterTemplateConfig> getServiceConfigs(CmTemplateProcessor templateProcessor, TemplatePreparationObject source); @Override String getServiceType(); @Override List<String> getRoleTypes(); @Override boolean isConfigurationNeeded(CmTemplateProcessor cmTemplateProcessor, TemplatePreparationObject source); }
HbaseCloudStorageServiceConfigProvider implements CmTemplateComponentConfigProvider { @Override public List<ApiClusterTemplateConfig> getServiceConfigs(CmTemplateProcessor templateProcessor, TemplatePreparationObject source) { List<ApiClusterTemplateConfig> hbaseConfigs = new ArrayList<>(1); ConfigUtils.getStorageLocationForServiceProperty(source, HBASE_ROOT_DIR) .ifPresent(location -> hbaseConfigs.add(config(HBASE_ROOT_DIR_TEMPLATE_PARAM, location.getValue()))); return hbaseConfigs; }  @Override List<ApiClusterTemplateConfig> getServiceConfigs(CmTemplateProcessor templateProcessor, TemplatePreparationObject source); @Override String getServiceType(); @Override List<String> getRoleTypes(); @Override boolean isConfigurationNeeded(CmTemplateProcessor cmTemplateProcessor, TemplatePreparationObject source);  }