|
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().