@Test public void getFirehoseNonJavaMemoryBytesWhenDLAndNoRegionServerInTheBlueprintShouldReturnLowMemoryforDL() { Assert.assertEquals("1073741824", underTest.firehoseNonJavaMemoryBytes(StackType.DATALAKE, Sets.newHashSet())); }
public String firehoseNonJavaMemoryBytes(StackType stackType, Set<String> componentsByHostGroup) { if (isDataLake(stackType)) { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datalakeNormalFirehoseNonJavaMemoryBytes, datalakeExtensiveFirehoseNonJavaMemoryBytes); } else { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datahubNormalFirehoseNonJavaMemoryBytes, datahubExtensiveFirehoseNonJavaMemoryBytes); } }
SMONMemoryWorkaroundService { public String firehoseNonJavaMemoryBytes(StackType stackType, Set<String> componentsByHostGroup) { if (isDataLake(stackType)) { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datalakeNormalFirehoseNonJavaMemoryBytes, datalakeExtensiveFirehoseNonJavaMemoryBytes); } else { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datahubNormalFirehoseNonJavaMemoryBytes, datahubExtensiveFirehoseNonJavaMemoryBytes); } } }
SMONMemoryWorkaroundService { public String firehoseNonJavaMemoryBytes(StackType stackType, Set<String> componentsByHostGroup) { if (isDataLake(stackType)) { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datalakeNormalFirehoseNonJavaMemoryBytes, datalakeExtensiveFirehoseNonJavaMemoryBytes); } else { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datahubNormalFirehoseNonJavaMemoryBytes, datahubExtensiveFirehoseNonJavaMemoryBytes); } }  }
SMONMemoryWorkaroundService { public String firehoseNonJavaMemoryBytes(StackType stackType, Set<String> componentsByHostGroup) { if (isDataLake(stackType)) { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datalakeNormalFirehoseNonJavaMemoryBytes, datalakeExtensiveFirehoseNonJavaMemoryBytes); } else { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datahubNormalFirehoseNonJavaMemoryBytes, datahubExtensiveFirehoseNonJavaMemoryBytes); } }  String firehoseHeapsize(StackType stackType, Set<String> componentsByHostGroup); String firehoseNonJavaMemoryBytes(StackType stackType, Set<String> componentsByHostGroup); }
SMONMemoryWorkaroundService { public String firehoseNonJavaMemoryBytes(StackType stackType, Set<String> componentsByHostGroup) { if (isDataLake(stackType)) { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datalakeNormalFirehoseNonJavaMemoryBytes, datalakeExtensiveFirehoseNonJavaMemoryBytes); } else { return calculateSmonMemoryParameterBasedOnServices( stackType, componentsByHostGroup, datahubNormalFirehoseNonJavaMemoryBytes, datahubExtensiveFirehoseNonJavaMemoryBytes); } }  String firehoseHeapsize(StackType stackType, Set<String> componentsByHostGroup); String firehoseNonJavaMemoryBytes(StackType stackType, Set<String> componentsByHostGroup);  }