Referenced by NES::QueryReconfigurationTest::addLogicalSourceAndCreatePhysicalSourceType(), NES::Monitoring::AllEntriesMetricStore::addMetrics(), NES::Monitoring::LatestEntriesMetricStore::addMetrics(), NES::Runtime::TupleBuffer::addRecycleCallback(), NES::Network::PartitionManager::addSubpartitionEventListener(), NES::Nautilus::IR::ValueScopingPhase::apply(), NES::ExpressionItem::as(), NES::detail::assertKiller(), NES::RequestProcessor::AsyncRequestProcessor::AsyncRequestProcessor(), NES::TestHarness::attachWorkerWithMemorySourceToCoordinator(), NES::Attribute(), NES::Query::buildStatistic(), NES::CASE(), NES::Compiler::CPPCompiler::compile(), NES::QueryCompilation::SampleCPPCodeGenerator::compileQuery(), NES::Node::containAsChild(), NES::Node::containAsGrandChild(), NES::Node::containAsGrandParent(), NES::Node::containAsParent(), NES::Monitoring::CpuMetricsWrapper::CpuMetricsWrapper(), NES::Network::EventOnlyNetworkChannel::create(), NES::Network::NetworkChannel::create(), NES::QueryCompilation::QueryCompilationRequest::create(), NES::TestUtils::TestSourceDescriptor::create(), NES::QueryCompilation::QueryCompilationResult::create(), NES::Statistic::CountMinStatisticFormat::create(), NES::Statistic::HyperLogLogStatisticFormat::create(), NES::Runtime::Execution::ExecutableQueryPlan::create(), NES::Compiler::CompilationRequest::create(), NES::TestHarnessWorkerConfiguration::create(), NES::Network::NetworkManager::create(), NES::DataTypeFactory::createArrayValueFromContainerType(), NES::DataTypeFactory::createArrayValueWithContainedType(), NES::DataTypeFactory::createBasicValue(), NES::Nautilus::ValueScopingPhaseTest::createCorrectBlock(), NES::DataTypeFactory::createFixedCharValue(), NES::Runtime::BufferManager::createFixedSizeBufferPool(), NES::createLambdaSource(), NES::Runtime::BufferManager::createLocalBufferPool(), NES::Network::detail::createNetworkChannel(), NES::QueryParsingService::createQueryFromCodeString(), NES::QueryParsingService::createSchemaFromCode(), NES::Statistic::DefaultStatisticQueryGenerator::createStatisticQuery(), NES::Nautilus::ValueScopingPhaseTest::createTraceAndApplyPhases(), NES::StatisticsIntegrationTest::createWorker(), NES::MonitoringQueriesTest::createWorker(), cuckoohash_map< Key, T, Hash, KeyEqual, Allocator, SLOT_PER_BUCKET >::cuckoohash_map(), NES::detail::Logger::debug(), NES::DataTypeSerializationUtil::deserializeDataValue(), NES::LogCaller< LogLevel::LOG_INFO >::do_call(), NES::LogCaller< LogLevel::LOG_TRACE >::do_call(), NES::LogCaller< LogLevel::LOG_DEBUG >::do_call(), NES::LogCaller< LogLevel::LOG_ERROR >::do_call(), NES::LogCaller< LogLevel::LOG_FATAL_ERROR >::do_call(), NES::LogCaller< LogLevel::LOG_WARNING >::do_call(), NES::detail::Logger::error(), NES::RequestProcessor::UpdateSourceCatalogRequest::executeRequestLogic(), NES::RequestProcessor::AddQueryRequest::executeRequestLogic(), NES::RequestProcessor::ExplainRequest::executeRequestLogic(), NES::detail::Logger::fatal(), NES::TestQuery::from(), NES::Runtime::FixedSizeBufferPool::getBufferTimeout(), NES::Runtime::BufferManager::getBufferTimeout(), NES::Runtime::BufferManager::getUnpooledBuffer(), NES::DataSource::handleReconfigurationMarker(), NES::Network::NetworkSource::handleReconfigurationMarker(), NES::detail::Logger::info(), NES::Runtime::WorkerContext::insertIntoReconnectBufferStorage(), NES::Network::NetworkSource::insertReconfigurationMarker(), NES::Exceptions::invokeErrorHandlers(), NES::PhysicalTypes::isSamePhysicalType(), main(), NES::Runtime::detail::MemorySegment::MemorySegment(), NES::MOD(), libcuckoo_bucket_container< Key, T, Allocator, Partial, SLOT_PER_BUCKET >::bucket::movable_key(), NES::Runtime::detail::nesErrorHandler(), NES::Runtime::detail::nesTerminateHandler(), NES::Runtime::detail::nesUnexpectedException(), NES::Monitoring::NetworkMetricsWrapper::NetworkMetricsWrapper(), NES::Runtime::AbstractQueryManager::notifySourceFailure(), NES::Runtime::AbstractQueryManager::notifyTaskFailure(), NES::Network::ExchangeProtocol::onEndOfStream(), NES::Network::NetworkSource::onEvent(), NES::operator!(), NES::operator!=(), NES::operator%(), NES::operator&&(), NES::operator*(), NES::operator+(), NES::operator++(), NES::operator-(), NES::operator--(), NES::operator/(), NES::operator<(), NES::operator<=(), cuckoohash_map< Key, T, Hash, KeyEqual, Allocator, SLOT_PER_BUCKET >::operator=(), cuckoohash_map< Key, T, Hash, KeyEqual, Allocator, SLOT_PER_BUCKET >::locked_table::operator=(), NES::operator==(), NES::operator>(), NES::operator>=(), NES::operator||(), NES::CircularBuffer< T, Allocator, >::pop(), NES::POWER(), NES::CircularBuffer< T, Allocator, >::push(), NES::Monitoring::AbstractSystemResourcesReader::readCpuStats(), NES::Monitoring::LinuxSystemResourcesReader::readCpuStats(), NES::Monitoring::CpuMetricsWrapper::readFromBuffer(), NES::Monitoring::NetworkMetricsWrapper::readFromBuffer(), NES::Monitoring::CpuCollector::readMetric(), NES::Monitoring::DiskCollector::readMetric(), NES::Monitoring::MemoryCollector::readMetric(), NES::Monitoring::NetworkCollector::readMetric(), NES::Monitoring::AbstractSystemResourcesReader::readNetworkStats(), NES::Monitoring::LinuxSystemResourcesReader::readNetworkStats(), NES::Network::NetworkSink::reconfigure(), NES::MonitoringService::registerMonitoringPlanToAllNodes(), NES::Network::PartitionManager::registerSubpartitionConsumer(), NES::Network::NetworkManager::registerSubpartitionEventProducer(), NES::Network::NetworkManager::registerSubpartitionEventProducerAsync(), NES::Network::NetworkManager::registerSubpartitionProducer(), NES::Network::PartitionManager::registerSubpartitionProducer(), NES::Network::NetworkManager::registerSubpartitionProducerAsync(), NES::CoordinatorRPCServer::RegisterWorker(), NES::Node::replace(), NES::RequestProcessor::AsyncRequestProcessor::runAsync(), NES::Runtime::AsyncTaskExecutor::runAsync(), NES::RequestProcessor::AbstractMultiRequest::scheduleSubRequest(), NES::Network::detail::NetworkEventSender< BaseChannelType >::sendEvent(), NES::CoordinatorRPCServer::SendLocationUpdate(), NES::SinkFormat::setBufferManager(), NES::AttributeField::setName(), NES::SinkFormat::setSchemaPtr(), NES::RequestProcessor::AbstractSubRequest::setStorageHandler(), NES::RemoteClientTest::SetUp(), NES::TestHarness::setupTopology(), NES::NesCoordinator::startCoordinator(), NES::Testing::detail::TestWaitingHelper::startWaitingThread(), NES::QueryReconfigurationTest::startWorker(), NES::Runtime::WorkerContext::storeEventChannelFuture(), NES::Runtime::WorkerContext::storeEventOnlyChannel(), NES::Runtime::WorkerContext::storeNetworkChannel(), NES::Runtime::WorkerContext::storeNetworkChannelFuture(), NES::RequestProcessor::Experimental::TEST_F(), NES::TEST_F(), TEST_F(), NES::Compiler::TEST_F(), NES::Spatial::TEST_F(), NES::TEST_P(), NES::Runtime::AsyncTaskExecutor::AsyncTaskFuture< R >::thenAsync(), NES::detail::Logger::trace(), NES::RequestProcessor::AbstractRequest::trySetExceptionInPromise(), NES::Runtime::NodeEngine::updatePhysicalSources(), NES::detail::Logger::warn(), NES::WHEN(), NES::Runtime::TupleBuffer::wrapMemory(), and NES::MonitoringSink::writeData().