NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <API/QueryAPI.hpp>
#include <API/Schema.hpp>
#include <BaseIntegrationTest.hpp>
#include <Plans/DecomposedQueryPlan/DecomposedQueryPlan.hpp>
#include <Util/Logger/Logger.hpp>
#include <Util/TestExecutionEngine.hpp>
#include <Util/TestSinkDescriptor.hpp>
#include <Util/magicenum/magic_enum.hpp>
Classes | |
class | NonKeyedTumblingWindowQueryExecutionTest |
Functions | |
void | fillBuffer (Runtime::MemoryLayouts::TestTupleBuffer &buf) |
TEST_F (NonKeyedTumblingWindowQueryExecutionTest, testTumblingWindow) | |
TEST_F (NonKeyedTumblingWindowQueryExecutionTest, testSimpleTumblingWindowNoProjection) | |
Variables | |
constexpr auto | dumpMode = NES::QueryCompilation::DumpMode::NONE |
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_F().
TEST_F | ( | NonKeyedTumblingWindowQueryExecutionTest | , |
testSimpleTumblingWindowNoProjection | |||
) |
References NES::WindowOperatorBuilder::WindowedQuery::apply(), NES::Attribute(), NES::Schema::create(), NES::API::EventTime(), fillBuffer(), NES::TestQuery::from(), NES::INT64, NES::API::Milliseconds(), NES::Query::sink(), NES::API::Sum(), NES::UINT64, and NES::Query::window().
TEST_F | ( | NonKeyedTumblingWindowQueryExecutionTest | , |
testTumblingWindow | |||
) |
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().
|
constexpr |
Referenced by NonKeyedTumblingWindowQueryExecutionTest::SetUp().