19 #ifndef HASHONE_QUERY_EXEC_H
20 #define HASHONE_QUERY_EXEC_H
52 :
myMachine(inputSchema, attsToIncludeInOutput) {
55 output = std::make_shared<TupleSet>();
64 :
myMachine(inputSchema, attsToIncludeInOutput) {
67 output = std::make_shared<TupleSet>();
81 std::vector<size_t>* outColumn =
new std::vector<size_t>();
87 std::vector<size_t>& outColumn =
output->getColumn<
size_t>(
outAtt);
90 outColumn.resize(numRows);
91 for (
int i = 0; i < numRows; i++) {
HashOneExecutor(TupleSpec &inputSchema, TupleSpec &attsToOperateOn, TupleSpec &attsToIncludeInOutput, ComputeInfoPtr)
std::vector< std::string > & getAtts()
TupleSetSetupMachine myMachine
std::shared_ptr< ComputeInfo > ComputeInfoPtr
std::vector< int > match(TupleSpec &attsToMatch)
std::string getType() override
void setup(TupleSetPtr input, TupleSetPtr output)
std::shared_ptr< TupleSet > TupleSetPtr
TupleSetPtr process(TupleSetPtr input) override
HashOneExecutor(TupleSpec &inputSchema, TupleSpec &attsToOperateOn, TupleSpec &attsToIncludeInOutput)