19 #ifndef FILTER_QUERY_EXEC_H
20 #define FILTER_QUERY_EXEC_H
46 :
myMachine(inputSchema, attsToIncludeInOutput) {
48 output = std::make_shared<TupleSet>();
61 std::vector<bool>& inputColumn = input->getColumn<
bool>(
whichAtt);
64 int numColumns =
output->getNumColumns();
65 for (
int i = 0; i < numColumns; i++) {
66 output->filterColumn(i, inputColumn);
TupleSetPtr process(TupleSetPtr input) override
std::vector< int > match(TupleSpec &attsToMatch)
TupleSetSetupMachine< bool > myMachine
void setup(TupleSetPtr input, TupleSetPtr output)
std::shared_ptr< TupleSet > TupleSetPtr
FilterQueryExecutor(TupleSpec &inputSchema, TupleSpec &attsToOperateOn, TupleSpec &attsToIncludeInOutput)