TCPSourceIntegrationTest.cpp File Reference

#include <BaseIntegrationTest.hpp>
#include <gtest/gtest.h>
#include <iostream>
#include <netinet/in.h>
#include <sys/socket.h>
#include <unistd.h>
#include <Catalogs/Query/QueryCatalog.hpp>
#include <Catalogs/Source/PhysicalSource.hpp>
#include <Common/DataTypes/DataTypeFactory.hpp>
#include <Components/NesCoordinator.hpp>
#include <Components/NesWorker.hpp>
#include <Configurations/Worker/PhysicalSourceTypes/TCPSourceType.hpp>
#include <Services/RequestHandlerService.hpp>
#include <Sinks/Mediums/NullOutputSink.hpp>
#include <Sources/DataSource.hpp>
#include <Sources/TCPSource.hpp>
#include <Util/Logger/Logger.hpp>
#include <Util/TestHarness/TestHarness.hpp>
#include <Operators/LogicalOperators/Sinks/NullOutputSinkDescriptor.hpp>
#include <Operators/LogicalOperators/Sinks/PrintSinkDescriptor.hpp>
#include <Util/TestUtils.hpp>
#include <thread>

Include dependency graph for TCPSourceIntegrationTest.cpp:

Classes
class	NES::TCPSourceIntegrationTest

Namespaces
	NES
	This exception represents a network error.

Functions
	NES::TEST_F (TCPSourceIntegrationTest, TCPSourceReadCSVDataWithSeparatorToken)
	tests TCPSource read of csv data that is seperated by a given token. Here is used More...
	NES::TEST_F (TCPSourceIntegrationTest, TCPSourceReadJSONDataWithSeparatorToken)
	tests TCPSource read of JSON data that is seperated by a given token. Here is used More...
	NES::TEST_F (TCPSourceIntegrationTest, TCPSourceReadCSVDataLengthFromSocket)
	tests TCPSource read of CSV data when obtaining the size of the data from the socket. Constant length More...
	NES::TEST_F (TCPSourceIntegrationTest, TCPSourceReadCSVWithVariableLength)
	tests TCPSource read of CSV data when obtaining the size of the data from the socket. Variable length More...
	NES::TEST_F (TCPSourceIntegrationTest, TCPSourceReadJSONDataLengthFromSocket)
	tests TCPSource read of JSON data when obtaining the size of the data from the socket. Constant length More...
	NES::TEST_F (TCPSourceIntegrationTest, TCPSourceReadJSONDataWithVariableLength)
	tests TCPSource read of CSV data when obtaining the size of the data from the socket. Variable length More...
	NES::TEST_F (TCPSourceIntegrationTest, TCPSourceReadCSVDataWithFixedSize)
	tests TCPSource read of CSV data with fixed length inputted at source creation time More...
	NES::TEST_F (TCPSourceIntegrationTest, TCPSourceReadJSONDataWithFixedSize)
	tests TCPSource read of CSV data with fixed length inputted at source creation time More...
	NES::TEST_F (TCPSourceIntegrationTest, DISABLED_TCPSourceReadCSVData)
	This test is written to check the proper functioning of our TCP data generator (more details on https://github.com/nebulastream/tcp-data-generator). The data generator is capable of producing data at a high even rate. Make sure that the data generator is running locally before starting this test. Last time tested by running: ./tcp-data-generator –host 127.0.0.1 -p 3000 -b 100 -t 1 -f 1000 -w 1000 This test has two purpose: More...