KeyedSlidingWindowQueryExecutionTest.cpp File Reference

#include <API/QueryAPI.hpp>
#include <API/Schema.hpp>
#include <BaseIntegrationTest.hpp>
#include <Plans/DecomposedQueryPlan/DecomposedQueryPlan.hpp>
#include <TestUtils/UtilityFunctions.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 KeyedSlidingWindowQueryExecutionTest.cpp:

Classes
class	KeyedSlidingWindowQueryExecutionTest

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

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

Function Documentation

createExpectedBuffer()

void createExpectedBuffer

(

Runtime::MemoryLayouts::TestTupleBuffer &

buf

)

Referenced by TEST_P().

Here is the caller graph for this function:

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	,
		KeyedSlidingWindowQueryExecutionTest	,
		::testing::Values(QueryCompilation::WindowingStrategy::SLICING, QueryCompilation::WindowingStrategy::BUCKETING)	,
		[] (const testing::TestParamInfo< KeyedSlidingWindowQueryExecutionTest::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	(	KeyedSlidingWindowQueryExecutionTest	,
		testKeyedSlidingWindow
	)

References NES::WindowOperatorBuilder::KeyedWindowedQuery::apply(), NES::Attribute(), NES::TestUtils::buffersContainSameTuples(), NES::WindowOperatorBuilder::WindowedQuery::byKey(), NES::Schema::create(), createExpectedBuffer(), NES::Runtime::MemoryLayouts::TestTupleBuffer::createTestTupleBuffer(), NES::API::EventTime(), fillBuffer(), NES::TestQuery::from(), NES::INT64, NES::API::Milliseconds(), NES_INFO, NES::Util::printTupleBufferAsCSV(), NES::Query::sink(), 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 KeyedSlidingWindowQueryExecutionTest::SetUp().