NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
Public Member Functions | Static Public Member Functions | Public Attributes | List of all members
NES::StatisticSinkTest Class Reference
Collaboration diagram for NES::StatisticSinkTest:
[legend]

Public Member Functions

void SetUp () override
 
void TearDown () override
 
bool sameStatisticsInVectors (std::vector< Statistic::HashStatisticPair > &left, std::vector< Statistic::StatisticPtr > &right)
 Checks if the left and right vector contain the same (order-insensitive) statistics. More...
 
std::pair< std::vector< Runtime::TupleBuffer >, std::vector< Statistic::StatisticPtr > > createRandomCountMinSketches (uint64_t numberOfSketches, const SchemaPtr &schema, const Runtime::BufferManagerPtr &bufferManager)
 Creates #numberOfSketches random CountMin-Sketches. More...
 
std::pair< std::vector< Runtime::TupleBuffer >, std::vector< Statistic::StatisticPtr > > createRandomHyperLogLogSketches (uint64_t numberOfSketches, const SchemaPtr &schema, const Runtime::BufferManagerPtr &bufferManager)
 Creates #numberOfSketches random HyperLogLog-Sketches. More...
 
- Public Member Functions inherited from NES::Testing::BaseIntegrationTest
 BaseIntegrationTest ()
 the base test class ctor that creates the internal test resources More...
 
 ~BaseIntegrationTest () override
 
void SetUp () override
 Fetches the port. More...
 
void TearDown () override
 Release internal ports. More...
 
void onFatalError (int signalNumber, std::string callstack) override
 onFatalError shall be called when a signal is caught More...
 
void onFatalException (std::shared_ptr< std::exception > exception, std::string callstack) override
 onFatalException shall be called when an exception is caught More...
 
- Public Member Functions inherited from NES::Testing::BaseUnitTest
void SetUp () override
 
void TearDown () override
 
- Public Member Functions inherited from NES::detail::virtual_enable_shared_from_this< ErrorListener >
 ~virtual_enable_shared_from_this () NES_NOEXCEPT(true) override=default
 
std::shared_ptr< T1 > shared_from_this ()
 
std::weak_ptr< T1 > weak_from_this ()
 
- Public Member Functions inherited from NES::detail::virtual_enable_shared_from_this_base< true >
virtual ~virtual_enable_shared_from_this_base () NES_NOEXCEPT(isNoexceptDestructible)=default
 
- Public Member Functions inherited from NES::Testing::detail::TestWaitingHelper
 TestWaitingHelper ()
 
void startWaitingThread (std::string testName)
 
void completeTest ()
 
void failTest ()
 

Static Public Member Functions

static void SetUpTestCase ()
 

Public Attributes

int numberOfStatistics
 
Statistic::StatisticDataCodec statisticDataCodec
 
Runtime::NodeEnginePtr nodeEngine {nullptr}
 
- Public Attributes inherited from NES::Testing::BaseUnitTest
detail::TestSourceNameHelper srcName
 

Additional Inherited Members

- Protected Member Functions inherited from NES::Testing::BaseIntegrationTest
BorrowedPortPtr getAvailablePort ()
 Retrieve another free port. More...
 
std::filesystem::path getTestResourceFolder () const
 returns the test resource folder to write files More...
 
- Protected Attributes inherited from NES::Testing::BaseIntegrationTest
BorrowedPortPtr rpcCoordinatorPort {nullptr}
 
BorrowedPortPtr restPort {nullptr}
 

Member Function Documentation

◆ createRandomCountMinSketches()

std::pair<std::vector<Runtime::TupleBuffer>, std::vector<Statistic::StatisticPtr> > NES::StatisticSinkTest::createRandomCountMinSketches ( uint64_t  numberOfSketches,
const SchemaPtr &  schema,
const Runtime::BufferManagerPtr &  bufferManager 
)
inline

Creates #numberOfSketches random CountMin-Sketches.

Parameters
numberOfSketches
schema
bufferManager
Returns
Pair<Vector of TupleBuffers, Vector of Statistics>

◆ createRandomHyperLogLogSketches()

std::pair<std::vector<Runtime::TupleBuffer>, std::vector<Statistic::StatisticPtr> > NES::StatisticSinkTest::createRandomHyperLogLogSketches ( uint64_t  numberOfSketches,
const SchemaPtr &  schema,
const Runtime::BufferManagerPtr &  bufferManager 
)
inline

Creates #numberOfSketches random HyperLogLog-Sketches.

Parameters
numberOfSketches
schema
bufferManager
Returns
Pair<Vector of TupleBuffers, Vector of Statistics>

◆ sameStatisticsInVectors()

bool NES::StatisticSinkTest::sameStatisticsInVectors ( std::vector< Statistic::HashStatisticPair > &  left,
std::vector< Statistic::StatisticPtr > &  right 
)
inline

Checks if the left and right vector contain the same (order-insensitive) statistics.

Parameters
left
right
Returns
True, if vector contain the same, false otherwise

References NES_ERROR.

◆ SetUp()

void NES::StatisticSinkTest::SetUp ( )
inlineoverride

References nodeEngine, numberOfStatistics, NES::Testing::BaseIntegrationTest::SetUp(), and statisticDataCodec.

Here is the call graph for this function:

◆ SetUpTestCase()

static void NES::StatisticSinkTest::SetUpTestCase ( )
inlinestatic

References NES::LOG_DEBUG, NES_INFO, and NES::Logger::setupLogging().

Here is the call graph for this function:

◆ TearDown()

void NES::StatisticSinkTest::TearDown ( )
inlineoverride

References nodeEngine, and NES::Testing::BaseIntegrationTest::TearDown().

Here is the call graph for this function:

Member Data Documentation

◆ nodeEngine

Runtime::NodeEnginePtr NES::StatisticSinkTest::nodeEngine {nullptr}

Referenced by SetUp(), and TearDown().

◆ numberOfStatistics

int NES::StatisticSinkTest::numberOfStatistics

Referenced by SetUp().

◆ statisticDataCodec

Statistic::StatisticDataCodec NES::StatisticSinkTest::statisticDataCodec

Referenced by SetUp().

The documentation for this class was generated from the following file: