Method filter

query/aql_batchexecutor.go:103–113

filter

()

// filter
func (e *BatchExecutorImpl) filter() {
	// process main table common filter
	e.qc.doProfile(func() {
		for _, filter := range e.qc.OOPK.MainTableCommonFilters {
			e.qc.OOPK.currentBatch.processExpression(filter, nil,
				e.qc.TableScanners, e.qc.OOPK.foreignTables, e.stream, e.qc.Device, e.qc.OOPK.currentBatch.filterAction)
		}
		e.customFilterFunc(e.stream)
		e.qc.reportTimingForCurrentBatch(e.stream, &e.start, filterEvalTiming)
	}, "filters", e.stream)
}

// join
func (e *BatchExecutorImpl) join() {