HyperLogLogBuildExecutionTest.cpp File Reference

#include <BaseUnitTest.hpp>
#include <Operators/LogicalOperators/Sinks/StatisticSinkDescriptor.hpp>
#include <Operators/LogicalOperators/StatisticCollection/Descriptor/HyperLogLogDescriptor.hpp>
#include <Operators/LogicalOperators/StatisticCollection/SendingPolicy/SendingPolicyASAP.hpp>
#include <Operators/LogicalOperators/StatisticCollection/TriggerCondition/NeverTrigger.hpp>
#include <Plans/DecomposedQueryPlan/DecomposedQueryPlan.hpp>
#include <Sinks/Formats/StatisticCollection/StatisticFormatFactory.hpp>
#include <StatisticCollection/StatisticStorage/DefaultStatisticStore.hpp>
#include <TestUtils/UtilityFunctions.hpp>
#include <Util/TestExecutionEngine.hpp>
#include <Util/TestSinkDescriptor.hpp>

Include dependency graph for HyperLogLogBuildExecutionTest.cpp:

Classes
class	NES::Runtime::Execution::HyperLogLogBuildExecutionTest

Namespaces
	NES
	This exception represents a network error.
	NES::Runtime
	Turn this on to have Thread::current_num_threads_ keep a count of currently-active threads.
	NES::Runtime::Execution

Functions
	NES::Runtime::Execution::TEST_P (HyperLogLogBuildExecutionTest, singleInputTuple)
	Here we test, if we create a hyperloglog sketch for a single input tuple. More...
	NES::Runtime::Execution::TEST_P (HyperLogLogBuildExecutionTest, multipleInputBuffers)
	Here we test, if we create multiple hyperloglog sketches for multiple input buffers, but also for larger sketches. More...
	NES::Runtime::Execution::TEST_P (HyperLogLogBuildExecutionTest, multipleInputBuffersSlidingWindow)
	Here we test, if we create multiple hyperloglog sketches for multiple input buffers, but also for larger sketches and for sliding windows (we create one sketch per slice) More...
	NES::Runtime::Execution::TEST_P (HyperLogLogBuildExecutionTest, multipleInputBuffersIngestionTime)
	Here we test, if we create multiple hyperloglog sketches for multiple input buffers, but also for larger sketches The difference is that we use the ingestion time instead of an event time. More...
	NES::Runtime::Execution::INSTANTIATE_TEST_CASE_P (testHyperLogLog, HyperLogLogBuildExecutionTest, ::testing::Combine(::testing::Values(1, 4, 8), ::testing::Values(4, 5, 8, 10, 20), ::testing::ValuesIn(magic_enum::enum_values< Statistic::StatisticDataCodec >())), [](const testing::TestParamInfo< HyperLogLogBuildExecutionTest::ParamType > &info) { const auto numWorkerThread=std::get< 0 >(info.param);const auto sketchWidth=std::get< 1 >(info.param);const auto dataCodec=std::get< 2 >(info.param);return std::to_string(numWorkerThread)+"Threads_"+std::to_string(sketchWidth)+"Width"+std::string(magic_enum::enum_name(dataCodec));})