RecordCountVarianceValidator- support dynamic threshold

Author: Sunjeet

hollow/src/main/java/com/netflix/hollow/api/producer/validation/RecordCountVarianceValidator.java

@@ -18,6 +18,7 @@
 
 import com.netflix.hollow.api.producer.HollowProducer.ReadState;
 import com.netflix.hollow.core.read.engine.HollowTypeReadState;
+import java.util.function.Supplier;
 
 /**
  * Used to validate if the cardinality change in current cycle is with in the allowed percent for a given typeName.
@@ -46,7 +47,7 @@ public class RecordCountVarianceValidator implements ValidatorListener {
 
     private final String typeName;
 
-    private final float allowableVariancePercent;
+    private final Supplier<Float> allowableVariancePercentSupplier;
 
     /**
      * @param typeName type name
@@ -58,13 +59,27 @@ public class RecordCountVarianceValidator implements ValidatorListener {
      * Anything more results in failure of validation.
      */
     public RecordCountVarianceValidator(String typeName, float allowableVariancePercent) {
+        this(typeName, () -> allowableVariancePercent);
+    }
+
+    /**
+     * @param typeName type name
+     * @param allowableVariancePercentSupplier: Used to validate if the cardinality change in current cycle is with in the
+     * allowed percent, and changes to this threshold are applied in the next invocation of validation.
+     * Ex: 0% allowableVariancePercent ensures type cardinality does not vary at all for cycle to cycle.
+     * Ex: Number of state in United States.
+     * 10% allowableVariancePercent: from previous cycle any addition or removal within 10% cardinality is valid.
+     * Anything more results in failure of validation.
+     */
+    public RecordCountVarianceValidator(String typeName, Supplier<Float> allowableVariancePercentSupplier)  {
         this.typeName = typeName;
-        if (allowableVariancePercent < 0) {
+        this.allowableVariancePercentSupplier = allowableVariancePercentSupplier;
+        Float allowableVariancePercent = allowableVariancePercentSupplier.get();
+        if (allowableVariancePercent == null || allowableVariancePercent < 0) {
             throw new IllegalArgumentException("RecordCountVarianceValidator for type " + typeName
                     + ": cannot have allowableVariancePercent less than 0. Value provided: "
                     + allowableVariancePercent);
         }
-        this.allowableVariancePercent = allowableVariancePercent;
     }
 
     @Override
@@ -74,6 +89,7 @@ public String getName() {
 
     @Override
     public ValidationResult onValidate(ReadState readState) {
+        Float allowableVariancePercent = allowableVariancePercentSupplier.get();
         ValidationResult.ValidationResultBuilder vrb = ValidationResult.from(this);
         vrb.detail(ALLOWABLE_VARIANCE_PERCENT_NAME, allowableVariancePercent)
                 .detail(DATA_TYPE_NAME, typeName);
@@ -92,7 +108,7 @@ public ValidationResult onValidate(ReadState readState) {
         float actualChangePercent = getChangePercent(latestCardinality, previousCardinality);
         vrb.detail(ACTUAL_CHANGE_PERCENT_NAME, actualChangePercent);
 
-        if (Float.compare(actualChangePercent, allowableVariancePercent) > 0) {
+        if (allowableVariancePercent == null || Float.compare(actualChangePercent, allowableVariancePercent) > 0) {
             String message = String.format(FAILED_RECORD_COUNT_VALIDATION, typeName, actualChangePercent,
                     allowableVariancePercent);
             return vrb.failed(message);

hollow/src/test/java/com/netflix/hollow/api/producer/validation/HollowProducerValidationListenerTest.java

@@ -90,7 +90,7 @@ public void testValidationListenerWithOnlyRecordCountValidator() {
 
     private void createHollowProducerAndRunCycle(final String typeName, boolean addPrimaryKeyValidator) {
         ValidatorListener dupeValidator = new DuplicateDataDetectionValidator(typeName);
-        ValidatorListener countValidator = new RecordCountVarianceValidator(typeName, 3.0f);
+        ValidatorListener countValidator = new RecordCountVarianceValidator(typeName, () -> 3.0f);
         validationListener = new TestValidationStatusListener();
         cycleAndValidationListener = new TestCycleAndValidationStatusListener();
         Builder builder = HollowProducer.withPublisher(publisher).withAnnouncer(announcer)