MillisecondIntervalTest.cpp File Reference

#include <BaseIntegrationTest.hpp>
#include <Catalogs/Source/PhysicalSource.hpp>
#include <Common/DataTypes/DataTypeFactory.hpp>
#include <Components/NesCoordinator.hpp>
#include <Components/NesWorker.hpp>
#include <Configurations/Worker/PhysicalSourceTypes/DefaultSourceType.hpp>
#include <Runtime/Execution/ExecutablePipelineStage.hpp>
#include <Runtime/Execution/PipelineExecutionContext.hpp>
#include <Runtime/NodeEngine.hpp>
#include <Runtime/NodeEngineBuilder.hpp>
#include <Runtime/QueryManager.hpp>
#include <Services/RequestHandlerService.hpp>
#include <Sources/SourceCreator.hpp>
#include <Util/TestSink.hpp>
#include <Util/TestUtils.hpp>
#include <gtest/gtest.h>
#include <thread>

Include dependency graph for MillisecondIntervalTest.cpp:

Classes
class	NES::MillisecondIntervalTest

Namespaces
	NES
	This exception represents a network error.

Macros
#define	STR_TO_FIX_CHAR(field_name)    std::memcpy(this->field_name, field_name.data(), std::min(field_name.size(), sizeof(this->field_name)));
#define	FIX_CHAR_CMP(field)   (!std::strncmp(lhs.field, rhs.field, sizeof(lhs.field)))

Functions
struct	NES::__attribute__ ((packed)) YSBRecordTuple
	NES::TEST_F (MillisecondIntervalTest, testPipelinedCSVSource)
	NES::TEST_F (MillisecondIntervalTest, testMultipleOutputBufferFromDefaultSourcePrintSubSecond)

Macro Definition Documentation

FIX_CHAR_CMP

#define FIX_CHAR_CMP

(

field

)

(!std::strncmp(lhs.field, rhs.field, sizeof(lhs.field)))

STR_TO_FIX_CHAR

#define STR_TO_FIX_CHAR

(

field_name

)

std::memcpy(this->field_name, field_name.data(), std::min(field_name.size(), sizeof(this->field_name)));