@Test public void getFirehoseHeapsizeWhenDHAndNoRegionServerInTheBlueprintShouldReturnLowMemoryforDH() { Assert.assertEquals("2147483648", underTest.firehoseHeapsize(StackType.WORKLOAD, Sets.newHashSet())); }
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);  }