Package | Description |
---|---|
org.apache.datasketches.sampling |
This package is dedicated to streaming algorithms that enable fixed size, uniform sampling of
unweighted items from a stream.
|
Modifier and Type | Method and Description |
---|---|
ReservoirItemsSketch<T> |
ReservoirItemsUnion.getResult()
Returns a sketch representing the current state of the union.
|
static <T> ReservoirItemsSketch<T> |
ReservoirItemsSketch.heapify(org.apache.datasketches.memory.Memory srcMem,
ArrayOfItemsSerDe<T> serDe)
Returns a sketch instance of this class from the given srcMem,
which must be a Memory representation of this sketch class.
|
static <T> ReservoirItemsSketch<T> |
ReservoirItemsSketch.newInstance(int k)
Construct a mergeable sampling sketch with up to k samples using the default resize
factor (8).
|
static <T> ReservoirItemsSketch<T> |
ReservoirItemsSketch.newInstance(int k,
ResizeFactor rf)
Construct a mergeable sampling sketch with up to k samples using a specified resize factor.
|
Modifier and Type | Method and Description |
---|---|
void |
VarOptItemsUnion.update(ReservoirItemsSketch<T> reservoirIn)
Union a reservoir sketch.
|
void |
ReservoirItemsUnion.update(ReservoirItemsSketch<T> sketchIn)
Union the given sketch.
|
Copyright © 2015–2021 The Apache Software Foundation. All rights reserved.