Interface | Description |
---|---|
DataBag<T> |
A collection of Tuples.
|
SerializationFactory<E> | |
ThresholdPolicy<E> |
Class | Description |
---|---|
AbstractDataBag<E> |
Abstract implementation of DataBag.
|
BagFactory |
Factory for constructing different types of
DataBag instances. |
DefaultDataBag<E> |
This data bag will gather items in memory until a size threshold is passed, at which point it will write
out all of the items to disk using the supplied serializer.
|
DistinctDataBag<E> |
This data bag will gather distinct items in memory until a size threshold is passed, at which point it will write
out all of the items to disk using the supplied serializer.
|
DistinctDataNet<E> |
This class is like
DistinctDataBag except that you are informed if the item you just
added was known to be distinct. |
SortedDataBag<E> |
This data bag will gather items in memory until a size threshold is passed, at which point it will write
out all of the items to disk using the supplied serializer.
|
ThresholdPolicyCount<T> |
A threshold policy based on the number of tuples added.
|
ThresholdPolicyFactory | |
ThresholdPolicyMemory<T> |
A threshold policy based on the estimated memory size of the tuples added.
|
Licenced under the Apache License, Version 2.0