NonKeyedSlidingWindowQueryExecutionTest.cpp File Reference

#include <API/QueryAPI.hpp>
#include <API/Schema.hpp>
#include <BaseIntegrationTest.hpp>
#include <Plans/DecomposedQueryPlan/DecomposedQueryPlan.hpp>
#include <Types/ThresholdWindow.hpp>
#include <Util/Logger/Logger.hpp>
#include <Util/TestExecutionEngine.hpp>
#include <Util/TestSinkDescriptor.hpp>
#include <Util/TestSourceDescriptor.hpp>
#include <Util/magicenum/magic_enum.hpp>
#include <iostream>
#include <utility>

Include dependency graph for NonKeyedSlidingWindowQueryExecutionTest.cpp:

Classes
class	NonKeyedSlidingWindowQueryExecutionTest

Functions
void	fillBuffer (Runtime::MemoryLayouts::TestTupleBuffer &buf)
	TEST_P (NonKeyedSlidingWindowQueryExecutionTest, testSimpleSlidingWindow)
	INSTANTIATE_TEST_CASE_P (testNonKeyedSlidingWindow, NonKeyedSlidingWindowQueryExecutionTest, ::testing::Values(QueryCompilation::WindowingStrategy::SLICING, QueryCompilation::WindowingStrategy::BUCKETING), [](const testing::TestParamInfo< NonKeyedSlidingWindowQueryExecutionTest::ParamType > &info) { return std::string(magic_enum::enum_name(info.param));})

Variables
constexpr auto	dumpMode = NES::QueryCompilation::DumpMode::NONE

Function Documentation

fillBuffer()

void fillBuffer

(

Runtime::MemoryLayouts::TestTupleBuffer &

buf

)

References NES::Runtime::MemoryLayouts::TestTupleBuffer::getBuffer(), NES::Runtime::MemoryLayouts::TestTupleBuffer::setNumberOfTuples(), and NES::Runtime::TupleBuffer::setSequenceData().

Referenced by TEST_P().

Here is the call graph for this function:

Here is the caller graph for this function:

INSTANTIATE_TEST_CASE_P()

INSTANTIATE_TEST_CASE_P	(	testNonKeyedSlidingWindow	,
		NonKeyedSlidingWindowQueryExecutionTest	,
		::testing::Values(QueryCompilation::WindowingStrategy::SLICING, QueryCompilation::WindowingStrategy::BUCKETING)	,
		[] (const testing::TestParamInfo< NonKeyedSlidingWindowQueryExecutionTest::ParamType > &info) { return std::string(magic_enum::enum_name(info.param));}
	)

References magic_enum::enum_name().

Here is the call graph for this function:

TEST_P()

TEST_P	(	NonKeyedSlidingWindowQueryExecutionTest	,
		testSimpleSlidingWindow
	)

References NES::WindowOperatorBuilder::WindowedQuery::apply(), NES::Attribute(), NES::Schema::create(), NES::API::EventTime(), fillBuffer(), NES::TestQuery::from(), NES::INT64, NES::API::Milliseconds(), NES::Query::project(), NES::API::Sum(), NES::UINT64, and NES::Query::window().

Here is the call graph for this function:

Variable Documentation

dumpMode

constexpr auto dumpMode = NES::QueryCompilation::DumpMode::NONE

constexpr

Referenced by NonKeyedSlidingWindowQueryExecutionTest::SetUp().