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::SourceTest Class Reference
Collaboration diagram for NES::SourceTest:
[legend]

Public Member Functions

void SetUp () override
 
void TearDown () override
 
std::optional< Runtime::TupleBuffer > GetEmptyBuffer ()
 
DataSourceProxyPtr createDataSourceProxy (const SchemaPtr &schema, Runtime::BufferManagerPtr bufferManager, Runtime::QueryManagerPtr queryManager, OperatorId operatorId, size_t numSourceLocalBuffers, GatheringMode gatheringMode, std::vector< Runtime::Execution::SuccessorExecutablePipeline > executableSuccessors)
 
std::shared_ptr< Runtime::Execution::ExecutablePipeline > createExecutablePipeline (std::shared_ptr< MockedExecutablePipeline > executableStage, std::shared_ptr< SinkMedium > sink)
 
- 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 TearDownTestCase ()
 
static void SetUpTestCase ()
 

Public Attributes

Runtime::NodeEnginePtr nodeEngine {nullptr}
 
std::string path_to_file
 
std::string path_to_bin_file
 
std::string wrong_filepath
 
std::string path_to_file_head
 
std::string path_to_decimals_file
 
SchemaPtr schema
 
SchemaPtr lambdaSchema
 
SchemaPtr decimalsSchema
 
uint8_t * singleMemoryArea
 
uint64_t tuple_size
 
uint64_t buffer_size
 
uint64_t numberOfBuffers
 
uint64_t numberOfTuplesToProcess
 
uint64_t operatorId
 
uint64_t originId
 
uint64_t statisticId
 
uint64_t numSourceLocalBuffersDefault
 
uint64_t gatheringInterval
 
uint64_t queryId
 
uint64_t sourceAffinity
 
size_t bufferAreaSize
 
std::shared_ptr< uint8_t > singleBufferMemoryArea
 
- 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

◆ createDataSourceProxy()

DataSourceProxyPtr NES::SourceTest::createDataSourceProxy ( const SchemaPtr &  schema,
Runtime::BufferManagerPtr  bufferManager,
Runtime::QueryManagerPtr  queryManager,
OperatorId  operatorId,
size_t  numSourceLocalBuffers,
GatheringMode  gatheringMode,
std::vector< Runtime::Execution::SuccessorExecutablePipeline >  executableSuccessors 
)
inline

References operatorId, and schema.

◆ createExecutablePipeline()

std::shared_ptr<Runtime::Execution::ExecutablePipeline> NES::SourceTest::createExecutablePipeline ( std::shared_ptr< MockedExecutablePipeline >  executableStage,
std::shared_ptr< SinkMedium >  sink 
)
inline

References NES::Runtime::Execution::ExecutablePipeline::create(), nodeEngine, and queryId.

Here is the call graph for this function:

◆ GetEmptyBuffer()

std::optional<Runtime::TupleBuffer> NES::SourceTest::GetEmptyBuffer ( )
inline

References nodeEngine.

◆ SetUp()

void NES::SourceTest::SetUp ( )
inlineoverride

References buffer_size, bufferAreaSize, NES::Schema::create(), NES::DataTypeFactory::createFixedChar(), decimalsSchema, NES::FLOAT32, gatheringInterval, NES::INT32, lambdaSchema, nodeEngine, numberOfBuffers, numberOfTuplesToProcess, numSourceLocalBuffersDefault, operatorId, originId, path_to_bin_file, path_to_decimals_file, path_to_file, path_to_file_head, queryId, schema, NES::Testing::BaseIntegrationTest::SetUp(), singleMemoryArea, sourceAffinity, tuple_size, NES::UINT16, NES::UINT32, NES::UINT64, and wrong_filepath.

Here is the call graph for this function:

◆ SetUpTestCase()

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

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

Here is the call graph for this function:

◆ TearDown()

void NES::SourceTest::TearDown ( )
inlineoverride

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

Here is the call graph for this function:

◆ TearDownTestCase()

static void NES::SourceTest::TearDownTestCase ( )
inlinestatic

References NES_INFO.

Member Data Documentation

◆ buffer_size

uint64_t NES::SourceTest::buffer_size

Referenced by SetUp().

◆ bufferAreaSize

size_t NES::SourceTest::bufferAreaSize

Referenced by SetUp().

◆ decimalsSchema

SchemaPtr NES::SourceTest::decimalsSchema

Referenced by SetUp().

◆ gatheringInterval

uint64_t NES::SourceTest::gatheringInterval

Referenced by SetUp().

◆ lambdaSchema

SchemaPtr NES::SourceTest::lambdaSchema

Referenced by SetUp().

◆ nodeEngine

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

Referenced by createExecutablePipeline(), GetEmptyBuffer(), SetUp(), and TearDown().

◆ numberOfBuffers

uint64_t NES::SourceTest::numberOfBuffers

Referenced by SetUp().

◆ numberOfTuplesToProcess

uint64_t NES::SourceTest::numberOfTuplesToProcess

Referenced by SetUp().

◆ numSourceLocalBuffersDefault

uint64_t NES::SourceTest::numSourceLocalBuffersDefault

Referenced by SetUp().

◆ operatorId

uint64_t NES::SourceTest::operatorId

Referenced by createDataSourceProxy(), and SetUp().

◆ originId

uint64_t NES::SourceTest::originId

Referenced by SetUp().

◆ path_to_bin_file

std::string NES::SourceTest::path_to_bin_file

Referenced by SetUp().

◆ path_to_decimals_file

std::string NES::SourceTest::path_to_decimals_file

Referenced by SetUp().

◆ path_to_file

std::string NES::SourceTest::path_to_file

Referenced by SetUp().

◆ path_to_file_head

std::string NES::SourceTest::path_to_file_head

Referenced by SetUp().

◆ queryId

uint64_t NES::SourceTest::queryId

Referenced by createExecutablePipeline(), and SetUp().

◆ schema

SchemaPtr NES::SourceTest::schema

Referenced by createDataSourceProxy(), and SetUp().

◆ singleBufferMemoryArea

std::shared_ptr<uint8_t> NES::SourceTest::singleBufferMemoryArea

◆ singleMemoryArea

uint8_t* NES::SourceTest::singleMemoryArea

Referenced by SetUp(), and TearDown().

◆ sourceAffinity

uint64_t NES::SourceTest::sourceAffinity

Referenced by SetUp().

◆ statisticId

uint64_t NES::SourceTest::statisticId

◆ tuple_size

uint64_t NES::SourceTest::tuple_size

Referenced by SetUp().

◆ wrong_filepath

std::string NES::SourceTest::wrong_filepath

Referenced by SetUp().

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