|
| MockDataSourceWithRunningRoutine (const SchemaPtr &schema, Runtime::BufferManagerPtr bufferManager, Runtime::QueryManagerPtr queryManager, OperatorId operatorId, size_t numSourceLocalBuffers, GatheringMode gatheringMode, std::vector< Runtime::Execution::SuccessorExecutablePipeline > executableSuccessors) |
|
| MOCK_METHOD (void, runningRoutine,()) |
|
| MOCK_METHOD (std::optional< Runtime::TupleBuffer >, receiveData,()) |
|
| MOCK_METHOD (std::string, toString,(),(const)) |
|
| MOCK_METHOD (SourceType, getType,(),(const)) |
|
| 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 std::optional< Runtime::TupleBuffer > | receiveData ()=0 |
| virtual function to receive a buffer @Note this function is overwritten by the particular data source 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...
|
|
virtual std::string | toString () const =0 |
| virtual function to get a string describing the particular source @Note this function is overwritten by the particular data source More...
|
|
virtual SourceType | getType () const =0 |
| get source Type 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...
|
|
| ~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...
|
|
| ~virtual_enable_shared_from_this () NES_NOEXCEPT(isNoexceptDestructible) override=default |
|
std::shared_ptr< T1 > | shared_from_this () |
|
std::weak_ptr< T1 > | weak_from_this () |
|
virtual | ~virtual_enable_shared_from_this_base () NES_NOEXCEPT(isNoexceptDestructible)=default |
|
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...
|
|
| ~virtual_enable_shared_from_this () NES_NOEXCEPT(isNoexceptDestructible) override=default |
|
std::shared_ptr< T1 > | shared_from_this () |
|
std::weak_ptr< T1 > | weak_from_this () |
|