Class ThresholdPolicyFactory


public class ThresholdPolicyFactory extends Object
  • Constructor Details

    • ThresholdPolicyFactory

      public ThresholdPolicyFactory()
  • Method Details

    • never

      public static final <E> ThresholdPolicy<E> never()
      A threshold policy that is never exceeded.
    • count

      public static <E> ThresholdPolicy<E> count(long threshold)
      A threshold policy based on the number of tuples added.
    • policyFromContext

      public static <E> ThresholdPolicy<E> policyFromContext(Context context)
      A threshold policy based on the ARQ.spillToDiskThreshold symbol in the given Context. If the symbol is not set, then the never() policy is used by default.