Method Process

filter/notnull.go:53–62

Process implements baker.Filter.

(l baker.Record, next func(baker.Record))

// Process implements baker.Filter.
func (v *NotNull) Process(l baker.Record, next func(baker.Record)) {
	for _, field := range v.fields {
		if l.Get(field) == nil {
			atomic.AddInt64(&v.numFilteredLines, 1)
			return
		}
	}

	next(l)
}