@Test public void getFirehoseHeapsizeWhenDLAndRegionServerInTheBlueprintShouldReturnHighMemoryforDL() { Assert.assertEquals("3221225472", underTest.firehoseHeapsize(StackType.DATALAKE, Sets.newHashSet("REGIONSERVER"))); }
public String firehoseHeapsize(StackType stackType, Set<String> componentsByHostGroup) { if (isDataLake(stackType)) { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datalakeNormalFirehoseHeapsize, datalakeExtensiveFirehoseHeapsize); } else { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datahubNormalFirehoseHeapsize, datahubExtensiveFirehoseHeapsize); } }
SMONMemoryWorkaroundService { public String firehoseHeapsize(StackType stackType, Set<String> componentsByHostGroup) { if (isDataLake(stackType)) { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datalakeNormalFirehoseHeapsize, datalakeExtensiveFirehoseHeapsize); } else { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datahubNormalFirehoseHeapsize, datahubExtensiveFirehoseHeapsize); } } }
SMONMemoryWorkaroundService { public String firehoseHeapsize(StackType stackType, Set<String> componentsByHostGroup) { if (isDataLake(stackType)) { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datalakeNormalFirehoseHeapsize, datalakeExtensiveFirehoseHeapsize); } else { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datahubNormalFirehoseHeapsize, datahubExtensiveFirehoseHeapsize); } }  }
SMONMemoryWorkaroundService { public String firehoseHeapsize(StackType stackType, Set<String> componentsByHostGroup) { if (isDataLake(stackType)) { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datalakeNormalFirehoseHeapsize, datalakeExtensiveFirehoseHeapsize); } else { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datahubNormalFirehoseHeapsize, datahubExtensiveFirehoseHeapsize); } }  String firehoseHeapsize(StackType stackType, Set<String> componentsByHostGroup); String firehoseNonJavaMemoryBytes(StackType stackType, Set<String> componentsByHostGroup); }
SMONMemoryWorkaroundService { public String firehoseHeapsize(StackType stackType, Set<String> componentsByHostGroup) { if (isDataLake(stackType)) { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datalakeNormalFirehoseHeapsize, datalakeExtensiveFirehoseHeapsize); } else { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datahubNormalFirehoseHeapsize, datahubExtensiveFirehoseHeapsize); } }  String firehoseHeapsize(StackType stackType, Set<String> componentsByHostGroup); String firehoseNonJavaMemoryBytes(StackType stackType, Set<String> componentsByHostGroup);  }