A platform for high-performance distributed tool and library development written in C++. It can be deployed in two different cluster modes: standalone or distributed. API for v0.5.0, released on June 13, 2018.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
ComputeExecutor.h
Go to the documentation of this file.
1 /*****************************************************************************
2  * *
3  * Copyright 2018 Rice University *
4  * *
5  * Licensed under the Apache License, Version 2.0 (the "License"); *
6  * you may not use this file except in compliance with the License. *
7  * You may obtain a copy of the License at *
8  * *
9  * http://www.apache.org/licenses/LICENSE-2.0 *
10  * *
11  * Unless required by applicable law or agreed to in writing, software *
12  * distributed under the License is distributed on an "AS IS" BASIS, *
13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. *
14  * See the License for the specific language governing permissions and *
15  * limitations under the License. *
16  * *
17  *****************************************************************************/
18 
19 #ifndef COMP_EXEC_H
20 #define COMP_EXEC_H
21 
22 #include "TupleSet.h"
23 
24 namespace pdb {
25 
26 // a nice little typedef to shared_ptrs to CompExecutor objects
28 typedef std::shared_ptr<ComputeExecutor> ComputeExecutorPtr;
29 
30 // this is a ComputeExecutor. By definition, it has one method that takes an input a TupleSet, and
31 // then somehow transofrms it to create a new TupleSet (a TupleSet is a column-oriented list of
32 // tuples).
34 
35 public:
36  // precess a tuple set
37  virtual TupleSetPtr process(TupleSetPtr input) = 0;
38 
39  // JiaNote: add below function for debugging
40  virtual std::string getType() {
41  return "UNKNOWN";
42  };
43 };
44 }
45 
46 #endif
std::shared_ptr< TupleSet > TupleSetPtr
Definition: TupleSet.h:64
std::shared_ptr< ComputeExecutor > ComputeExecutorPtr
virtual TupleSetPtr process(TupleSetPtr input)=0
virtual std::string getType()