NES::Network::NetworkSink Member List

This is the complete list of members for NES::Network::NetworkSink, including all inherited members.

activeProducers	NES::SinkMedium	protected
applyNextSinkDescriptor()	NES::Network::NetworkSink
configureNewSinkDescriptor(const NetworkSinkDescriptor &newNetworkSinkDescriptor)	NES::Network::NetworkSink
decomposedQueryId	NES::SinkMedium	protected
decomposedQueryVersion	NES::SinkMedium	protected
getNodeEngine()	NES::Network::NetworkSink
getNumberOfWrittenOutBuffers()	NES::SinkMedium
getNumberOfWrittenOutTuples()	NES::SinkMedium
getOperatorId() const	NES::SinkMedium
getParentPlanId() const	NES::SinkMedium
getParentPlanVersion() const	NES::SinkMedium
getSchemaPtr() const	NES::SinkMedium
getSharedQueryId() const	NES::SinkMedium
getSinkFormat()	NES::SinkMedium
getSinkMediumType() override	NES::Network::NetworkSink	virtual
getUniqueNetworkSinkDescriptorId() const	NES::Network::NetworkSink
getVersion()	NES::Network::NetworkSink
isForMigration() const	NES::SinkMedium
migration	NES::SinkMedium	protected
NetworkSink(const SchemaPtr &schema, OperatorId uniqueNetworkSinkDescriptorId, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, NodeLocation const &destination, NesPartition nesPartition, Runtime::NodeEnginePtr nodeEngine, size_t numOfProducers, std::chrono::milliseconds waitTime, uint8_t retryTimes, uint64_t numberOfOrigins, DecomposedQueryPlanVersion version)	NES::Network::NetworkSink	explicit
numberOfOrigins	NES::SinkMedium	protected
onEvent(Runtime::BaseEvent &event) override	NES::Network::NetworkSink	protectedvirtual
onEvent(Runtime::BaseEvent &event, Runtime::WorkerContextRef workerContext)	NES::Network::NetworkSink	protected
operator<(const NetworkSink &lhs, const NetworkSink &rhs)	NES::Network::NetworkSink	friend
postReconfigurationCallback(Runtime::ReconfigurationMessage &) override	NES::Network::NetworkSink	virtual
preSetup()	NES::Network::NetworkSink
reconfigure(Runtime::ReconfigurationMessage &task, Runtime::WorkerContext &workerContext) override	NES::Network::NetworkSink	virtual
scheduleNewDescriptor(const NetworkSinkDescriptor &networkSinkDescriptor)	NES::Network::NetworkSink
schemaWritten	NES::SinkMedium	protected
sentBuffer	NES::SinkMedium	protected
sentTuples	NES::SinkMedium	protected
setMigrationFlag()	NES::SinkMedium
setup() override	NES::Network::NetworkSink	virtual
NES::shared_from_this()	NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >	inline
NES::Runtime::RuntimeEventListener::shared_from_this()	NES::detail::virtual_enable_shared_from_this< RuntimeEventListener, false >	inline
sharedQueryId	NES::SinkMedium	protected
shutdown() override	NES::Network::NetworkSink	virtual
sinkFormat	NES::SinkMedium	protected
SinkMedium(SinkFormatPtr sinkFormat, Runtime::NodeEnginePtr nodeEngine, uint32_t numOfProducers, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion)	NES::SinkMedium	explicit
SinkMedium(SinkFormatPtr sinkFormat, Runtime::NodeEnginePtr nodeEngine, uint32_t numOfProducers, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, uint64_t numberOfOrigins)	NES::SinkMedium	explicit
toString() const override	NES::Network::NetworkSink	virtual
NES::weak_from_this()	NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >	inline
NES::Runtime::RuntimeEventListener::weak_from_this()	NES::detail::virtual_enable_shared_from_this< RuntimeEventListener, false >	inline
writeData(Runtime::TupleBuffer &inputBuffer, Runtime::WorkerContext &workerContext) override	NES::Network::NetworkSink	virtual
writeMutex	NES::SinkMedium	protected
~Reconfigurable() NES_NOEXCEPT(false) override=default	NES::Runtime::Reconfigurable
NES::~virtual_enable_shared_from_this() NES_NOEXCEPT(isNoexceptDestructible) override=default	NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >
NES::Runtime::RuntimeEventListener::~virtual_enable_shared_from_this() NES_NOEXCEPT(isNoexceptDestructible) override=default	NES::detail::virtual_enable_shared_from_this< RuntimeEventListener, false >
~virtual_enable_shared_from_this_base() NES_NOEXCEPT(isNoexceptDestructible)=default	NES::detail::virtual_enable_shared_from_this_base< isNoexceptDestructible >	virtual