Akumuli
 All Classes Namespaces Functions Variables Typedefs Enumerations Enumerator Friends
limiter.h
1 #pragma once
2 
3 #include <memory>
4 
5 #include "../queryprocessor_framework.h"
6 
7 namespace Akumuli {
8 namespace QP {
9 
10 struct Limiter : Node {
11 
12  uint64_t limit_;
13  uint64_t offset_;
14  uint64_t counter_;
15  std::shared_ptr<Node> next_;
16 
17  Limiter(uint64_t limit, uint64_t offset, std::shared_ptr<Node> next);
18 
19  virtual void complete();
20 
21  virtual bool put(const aku_Sample& sample);
22 
23  virtual void set_error(aku_Status status);
24 
25  virtual int get_requirements() const;
26 };
27 }
28 } // namespace
Definition: limiter.h:10
virtual int get_requirements() const
Definition: limiter.cpp:38
virtual bool put(const aku_Sample &sample)
Definition: limiter.cpp:18
virtual void complete()
Complete adding values.
Definition: limiter.cpp:14
Definition: queryprocessor_framework.h:28