This sketch samples data from a stream of items. More...

#include <var_opt_sketch.hpp>

Public Member Functions
	var_opt_sketch (uint32_t k, resize_factor rf=var_opt_constants::DEFAULT_RESIZE_FACTOR, const A &allocator=A())
	Constructor.

	var_opt_sketch (const var_opt_sketch &other)
	Copy constructor.

	var_opt_sketch (var_opt_sketch &&other) noexcept
	Move constructor.

var_opt_sketch &	operator= (const var_opt_sketch &other)
	Copy assignment.

var_opt_sketch &	operator= (var_opt_sketch &&other)
	Move assignment.

void	update (const T &item, double weight=1.0)
	Updates this sketch with the given data item with the given weight.

void	update (T &&item, double weight=1.0)
	Updates this sketch with the given data item with the given weight.

uint32_t	get_k () const
	Returns the configured maximum sample size.

uint64_t	get_n () const
	Returns the length of the input stream.

uint32_t	get_num_samples () const
	Returns the number of samples currently in the sketch.

template<typename P >
subset_summary	estimate_subset_sum (P predicate) const
	Computes an estimated subset sum from the entire stream for objects matching a given predicate.

bool	is_empty () const
	Returns true if the sketch is empty.

void	reset ()
	Resets the sketch to its default, empty state.

template<typename TT = T, typename SerDe = serde<T>, typename std::enable_if< std::is_arithmetic< TT >::value, int >::type = 0>
size_t	get_serialized_size_bytes (const SerDe &sd=SerDe()) const
	Computes size needed to serialize the current state of the sketch.

template<typename TT = T, typename SerDe = serde<T>, typename std::enable_if<!std::is_arithmetic< TT >::value, int >::type = 0>
size_t	get_serialized_size_bytes (const SerDe &sd=SerDe()) const
	Computes size needed to serialize the current state of the sketch.

template<typename SerDe = serde<T>>
vector_bytes	serialize (unsigned header_size_bytes=0, const SerDe &sd=SerDe()) const
	This method serializes the sketch as a vector of bytes.

template<typename SerDe = serde<T>>
void	serialize (std::ostream &os, const SerDe &sd=SerDe()) const
	This method serializes the sketch into a given stream in a binary form.

string< A >	to_string () const
	Prints a summary of the sketch.

string< A >	items_to_string () const
	Prints the raw sketch items to a string.

const_iterator	begin () const
	Iterator pointing to the first item in the sketch.

const_iterator	end () const
	Iterator pointing to the past-the-end item in the sketch.

Static Public Member Functions
template<typename SerDe = serde<T>>
static var_opt_sketch	deserialize (std::istream &is, const SerDe &sd=SerDe(), const A &allocator=A())
	This method deserializes a sketch from a given stream.

template<typename SerDe = serde<T>>
static var_opt_sketch	deserialize (const void *bytes, size_t size, const SerDe &sd=SerDe(), const A &allocator=A())
	This method deserializes a sketch from a given array of bytes.

Detailed Description

template<typename T, typename A = std::allocator<T>>
class datasketches::var_opt_sketch< T, A >

This sketch samples data from a stream of items.

Designed for optimal (minimum) variance when querying the sketch to estimate subset sums of items matching a provided predicate. Variance optimal (varopt) sampling is related to reservoir sampling, with improved error bounds for subset sum estimation.

author Kevin Lang author Jon Malkin

Constructor & Destructor Documentation

◆ var_opt_sketch() [1/3]

template<typename T , typename A >

var_opt_sketch	(	uint32_t	k,
		resize_factor	rf = `var_opt_constants::DEFAULT_RESIZE_FACTOR`,
		const A &	allocator = `A()`
	)

explicit

Constructor.

Parameters

k	sketch size
rf	resize factor
allocator	instance of an allocator

◆ var_opt_sketch() [2/3]

template<typename T , typename A >

var_opt_sketch ( const var_opt_sketch< T, A > & other )

Copy constructor.

Parameters

other sketch to be copied

◆ var_opt_sketch() [3/3]

template<typename T , typename A >

var_opt_sketch ( var_opt_sketch< T, A > && other )

noexcept

Move constructor.

Parameters

other sketch to be moved

Member Function Documentation

◆ operator=() [1/2]

template<typename T , typename A >

var_opt_sketch< T, A > & operator= ( const var_opt_sketch< T, A > & other )

Copy assignment.

Parameters

other sketch to be copied

Returns: reference to this sketch

◆ operator=() [2/2]

template<typename T , typename A >

var_opt_sketch< T, A > & operator= ( var_opt_sketch< T, A > && other )

Move assignment.

Parameters

other sketch to be moved

Returns: reference to this sketch

◆ update() [1/2]

template<typename T , typename A >

void update	(	const T &	item,
		double	weight = `1.0`
	)

Updates this sketch with the given data item with the given weight.

This method takes an lvalue.

Parameters

item	an item from a stream of items
weight	the weight of the item

◆ update() [2/2]

template<typename T , typename A >

void update	(	T &&	item,
		double	weight = `1.0`
	)

Updates this sketch with the given data item with the given weight.

This method takes an rvalue.

Parameters

item	an item from a stream of items
weight	the weight of the item

◆ get_k()

template<typename T , typename A >

uint32_t get_k ( ) const

inline

Returns the configured maximum sample size.

Returns: configured maximum sample size

◆ get_n()

template<typename T , typename A >

uint64_t get_n ( ) const

inline

Returns the length of the input stream.

Returns: stream length

◆ get_num_samples()

template<typename T , typename A >

uint32_t get_num_samples ( ) const

inline

Returns the number of samples currently in the sketch.

Returns: stream length

◆ estimate_subset_sum()

template<typename T , typename A >

template<typename P >

subset_summary estimate_subset_sum ( P predicate ) const

Computes an estimated subset sum from the entire stream for objects matching a given predicate.

Provides a lower bound, estimate, and upper bound using a target of 2 standard deviations. This is technically a heuristic method and tries to err on the conservative side.

Parameters

predicate a predicate function

Returns: a subset_summary item with estimate, upper and lower bounds, and total sketch weight

◆ is_empty()

template<typename T , typename A >

bool is_empty ( ) const

inline

Returns true if the sketch is empty.

Returns: empty flag

◆ get_serialized_size_bytes() [1/2]

template<typename T , typename A >

template<typename TT , typename SerDe , typename std::enable_if<!std::is_arithmetic< TT >::value, int >::type >

size_t get_serialized_size_bytes ( const SerDe & sd = SerDe() ) const

inline

Computes size needed to serialize the current state of the sketch.

This version is for fixed-size arithmetic types (integral and floating point).

Parameters

sd	instance of a SerDe

Returns: size in bytes needed to serialize this sketch

◆ get_serialized_size_bytes() [2/2]

template<typename T , typename A = std::allocator<T>>

template<typename TT = T, typename SerDe = serde<T>, typename std::enable_if<!std::is_arithmetic< TT >::value, int >::type = 0>

size_t get_serialized_size_bytes ( const SerDe & sd = SerDe() ) const

inline

Computes size needed to serialize the current state of the sketch.

This version is for all other types and can be expensive since every item needs to be looked at.

Parameters

sd	instance of a SerDe

Returns: size in bytes needed to serialize this sketch

◆ serialize() [1/2]

template<typename T , typename A = std::allocator<T>>

template<typename SerDe = serde<T>>

vector_bytes serialize	(	unsigned	header_size_bytes = `0`,
		const SerDe &	sd = `SerDe()`
	)		const

This method serializes the sketch as a vector of bytes.

An optional header can be reserved in front of the sketch. It is a blank space of a given size. This header is used in Datasketches PostgreSQL extension.

Parameters

header_size_bytes	space to reserve in front of the sketch
sd	instance of a SerDe

◆ serialize() [2/2]

template<typename T , typename A >

template<typename SerDe >

void serialize	(	std::ostream &	os,
		const SerDe &	sd = `SerDe()`
	)		const

This method serializes the sketch into a given stream in a binary form.

Parameters

os	output stream
sd	instance of a SerDe

◆ deserialize() [1/2]

template<typename T , typename A = std::allocator<T>>

template<typename SerDe = serde<T>>

static var_opt_sketch deserialize	(	std::istream &	is,
		const SerDe &	sd = `SerDe()`,
		const A &	allocator = `A()`
	)

static

This method deserializes a sketch from a given stream.

Parameters

is	input stream
sd	instance of a SerDe
allocator	instance of an allocator

Returns: an instance of a sketch

◆ deserialize() [2/2]

template<typename T , typename A = std::allocator<T>>

template<typename SerDe = serde<T>>

static var_opt_sketch deserialize	(	const void *	bytes,
		size_t	size,
		const SerDe &	sd = `SerDe()`,
		const A &	allocator = `A()`
	)

static

This method deserializes a sketch from a given array of bytes.

Parameters

bytes	pointer to the array of bytes
size	the size of the array
sd	instance of a SerDe
allocator	instance of an allocator

Returns: an instance of a sketch

◆ to_string()

template<typename T , typename A >

string< A > to_string ( ) const

Prints a summary of the sketch.

Returns: the summary as a string

◆ items_to_string()

template<typename T , typename A >

string< A > items_to_string ( ) const

Prints the raw sketch items to a string.

Calls items_to_stream() internally. Only works for type T with a defined std::ostream& operator<<(std::ostream&, const T&) and kept separate from to_string() to allow compilation even if T does not have such an operator defined.

Returns: a string with the sketch items

◆ begin()

template<typename T , typename A >

var_opt_sketch< T, A >::const_iterator begin ( ) const

Iterator pointing to the first item in the sketch.

If the sketch is empty, the returned iterator must not be dereferenced or incremented.

Returns: iterator pointing to the first item in the sketch

◆ end()

template<typename T , typename A >

var_opt_sketch< T, A >::const_iterator end ( ) const

Iterator pointing to the past-the-end item in the sketch.

The past-the-end item is the hypothetical item that would follow the last item. It does not point to any item, and must not be dereferenced or incremented.

Returns: iterator pointing to the past-the-end item in the sketch

The documentation for this class was generated from the following files:

sampling/include/var_opt_sketch.hpp
sampling/include/var_opt_sketch_impl.hpp

Public Member Functions

Static Public Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ var_opt_sketch() [1/3]

◆ var_opt_sketch() [2/3]

◆ var_opt_sketch() [3/3]

Member Function Documentation

◆ operator=() [1/2]

◆ operator=() [2/2]

◆ update() [1/2]

◆ update() [2/2]

◆ get_k()

◆ get_n()

◆ get_num_samples()

◆ estimate_subset_sum()

◆ is_empty()

◆ get_serialized_size_bytes() [1/2]

◆ get_serialized_size_bytes() [2/2]

◆ serialize() [1/2]

◆ serialize() [2/2]

◆ deserialize() [1/2]

◆ deserialize() [2/2]

◆ to_string()

◆ items_to_string()

◆ begin()

◆ end()