CountMinBuildExecutionTest.cpp File Reference

#include <BaseUnitTest.hpp>
#include <Operators/LogicalOperators/Sinks/StatisticSinkDescriptor.hpp>
#include <Operators/LogicalOperators/StatisticCollection/Descriptor/CountMinDescriptor.hpp>
#include <Operators/LogicalOperators/StatisticCollection/SendingPolicy/SendingPolicyASAP.hpp>
#include <Operators/LogicalOperators/StatisticCollection/TriggerCondition/NeverTrigger.hpp>
#include <Plans/DecomposedQueryPlan/DecomposedQueryPlan.hpp>
#include <QueryCompiler/Phases/Translations/TimestampField.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 CountMinBuildExecutionTest.cpp:

Classes
class	NES::Runtime::Execution::CountMinBuildExecutionTest

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 (CountMinBuildExecutionTest, singleInputTuple)
	Here we test, if we create a count min sketch for a single input tuple. More...
	NES::Runtime::Execution::TEST_P (CountMinBuildExecutionTest, multipleInputBuffers)
	Here we test, if we create multiple count min sketches for multiple input buffers, but also for larger sketches. More...
	NES::Runtime::Execution::TEST_P (CountMinBuildExecutionTest, multipleInputBuffersSlidingWindow)
	Here we test, if we create multiple count min 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 (CountMinBuildExecutionTest, multipleInputBuffersIngestionTime)
	Here we test, if we create multiple count min 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 (testCountMin, CountMinBuildExecutionTest, ::testing::Combine(::testing::Values(1, 4, 8), ::testing::Values(1, 100, 4000), ::testing::Values(1, 5, 10), ::testing::ValuesIn(magic_enum::enum_values< Statistic::StatisticDataCodec >())), [](const testing::TestParamInfo< CountMinBuildExecutionTest::ParamType > &info) { const auto numWorkerThread=std::get< 0 >(info.param);const auto sketchWidth=std::get< 1 >(info.param);const auto sketchDepth=std::get< 2 >(info.param);const auto dataCodec=std::get< 3 >(info.param);return std::to_string(numWorkerThread)+"Threads_"+std::to_string(sketchWidth)+"Width_"+std::to_string(sketchDepth)+"Depth_"+std::string(magic_enum::enum_name(dataCodec));})

Variables
constexpr auto	NES::Runtime::Execution::queryCompilerDumpMode = NES::QueryCompilation::DumpMode::NONE