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