NES::Runtime::WorkerContext Member List

This is the complete list of members for NES::Runtime::WorkerContext, including all inherited members.

abortConnectionProcess(OperatorId operatorId)	NES::Runtime::WorkerContext
allocateTupleBuffer()	NES::Runtime::WorkerContext
containsNetworkChannel(OperatorId id)	NES::Runtime::WorkerContext
containsNetworkChannelFuture(OperatorId id)	NES::Runtime::WorkerContext
createStorage(Network::NesPartition nesPartition)	NES::Runtime::WorkerContext
decreaseObjectRefCnt(void *object)	NES::Runtime::WorkerContext
doesEventChannelExist(OperatorId operatorId)	NES::Runtime::WorkerContext
doesNetworkChannelExist(OperatorId operatorId)	NES::Runtime::WorkerContext
getAsyncConnectionResult(OperatorId operatorId, DecomposedQueryPlanVersion version)	NES::Runtime::WorkerContext
getAsyncEventChannelConnectionResult(OperatorId operatorId)	NES::Runtime::WorkerContext
getBufferProvider()	NES::Runtime::WorkerContext
getBufferProviderTLS()	NES::Runtime::WorkerContext	static
getEventOnlyNetworkChannel(OperatorId operatorId)	NES::Runtime::WorkerContext
getId() const	NES::Runtime::WorkerContext
getNetworkChannel(OperatorId ownerId, DecomposedQueryPlanVersion ownerVersion)	NES::Runtime::WorkerContext
getQueueId() const	NES::Runtime::WorkerContext
getTopTupleFromStorage(Network::NesPartition nesPartition)	NES::Runtime::WorkerContext
insertIntoReconnectBufferStorage(OperatorId operatorId, NES::Runtime::TupleBuffer buffer)	NES::Runtime::WorkerContext
insertIntoStorage(Network::NesPartition nesPartition, NES::Runtime::TupleBuffer buffer)	NES::Runtime::WorkerContext
isAsyncConnectionInProgress(OperatorId operatorId)	NES::Runtime::WorkerContext
releaseEventOnlyChannel(OperatorId id, Runtime::QueryTerminationType terminationType)	NES::Runtime::WorkerContext
releaseNetworkChannel(OperatorId id, DecomposedQueryPlanVersion version, Runtime::QueryTerminationType terminationType, uint16_t sendingThreadCount, uint64_t currentMessageSequenceNumber, bool shouldPropagateMarker, const std::optional< ReconfigurationMarkerPtr > &reconfigurationMarker)	NES::Runtime::WorkerContext
removeBufferFromReconnectBufferStorage(OperatorId operatorId)	NES::Runtime::WorkerContext
removeTopTupleFromStorage(Network::NesPartition nesPartition)	NES::Runtime::WorkerContext
setObjectRefCnt(void *object, uint32_t refCnt)	NES::Runtime::WorkerContext
storeEventChannelFuture(OperatorId id, DecomposedQueryPlanVersion version, std::pair< std::future< Network::EventOnlyNetworkChannelPtr >, std::promise< bool >> &&channelFuture)	NES::Runtime::WorkerContext
storeEventOnlyChannel(OperatorId id, Network::EventOnlyNetworkChannelPtr &&channel)	NES::Runtime::WorkerContext
storeNetworkChannel(OperatorId id, DecomposedQueryPlanVersion version, Network::NetworkChannelPtr &&channel)	NES::Runtime::WorkerContext
storeNetworkChannelFuture(OperatorId id, DecomposedQueryPlanVersion version, std::pair< std::future< Network::NetworkChannelPtr >, std::promise< bool >> &&channelFuture)	NES::Runtime::WorkerContext
trimStorage(Network::NesPartition nesPartition, uint64_t timestamp)	NES::Runtime::WorkerContext
waitForAsyncConnection(OperatorId operatorId)	NES::Runtime::WorkerContext
waitForAsyncConnectionEventChannel(OperatorId operatorId)	NES::Runtime::WorkerContext
WorkerContext(WorkerThreadId workerId, const BufferManagerPtr &bufferManager, uint64_t numberOfBuffersPerWorker, uint32_t queueId=0)	NES::Runtime::WorkerContext	explicit
~WorkerContext()	NES::Runtime::WorkerContext