NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <API/Schema.hpp>
#include <BaseIntegrationTest.hpp>
#include <Common/DataTypes/DataTypeFactory.hpp>
#include <Common/ExecutableType/Array.hpp>
#include <Runtime/BufferManager.hpp>
#include <Util/TestTupleBuffer.hpp>
#include <Util/magicenum/magic_enum.hpp>
Classes | |
class | NES::Runtime::MemoryLayouts::TestTupleBufferTest |
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::MemoryLayouts | |
Macros | |
#define | VAR_SIZED_DATA_TYPES uint16_t, std::string, double, std::string |
#define | FIXED_SIZED_DATA_TYPES uint16_t, bool, double |
Typedefs | |
using | NES::Runtime::MemoryLayouts::VarSizeDataTuple = std::tuple< VAR_SIZED_DATA_TYPES > |
using | NES::Runtime::MemoryLayouts::FixedSizedDataTuple = std::tuple< FIXED_SIZED_DATA_TYPES > |
Functions | |
NES::Runtime::MemoryLayouts::TEST_P (TestTupleBufferTest, readWritetestBufferTest) | |
NES::Runtime::MemoryLayouts::TEST_P (TestTupleBufferTest, readWritetestBufferTestVarSizeData) | |
NES::Runtime::MemoryLayouts::TEST_P (TestTupleBufferTest, readWritetestBufferTestFullBuffer) | |
NES::Runtime::MemoryLayouts::TEST_P (TestTupleBufferTest, readWritetestBufferTestFullBufferVarSizeData) | |
NES::Runtime::MemoryLayouts::TEST_P (TestTupleBufferTest, countOccurrencesTest) | |
NES::Runtime::MemoryLayouts::TEST_P (TestTupleBufferTest, countOccurrencesTestVarSizeData) | |
NES::Runtime::MemoryLayouts::TEST_P (TestTupleBufferTest, DynamicTupleCompare) | |
NES::Runtime::MemoryLayouts::TEST_P (TestTupleBufferTest, DynamicTupleCompareVarSizeData) | |
NES::Runtime::MemoryLayouts::INSTANTIATE_TEST_CASE_P (TestInputs, TestTupleBufferTest, ::testing::Values(Schema::MemoryLayoutType::COLUMNAR_LAYOUT, Schema::MemoryLayoutType::ROW_LAYOUT), [](const testing::TestParamInfo< TestTupleBufferTest::ParamType > &info) { return std::string(magic_enum::enum_name(info.param));}) | |
#define FIXED_SIZED_DATA_TYPES uint16_t, bool, double |
#define VAR_SIZED_DATA_TYPES uint16_t, std::string, double, std::string |