SourceTest.cpp File Reference

#include <API/TestSchemas.hpp>
#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/CSVSourceType.hpp>
#include <Configurations/Worker/PhysicalSourceTypes/LambdaSourceType.hpp>
#include <Configurations/Worker/PhysicalSourceTypes/TCPSourceType.hpp>
#include <Monitoring/MetricCollectors/CpuCollector.hpp>
#include <Monitoring/MetricCollectors/DiskCollector.hpp>
#include <Monitoring/MonitoringPlan.hpp>
#include <Monitoring/ResourcesReader/SystemResourcesReaderFactory.hpp>
#include <Monitoring/Util/MetricUtils.hpp>
#include <Runtime/Execution/ExecutablePipelineStage.hpp>
#include <Runtime/Execution/ExecutableQueryPlan.hpp>
#include <Runtime/Execution/PipelineExecutionContext.hpp>
#include <Runtime/FixedSizeBufferPool.hpp>
#include <Runtime/MemoryLayout/ColumnLayout.hpp>
#include <Runtime/MemoryLayout/MemoryLayout.hpp>
#include <Runtime/MemoryLayout/RowLayout.hpp>
#include <Runtime/NodeEngine.hpp>
#include <Runtime/NodeEngineBuilder.hpp>
#include <Runtime/QueryManager.hpp>
#include <Runtime/WorkerContext.hpp>
#include <Services/RequestHandlerService.hpp>
#include <Sinks/Mediums/NullOutputSink.hpp>
#include <Sinks/SinkCreator.hpp>
#include <Sources/BinarySource.hpp>
#include <Sources/CSVSource.hpp>
#include <Sources/DefaultSource.hpp>
#include <Sources/LambdaSource.hpp>
#include <Sources/MonitoringSource.hpp>
#include <Sources/SourceCreator.hpp>
#include <Util/Logger/Logger.hpp>
#include <Util/MetricValidator.hpp>
#include <Util/TestTupleBuffer.hpp>
#include <Util/TestUtils.hpp>
#include <cstring>
#include <gmock/gmock.h>
#include <gtest/gtest.h>
#include <iostream>
#include <limits>
#include <string>

Include dependency graph for SourceTest.cpp:

Classes
class	NES::MockDataSource
class	NES::MockDataSourceWithRunningRoutine
class	NES::DataSourceProxy
class	NES::BinarySourceProxy
class	NES::CSVSourceProxy
class	NES::TCPSourceProxy
class	NES::GeneratorSourceProxy
class	NES::DefaultSourceProxy
class	NES::LambdaSourceProxy
class	NES::MonitoringSourceProxy
class	NES::MockedPipelineExecutionContext
class	NES::MockedExecutablePipeline
class	NES::SourceTest

Namespaces
	NES
	This exception represents a network error.

Typedefs
using	NES::DataSourceProxyPtr = std::shared_ptr< DataSourceProxy >

Functions
struct	NES::__attribute__ ((packed)) YSBRecordTuple
	NES::TEST_F (SourceTest, testDataSourceGetOperatorId)
	NES::TEST_F (SourceTest, DISABLED_testDataSourceEmptySuccessors)
	NES::TEST_F (SourceTest, testDataSourceGetSchema)
	NES::TEST_F (SourceTest, testDataSourceRunningImmediately)
	NES::TEST_F (SourceTest, testDataSourceStartSideEffectRunningTrue)
	NES::TEST_F (SourceTest, testDataSourceStartTwiceNoSideEffect)
	NES::TEST_F (SourceTest, testDataSourceStopImmediately)
	NES::TEST_F (SourceTest, testDataSourceStopSideEffect)
	NES::TEST_F (SourceTest, testDataSourceHardStopSideEffect)
	NES::TEST_F (SourceTest, testDataSourceGracefulStopSideEffect)
	NES::TEST_F (SourceTest, testDataSourceRunningRoutineGatheringInterval)
	NES::TEST_F (SourceTest, testDataSourceRunningRoutineIngestion)
	NES::TEST_F (SourceTest, DISABLED_testDataSourceRunningRoutineKalmanFilter)
	NES::TEST_F (SourceTest, testDataSourceGatheringIntervalRoutineBufWithValue)
	NES::TEST_F (SourceTest, testDataSourceIngestionRoutineBufWithValue)
	NES::TEST_F (SourceTest, testDataSourceOpen)
	NES::TEST_F (SourceTest, testBinarySourceGetType)
	NES::TEST_F (SourceTest, testBinarySourceWrongPath)
	NES::TEST_F (SourceTest, testBinarySourceCorrectPath)
	NES::TEST_F (SourceTest, testBinarySourceFillBuffer)
	NES::TEST_F (SourceTest, testBinarySourceFillBufferRandomTimes)
	NES::TEST_F (SourceTest, testBinarySourceFillBufferContents)
	NES::TEST_F (SourceTest, testCSVSourceGetType)
	NES::TEST_F (SourceTest, testCSVSourceWrongFilePath)
	NES::TEST_F (SourceTest, testCSVSourceCorrectFilePath)
	NES::TEST_F (SourceTest, testCSVSourceFillBufferFileEnded)
	NES::TEST_F (SourceTest, testCSVSourceFillBufferOnce)
	NES::TEST_F (SourceTest, testCSVSourceFillBufferOnceColumnLayout)
	NES::TEST_F (SourceTest, testCSVSourceFillBufferContentsHeaderFailure)
	NES::TEST_F (SourceTest, testCSVSourceFillBufferContentsHeaderFailureColumnLayout)
	NES::TEST_F (SourceTest, testCSVSourceFillBufferContentsSkipHeader)
	NES::TEST_F (SourceTest, testCSVSourceFillBufferContentsSkipHeaderColumnLayout)
	NES::TEST_F (SourceTest, testCSVSourceFillBufferFullFileColumnLayout)
	NES::TEST_F (SourceTest, testCSVSourceFillBufferFullFile)
	NES::TEST_F (SourceTest, testCSVSourceIntTypes)
	NES::TEST_F (SourceTest, testCSVSourceFloatTypes)
	NES::TEST_F (SourceTest, testCSVSourceBooleanTypes)
	NES::TEST_F (SourceTest, testCSVSourceCommaFloatingPoint)
	NES::TEST_F (SourceTest, TCPSourceInit)
	NES::TEST_F (SourceTest, TCPSourcePrint)
	NES::TEST_F (SourceTest, TCPSourcePrintWithChangedValues)
	NES::TEST_F (SourceTest, testGeneratorSourceGetType)
	NES::TEST_F (SourceTest, testDefaultSourceGetType)
	NES::TEST_F (SourceTest, testDefaultSourceReceiveData)
	NES::TEST_F (SourceTest, testLambdaSourceInitAndTypeInterval)
	NES::TEST_F (SourceTest, testLambdaSourceInitAndTypeIngestion)
	NES::TEST_F (SourceTest, testIngestionRateFromQuery)