NES::Statistic Namespace Reference

Classes
class	AbstractStatisticQueryGenerator
	Interface for creating a statistic query. More...
class	DefaultStatisticQueryGenerator
	Generates a statistic query by a simple mapping strategy of metric types -—> Synopsis. More...
class	StatisticIdsExtractor
class	StatisticInterface
class	DummyStatistic
	Dummy statistic so that we can test our DefaultStatisticStore. More...
class	DefaultStatisticStoreTest
class	AbstractStatisticFormat
	An interface for parsing (reading and creating) statistics from/to a TupleBuffer. The idea is that this format is called in the StatisticSink as well as the operator handler and returns multiple statistics that are then inserted into a StatisticStorage. More...
class	CountMinStatisticFormat
	StatisticSinkFormat that creates/builds CountMin-Sketches from a tuple buffer. More...
class	HyperLogLogStatisticFormat
	StatisticSinkFormat that creates/builds HyperLogLog-Sketches from a tuple buffer. More...
class	StatisticFormatFactory
	Factory for creating StatisticSinkFormat. More...
class	StatisticSink
	Physical sink that receives a tuple buffer, extracts statistics, and writes these statistics to the statisticStore. More...
class	StatisticManager
class	AbstractStatisticStore
	An interface for any statistic store. More...
class	DefaultStatisticStore
	This is a thread-safe StatisticStore that simply stores all data in an unordered_map that is made thread-safe by using folly::Synchronized. More...

Typedefs
using	StatisticProbeHandlerPtr = std::shared_ptr< StatisticProbeHandler >
using	CharacteristicPtr = std::shared_ptr< Characteristic >
using	TriggerConditionPtr = std::shared_ptr< TriggerCondition >
using	SendingPolicyPtr = std::shared_ptr< SendingPolicy >
using	AbstractStatisticQueryGeneratorPtr = std::shared_ptr< AbstractStatisticQueryGenerator >
using	StatisticRegistryPtr = std::shared_ptr< StatisticRegistry >
using	StatisticQueryGeneratorPtr = std::shared_ptr< AbstractStatisticQueryGenerator >
using	StatisticPtr = std::shared_ptr< Statistic >
using	HashStatisticPair = std::pair< StatisticHash, StatisticPtr >
using	StatisticFormatPtr = std::shared_ptr< AbstractStatisticFormat >
using	StatisticStorePtr = std::shared_ptr< AbstractStatisticStore >
using	StatisticManagerPtr = std::shared_ptr< StatisticManager >

Enumerations
enum class	StatisticSynopsisType : uint8_t { COUNT_MIN , HLL }
enum class	StatisticDataCodec : uint8_t { DEFAULT }

Functions
	TEST_F (DefaultStatisticStoreTest, singleItem)
	Tests, if we can insert, get and delete one single Statistic. More...
	TEST_P (DefaultStatisticStoreTest, multipleItem)
	Tests, if we can insert, get and delete multiple items. More...
	INSTANTIATE_TEST_CASE_P (testDefaultStatisticStore, DefaultStatisticStoreTest, ::testing::Combine(::testing::Values(1, 2, 4, 8), ::testing::Values(1, 5, 10), ::testing::Values(1, 500, 1000)), [](const testing::TestParamInfo< DefaultStatisticStoreTest::ParamType > &info) { return std::string(std::to_string(std::get< 0 >(info.param))+"_Threads"+std::to_string(std::get< 1 >(info.param))+"_StatisticKey"+std::to_string(std::get< 2 >(info.param))+"_StatisticsPerKey");})

Typedef Documentation

AbstractStatisticQueryGeneratorPtr

using NES::Statistic::AbstractStatisticQueryGeneratorPtr = typedef std::shared_ptr<AbstractStatisticQueryGenerator>

CharacteristicPtr

using NES::Statistic::CharacteristicPtr = typedef std::shared_ptr<Characteristic>

HashStatisticPair

typedef std::pair< StatisticHash, StatisticPtr > NES::Statistic::HashStatisticPair

SendingPolicyPtr

using NES::Statistic::SendingPolicyPtr = typedef std::shared_ptr<SendingPolicy>

StatisticFormatPtr

typedef std::shared_ptr< AbstractStatisticFormat > NES::Statistic::StatisticFormatPtr

StatisticManagerPtr

using NES::Statistic::StatisticManagerPtr = typedef std::shared_ptr<StatisticManager>

StatisticProbeHandlerPtr

typedef std::shared_ptr< StatisticProbeHandler > NES::Statistic::StatisticProbeHandlerPtr

StatisticPtr

typedef std::shared_ptr< Statistic > NES::Statistic::StatisticPtr

StatisticQueryGeneratorPtr

using NES::Statistic::StatisticQueryGeneratorPtr = typedef std::shared_ptr<AbstractStatisticQueryGenerator>

StatisticRegistryPtr

using NES::Statistic::StatisticRegistryPtr = typedef std::shared_ptr<StatisticRegistry>

StatisticStorePtr

typedef std::shared_ptr< AbstractStatisticStore > NES::Statistic::StatisticStorePtr

TriggerConditionPtr

using NES::Statistic::TriggerConditionPtr = typedef std::shared_ptr<TriggerCondition>

Enumeration Type Documentation

StatisticDataCodec

enum NES::Statistic::StatisticDataCodec : uint8_t

strong

Enumerator
DEFAULT

StatisticSynopsisType

enum NES::Statistic::StatisticSynopsisType : uint8_t

strong

Enumerator
COUNT_MIN
HLL

Function Documentation

INSTANTIATE_TEST_CASE_P()

NES::Statistic::INSTANTIATE_TEST_CASE_P	(	testDefaultStatisticStore	,
		DefaultStatisticStoreTest	,
		::testing::Combine(::testing::Values(1, 2, 4, 8), ::testing::Values(1, 5, 10), ::testing::Values(1, 500, 1000))	,
		[] (const testing::TestParamInfo< DefaultStatisticStoreTest::ParamType > &info) { return std::string(std::to_string(std::get< 0 >(info.param))+"_Threads"+std::to_string(std::get< 1 >(info.param))+"_StatisticKey"+std::to_string(std::get< 2 >(info.param))+"_StatisticsPerKey");}
	)

TEST_F()

NES::Statistic::TEST_F	(	DefaultStatisticStoreTest	,
		singleItem
	)

Tests, if we can insert, get and delete one single Statistic.

References NES::Attribute(), NES::Statistic::DummyStatistic::create(), NES::Statistic::DefaultStatisticStoreTest::defaultStatisticStore, NES::Statistic::DefaultStatisticStore::deleteStatistics(), NES::API::EventTime(), NES::Statistic::DefaultStatisticStore::getStatistics(), NES::Statistic::DefaultStatisticStore::insertStatistic(), and NES::API::Milliseconds().

Here is the call graph for this function:

TEST_P()

NES::Statistic::TEST_P	(	DefaultStatisticStoreTest	,
		multipleItem
	)

Tests, if we can insert, get and delete multiple items.

References NES::Statistic::DefaultStatisticStoreTest::createData(), NES::Statistic::DefaultStatisticStoreTest::defaultStatisticStore, NES::Statistic::DefaultStatisticStore::getStatistics(), NES::API::Milliseconds(), and NES::numberOfThreads.

Here is the call graph for this function: