public class ThresholdPolicyFactory extends Object
Constructor and Description |
---|
ThresholdPolicyFactory() |
Modifier and Type | Method and Description |
---|---|
static <E> ThresholdPolicy<E> |
count(long threshold)
A threshold policy based on the number of tuples added.
|
static <E> ThresholdPolicy<E> |
never()
A threshold policy that is never exceeded.
|
static <E> ThresholdPolicy<E> |
policyFromContext(Context context)
A threshold policy based on the
ARQ.spillToDiskThreshold symbol in the given Context. |
public static final <E> ThresholdPolicy<E> never()
public static <E> ThresholdPolicy<E> count(long threshold)
public static <E> ThresholdPolicy<E> policyFromContext(Context context)
ARQ.spillToDiskThreshold
symbol in the given Context.
If the symbol is not set, then the never()
policy is used by default.Licenced under the Apache License, Version 2.0