NES::Runtime::QueryStatistics Class Reference

#include <QueryStatistics.hpp>

Public Member Functions
	QueryStatistics (SharedQueryId sharedQueryId, DecomposedQueryId subQueryId)
	QueryStatistics (const QueryStatistics &other)
uint64_t	getProcessedTasks () const
	getter for processedTasks More...
uint64_t	getProcessedTuple () const
	getter for processedTuple More...
uint64_t	getProcessedBuffers () const
	getter for processedBuffers More...
uint64_t	getTimestampQueryStart () const
	getter for timestampQueryStart More...
uint64_t	getTimestampFirstProcessedTask () const
	getter for timestampFirstProcessedTask More...
uint64_t	getTimestampLastProcessedTask () const
	getter for timestampLastProcessedTask More...
uint64_t	getProcessedWatermarks () const
	getter for processedWatermarks More...
void	setProcessedTasks (uint64_t processedTasks)
	setter for processedTasks More...
void	setProcessedTuple (uint64_t processedTuple)
	setter for processedTuple More...
void	setTimestampQueryStart (uint64_t timestampQueryStart, bool noOverwrite)
	setter for timestampQueryStart More...
void	setTimestampFirstProcessedTask (uint64_t timestampFirstProcessedTask, bool noOverwrite)
	setter for timestampFirstProcessedTask More...
void	setTimestampLastProcessedTask (uint64_t timestampLastProcessedTask)
	setter for timestampLastProcessedTask More...
void	incProcessedBuffers ()
	increment processedBuffers More...
void	incProcessedTasks ()
	increment processedTasks More...
void	incProcessedTuple (uint64_t tupleCnt)
	increment processedTuple More...
void	incLatencySum (uint64_t latency)
	increment latency sum More...
void	incTasksPerPipelineId (PipelineId pipelineId, WorkerThreadId workerId)
	increment latency sum More...
folly::Synchronized< std::map< PipelineId, std::map< WorkerThreadId, std::atomic< uint64_t > > > > &	getPipelineIdToTaskMap ()
	get pipeline id task map More...
uint64_t	getLatencySum () const
	get sum of all latencies More...
void	incQueueSizeSum (uint64_t size)
	increment queue size sum More...
uint64_t	getAvailableGlobalBufferSum () const
	get sum of all available buffers More...
void	incAvailableGlobalBufferSum (uint64_t size)
	increment available buffer sum More...
uint64_t	getAvailableFixedBufferSum () const
	get sum of all fixed buffer buffers More...
void	incAvailableFixedBufferSum (uint64_t size)
	increment available fixed buffer sum More...
uint64_t	getQueueSizeSum () const
	get sum of all queue sizes More...
void	incProcessedWatermarks ()
	increment processedWatermarks More...
void	setProcessedBuffers (uint64_t processedBuffers)
	setter for processedBuffers More...
std::string	getQueryStatisticsAsString ()
	return the current statistics as a string More...
SharedQueryId	getQueryId () const
	get the query id of this queriy More...
DecomposedQueryId	getSubQueryId () const
	get the sub id of this qep (the pipeline stage) More...
void	addTimestampToLatencyValue (uint64_t now, uint64_t latency)
folly::Synchronized< std::map< uint64_t, std::vector< uint64_t > > > &	getTsToLatencyMap ()
void	clear ()

Constructor & Destructor Documentation

QueryStatistics() [1/2]

NES::Runtime::QueryStatistics::QueryStatistics ( SharedQueryId  sharedQueryId, DecomposedQueryId  subQueryId  )

inline

QueryStatistics() [2/2]

NES::Runtime::QueryStatistics::QueryStatistics

(

const QueryStatistics &

other

)

Member Function Documentation

addTimestampToLatencyValue()

void NES::Runtime::QueryStatistics::addTimestampToLatencyValue	(	uint64_t	now,
		uint64_t	latency
	)

Add for the current time stamp (now) a new latency value

Parameters

now
latency

clear()

void NES::Runtime::QueryStatistics::clear

(

)

clear the content of the statistics

getAvailableFixedBufferSum()

uint64_t NES::Runtime::QueryStatistics::getAvailableFixedBufferSum

(

)

const

get sum of all fixed buffer buffers

Returns

value

getAvailableGlobalBufferSum()

uint64_t NES::Runtime::QueryStatistics::getAvailableGlobalBufferSum

(

)

const

get sum of all available buffers

Returns

value

getLatencySum()

uint64_t NES::Runtime::QueryStatistics::getLatencySum

(

)

const

get sum of all latencies

Returns

value

getPipelineIdToTaskMap()

folly::Synchronized< std::map< PipelineId, std::map< WorkerThreadId, std::atomic< uint64_t > > > > & NES::Runtime::QueryStatistics::getPipelineIdToTaskMap

(

)

get pipeline id task map

getProcessedBuffers()

uint64_t NES::Runtime::QueryStatistics::getProcessedBuffers

(

)

const

getter for processedBuffers

Returns

processedBuffers

getProcessedTasks()

uint64_t NES::Runtime::QueryStatistics::getProcessedTasks

(

)

const

getter for processedTasks

Returns

processedTasks

getProcessedTuple()

uint64_t NES::Runtime::QueryStatistics::getProcessedTuple

(

)

const

getter for processedTuple

Returns

processedTuple

getProcessedWatermarks()

uint64_t NES::Runtime::QueryStatistics::getProcessedWatermarks

(

)

const

getter for processedWatermarks

Returns

processedBuffers

getQueryId()

SharedQueryId NES::Runtime::QueryStatistics::getQueryId

(

)

const

get the query id of this queriy

Returns

queryId

getQueryStatisticsAsString()

std::string NES::Runtime::QueryStatistics::getQueryStatisticsAsString

(

)

return the current statistics as a string

Returns

statistics as a string

getQueueSizeSum()

uint64_t NES::Runtime::QueryStatistics::getQueueSizeSum

(

)

const

get sum of all queue sizes

Returns

value

getSubQueryId()

DecomposedQueryId NES::Runtime::QueryStatistics::getSubQueryId

(

)

const

get the sub id of this qep (the pipeline stage)

Returns

subqueryID

getTimestampFirstProcessedTask()

uint64_t NES::Runtime::QueryStatistics::getTimestampFirstProcessedTask

(

)

const

getter for timestampFirstProcessedTask

Returns

timestampFirstProcessedTask In MS.

getTimestampLastProcessedTask()

uint64_t NES::Runtime::QueryStatistics::getTimestampLastProcessedTask

(

)

const

getter for timestampLastProcessedTask

Returns

timestampLastProcessedTask In MS.

getTimestampQueryStart()

uint64_t NES::Runtime::QueryStatistics::getTimestampQueryStart

(

)

const

getter for timestampQueryStart

Returns

timestampQueryStart In MS.

getTsToLatencyMap()

folly::Synchronized< std::map< uint64_t, std::vector< uint64_t > > > & NES::Runtime::QueryStatistics::getTsToLatencyMap

(

)

get the ts to latency map which stores ts as key and latencies in vectors

Returns

incAvailableFixedBufferSum()

void NES::Runtime::QueryStatistics::incAvailableFixedBufferSum

(

uint64_t

size

)

increment available fixed buffer sum

References size().

Here is the call graph for this function:

incAvailableGlobalBufferSum()

void NES::Runtime::QueryStatistics::incAvailableGlobalBufferSum

(

uint64_t

size

)

increment available buffer sum

References size().

Here is the call graph for this function:

incLatencySum()

void NES::Runtime::QueryStatistics::incLatencySum

(

uint64_t

latency

)

increment latency sum

incProcessedBuffers()

void NES::Runtime::QueryStatistics::incProcessedBuffers

(

)

increment processedBuffers

incProcessedTasks()

void NES::Runtime::QueryStatistics::incProcessedTasks

(

)

increment processedTasks

incProcessedTuple()

void NES::Runtime::QueryStatistics::incProcessedTuple

(

uint64_t

tupleCnt

)

increment processedTuple

incProcessedWatermarks()

void NES::Runtime::QueryStatistics::incProcessedWatermarks

(

)

increment processedWatermarks

incQueueSizeSum()

void NES::Runtime::QueryStatistics::incQueueSizeSum

(

uint64_t

size

)

increment queue size sum

References size().

Here is the call graph for this function:

incTasksPerPipelineId()

void NES::Runtime::QueryStatistics::incTasksPerPipelineId	(	PipelineId	pipelineId,
		WorkerThreadId	workerId
	)

increment latency sum

Parameters

pipelineId
workerId

setProcessedBuffers()

void NES::Runtime::QueryStatistics::setProcessedBuffers

(

uint64_t

processedBuffers

)

setter for processedBuffers

Returns

processedBuffers

setProcessedTasks()

void NES::Runtime::QueryStatistics::setProcessedTasks

(

uint64_t

processedTasks

)

setter for processedTasks

setProcessedTuple()

void NES::Runtime::QueryStatistics::setProcessedTuple

(

uint64_t

processedTuple

)

setter for processedTuple

setTimestampFirstProcessedTask()

void NES::Runtime::QueryStatistics::setTimestampFirstProcessedTask	(	uint64_t	timestampFirstProcessedTask,
		bool	noOverwrite = false
	)

setter for timestampFirstProcessedTask

Parameters

timestampFirstProcessedTask	In MS.
noOverwrite	If true, the value is only set, if the previous value was 0 (if it was never set).

References NES_DEBUG.

setTimestampLastProcessedTask()

void NES::Runtime::QueryStatistics::setTimestampLastProcessedTask

(

uint64_t

timestampLastProcessedTask

)

setter for timestampLastProcessedTask

Parameters

timestampLastProcessedTask

In MS.

setTimestampQueryStart()

void NES::Runtime::QueryStatistics::setTimestampQueryStart	(	uint64_t	timestampQueryStart,
		bool	noOverwrite = false
	)

setter for timestampQueryStart

Parameters

timestampQueryStart	In MS.
noOverwrite	If true, the value is only set, if the previous value was 0 (if it was never set).

References NES_DEBUG.

---

The documentation for this class was generated from the following files:

• /nebulastream/nes-runtime/include/Runtime/QueryStatistics.hpp
• /nebulastream/nes-runtime/src/Runtime/QueryStatistics.cpp