Commit d1a408c5 authored by Philipp Götze's avatar Philipp Götze
Browse files

Removed unused variables

parent c9f6d609
...@@ -258,10 +258,6 @@ private: ...@@ -258,10 +258,6 @@ private:
*/ */
void processPunctuation( const PunctuationPtr& punctuation ) { void processPunctuation( const PunctuationPtr& punctuation ) {
Lock lock( mAggrMtx ); Lock lock( mAggrMtx );
const Timestamp timestamp = punctuation->getTimestamp();
const bool outdated = false;
produceAggregates( timestamp, outdated, lock );
this->getOutputPunctuationChannel().publish(punctuation); this->getOutputPunctuationChannel().publish(punctuation);
} }
...@@ -350,29 +346,6 @@ private: ...@@ -350,29 +346,6 @@ private:
} }
} }
/**
* @brief Produce aggregate elements for all groups in the aggregation table.
*
* This method produces an aggregation result for each group that is currently
* available in this operator. Groups having a timestamp older than the last
* notification will be skipped, unless the operator was configured to always
* produce a full result.
*
* @param[in] timestamp
* the timestamp for the result elements
* @param[in] outdated
* flag indicating if the result elements should be marked as outdated
* @param[in] lock
* a reference to the lock protecting the aggregation state
*/
void produceAggregates(const Timestamp& timestamp, const bool outdated, const Lock& lock) {
for (const auto groupEntry : mAggregateTable) {
const AggregateStatePtr& aggrState = groupEntry.second;
//produceAggregate(aggrState, timestamp, outdated, lock);
}
}
/** /**
* @brief Produce a final aggregate for a specific state and publish it to all subscribers. * @brief Produce a final aggregate for a specific state and publish it to all subscribers.
* *
...@@ -403,11 +376,7 @@ protected: ...@@ -403,11 +376,7 @@ protected:
* TODO * TODO
*/ */
void notificationCallback() { void notificationCallback() {
const bool outdated = false;
const Timestamp timestamp = 0; // = ????;
Lock lock(mAggrMtx); Lock lock(mAggrMtx);
this->produceAggregates(timestamp, outdated, lock);
PunctuationPtr punctuation = std::make_shared< Punctuation >( Punctuation::SlideExpired ); PunctuationPtr punctuation = std::make_shared< Punctuation >( Punctuation::SlideExpired );
this->getOutputPunctuationChannel().publish(punctuation); this->getOutputPunctuationChannel().publish(punctuation);
} }
......
...@@ -172,7 +172,6 @@ int main(int argc, char **argv){ ...@@ -172,7 +172,6 @@ int main(int argc, char **argv){
.partitionBy([&ThreadAmount](auto tp) { return get<0>(tp) % ThreadAmount; }, ThreadAmount) .partitionBy([&ThreadAmount](auto tp) { return get<0>(tp) % ThreadAmount; }, ThreadAmount)
.statefulMap<TInMarkov, ClusterState>([&mtx](auto tp, bool outdated, std::shared_ptr<ClusterState> state){ //this operator clusters .statefulMap<TInMarkov, ClusterState>([&mtx](auto tp, bool outdated, std::shared_ptr<ClusterState> state){ //this operator clusters
int FoundRowNew = 0, RowNumberNew = 0, HasEnoughValues = 0; int FoundRowNew = 0, RowNumberNew = 0, HasEnoughValues = 0;
double testDouble = 0.0;
std::vector<int> ClusterSequence(0, 0); //handover variable std::vector<int> ClusterSequence(0, 0); //handover variable
std::string TempMetadataString = get<2>(tp); //check for outdated tuple or not (within the window or not) std::string TempMetadataString = get<2>(tp); //check for outdated tuple or not (within the window or not)
double TempMachineNumber, TempValueNumber; double TempMachineNumber, TempValueNumber;
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment