NES::BinarySourceProxy Class Reference
Collaboration diagram for NES::BinarySourceProxy:
Public Member Functions | |
| BinarySourceProxy (const SchemaPtr &schema, Runtime::BufferManagerPtr bufferManager, Runtime::QueryManagerPtr queryManager, const std::string &file_path, OperatorId operatorId, size_t numSourceLocalBuffers, std::vector< Runtime::Execution::SuccessorExecutablePipeline > successors) | |
 Public Member Functions inherited from NES::BinarySource | |
| BinarySource (const SchemaPtr &schema, Runtime::BufferManagerPtr bufferManager, Runtime::QueryManagerPtr queryManager, const std::string &pathToFile, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, GatheringMode gatheringMode, const std::string &physicalSourceName, std::vector< Runtime::Execution::SuccessorExecutablePipeline > successors) | |
| the constructor for a binary source More... | |
| std::optional< Runtime::TupleBuffer > | receiveData () override |
| override the receiveData method for the binary source More... | |
| std::string | toString () const override |
| override the toString method for the binary source More... | |
| void | fillBuffer (Runtime::TupleBuffer &) |
| method to fill the buffer with tuples More... | |
| SourceType | getType () const override |
| get source Type More... | |
| const std::string & | getFilePath () const |
| Public Member Functions inherited from NES::DataSource | |
| DataSource (SchemaPtr schema, Runtime::BufferManagerPtr bufferManager, Runtime::QueryManagerPtr queryManager, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, GatheringMode gatheringMode, const std::string &physicalSourceName, bool persistentSource, std::vector< Runtime::Execution::SuccessorExecutablePipeline > executableSuccessors=std::vector< Runtime::Execution::SuccessorExecutablePipeline >(), uint64_t sourceAffinity=std::numeric_limits< uint64_t >::max(), uint64_t taskQueueId=0) | |
| public constructor for data source @Note the number of buffers to process is set to UINT64_MAX and the value is needed by some test to produce a deterministic behavior More... | |
| DataSource ()=delete | |
| virtual void | open () |
| This methods initializes thread-local state. For instance, it creates the local buffer pool and is necessary because we cannot do it in the constructor. More... | |
| virtual void | close () |
| This method cleans up thread-local state for the source. More... | |
| virtual bool | start () |
| method to start the source. 1.) check if bool running is true, if true return if not start source 2.) start new thread with runningRoutine More... | |
| virtual bool | stop (Runtime::QueryTerminationType graceful) |
| method to stop the source. 1.) check if bool running is false, if false return, if not stop source 2.) stop thread by join More... | |
| virtual void | runningRoutine () |
| running routine while source is active More... | |
| virtual void | createOrLoadPersistedProperties () |
| This method defines the logic to load the properties persisted during the previous run of the data source. More... | |
| virtual void | storePersistedProperties () |
| This method stores all properties that need to be persisted for future retrieval during createOrLoadPersistedProperties call. More... | |
| virtual void | clearPersistedProperties () |
| This method clears the persisted properties of the data source on had stop. More... | |
| SchemaPtr | getSchema () const |
| method to return the current schema of the source More... | |
| std::string | getSourceSchemaAsString () |
| method to return the current schema of the source as string More... | |
| bool | isRunning () const noexcept |
| debug function for testing to test if source is running More... | |
| uint64_t | getNumberOfGeneratedTuples () const |
| debug function for testing to get number of generated tuples More... | |
| uint64_t | getNumberOfGeneratedBuffers () const |
| debug function for testing to get number of generated buffer More... | |
| virtual bool | performSoftStop () |
| This method will mark the running as false this will result in 1. the interruption of data gathering loop and 2. initiation of soft stop routine. More... | |
| void | setGatheringInterval (std::chrono::milliseconds interval) |
| method to set the sampling interval More... | |
| virtual | ~DataSource () NES_NOEXCEPT(false) override |
| Internal destructor to make sure that the data source is stopped before deconstrcuted @Note must be public because of boost serialize. More... | |
| uint64_t | getNumBuffersToProcess () const |
| Get number of buffers to be processed. More... | |
| std::chrono::milliseconds | getGatheringInterval () const |
| Get gathering interval. More... | |
| uint64_t | getGatheringIntervalCount () const |
| Get number representation of gathering interval. More... | |
| OperatorId | getOperatorId () const |
| Gets the operator id for the data source. More... | |
| void | setOperatorId (OperatorId operatorId) |
| Set the operator id for the data source. More... | |
| std::vector< Runtime::Execution::SuccessorExecutablePipeline > | getExecutableSuccessors () |
| Returns the list of successor pipelines. More... | |
| void | addExecutableSuccessors (std::vector< Runtime::Execution::SuccessorExecutablePipeline > newPipelines) |
| Add a list of successor pipelines. More... | |
| template<typename Derived > | |
| std::shared_ptr< Derived > | shared_from_base () |
| This method is necessary to avoid problems with the shared_from_this machinery combined with multi-inheritance. More... | |
| virtual std::vector< Schema::MemoryLayoutType > | getSupportedLayouts () |
| This method returns all supported layouts. More... | |
| virtual void | onEvent (Runtime::BaseEvent &) override |
| API method called upon receiving an event. More... | |
| virtual void | onEvent (Runtime::BaseEvent &event, Runtime::WorkerContextRef workerContext) |
| API method called upon receiving an event, whose handling requires the WorkerContext (e.g. its network channels). More... | |
| virtual bool | fail () |
| void | setSourceSharing (bool value) |
| set source sharing value More... | |
| void | incrementNumberOfConsumerQueries () |
| set the number of queries that use this source More... | |
| virtual bool | handleReconfigurationMarker (ReconfigurationMarkerPtr marker) |
| check if a reconfiguration marker contains an event for this source. If so, trigger the reconfiguration and propagate the marker downstream. More... | |
| Public Member Functions inherited from NES::Runtime::Reconfigurable | |
| ~Reconfigurable () NES_NOEXCEPT(false) override=default | |
| virtual void | reconfigure (ReconfigurationMessage &, WorkerContext &) |
| reconfigure callback that will be called per thread More... | |
| virtual void | postReconfigurationCallback (ReconfigurationMessage &) |
| callback that will be called on the last thread the executes the reconfiguration More... | |
| Public Member Functions inherited from NES::detail::virtual_enable_shared_from_this< Reconfigurable, false > | |
| ~virtual_enable_shared_from_this () NES_NOEXCEPT(isNoexceptDestructible) override=default | |
| std::shared_ptr< T1 > | shared_from_this () |
| std::weak_ptr< T1 > | weak_from_this () |
| Public Member Functions inherited from NES::detail::virtual_enable_shared_from_this_base< isNoexceptDestructible > | |
| virtual | ~virtual_enable_shared_from_this_base () NES_NOEXCEPT(isNoexceptDestructible)=default |
| Public Member Functions inherited from NES::DataEmitter | |
| virtual | ~DataEmitter () NES_NOEXCEPT(false)=default |
| virtual void | onEndOfStream (Runtime::QueryTerminationType) |
| virtual DecomposedQueryPlanVersion | getVersion () const |
| virtual bool | startNewVersion () |
| start a previously scheduled new version for this data emitter More... | |
| virtual bool | insertReconfigurationMarker (ReconfigurationMarkerPtr) |
| check if a reconfiguration marker contains an event for this data emitter. If so, trigger the reconfiguration and propagate the marker downstream. More... | |
| Public Member Functions inherited from NES::detail::virtual_enable_shared_from_this< RuntimeEventListener, false > | |
| ~virtual_enable_shared_from_this () NES_NOEXCEPT(isNoexceptDestructible) override=default | |
| std::shared_ptr< T1 > | shared_from_this () |
| std::weak_ptr< T1 > | weak_from_this () |
Constructor & Destructor Documentation
◆ BinarySourceProxy()
|
inline |
References NES::INTERVAL_MODE.
The documentation for this class was generated from the following file:
- /nebulastream/nes-coordinator/tests/UnitTests/Source/SourceTest.cpp
