NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <Catalogs/Exceptions/InvalidQueryStateException.hpp>
#include <Catalogs/Query/QueryCatalog.hpp>
#include <Catalogs/Topology/Topology.hpp>
#include <Components/NesCoordinator.hpp>
#include <Configurations/WorkerConfigurationKeys.hpp>
#include <Configurations/WorkerPropertyKeys.hpp>
#include <GRPC/CoordinatorRPCServer.hpp>
#include <Monitoring/Metrics/Gauge/RegistrationMetrics.hpp>
#include <Monitoring/Metrics/Metric.hpp>
#include <Monitoring/MonitoringManager.hpp>
#include <RequestProcessor/RequestTypes/ISQP/ISQPEvents/ISQPAddLinkEvent.hpp>
#include <RequestProcessor/RequestTypes/ISQP/ISQPEvents/ISQPRemoveLinkEvent.hpp>
#include <RequestProcessor/RequestTypes/ISQP/ISQPRequest.hpp>
#include <RequestProcessor/RequestTypes/SourceCatalog/SourceCatalogEvents/AddPhysicalSourcesEvent.hpp>
#include <Runtime/OpenCLManager.hpp>
#include <Services/CoordinatorHealthCheckService.hpp>
#include <Services/QueryParsingService.hpp>
#include <Services/RequestHandlerService.hpp>
#include <Util/Logger/Logger.hpp>
#include <Util/Mobility/ReconnectPoint.hpp>
#include <Util/Mobility/SpatialTypeUtility.hpp>
#include <utility>
Functions | |
void | deserializeOpenCLDeviceInfo (std::any &property, const google::protobuf::RepeatedPtrField< SerializedOpenCLDeviceInfo > &serializedDeviceInfos) |
void deserializeOpenCLDeviceInfo | ( | std::any & | property, |
const google::protobuf::RepeatedPtrField< SerializedOpenCLDeviceInfo > & | serializedDeviceInfos | ||
) |
References NES_WARNING.
Referenced by NES::CoordinatorRPCServer::RegisterWorker().