19 #ifndef FILTER_QUERY_EXEC_H
20 #define FILTER_QUERY_EXEC_H
48 :
myMachine(inputSchema, attsToIncludeInOutput) {
51 output = std::make_shared<TupleSet>();
59 :
myMachine(inputSchema, attsToIncludeInOutput) {
62 output = std::make_shared<TupleSet>();
73 std::vector<bool>& inputColumn = input->getColumn<
bool>(
whichAtt);
76 int numColumns =
output->getNumColumns();
77 for (
int i = 0; i < numColumns; i++) {
78 output->filterColumn(i, inputColumn);
FilterExecutor(TupleSpec &inputSchema, TupleSpec &attsToOperateOn, TupleSpec &attsToIncludeInOutput, ComputeInfoPtr)
std::string getType() override
std::shared_ptr< ComputeInfo > ComputeInfoPtr
std::vector< int > match(TupleSpec &attsToMatch)
FilterExecutor(TupleSpec &inputSchema, TupleSpec &attsToOperateOn, TupleSpec &attsToIncludeInOutput)
TupleSetPtr process(TupleSetPtr input) override
void setup(TupleSetPtr input, TupleSetPtr output)
std::shared_ptr< TupleSet > TupleSetPtr
TupleSetSetupMachine myMachine