Function newScanner

sbuf/scanner.go:50–70

(ctx context.Context, r sio.Reader, filterExpr Pushdown)

}

func newScanner(ctx context.Context, r sio.Reader, filterExpr Pushdown) (Scanner, error) {
	var sa ScannerAble
	if zf, ok := r.(*File); ok {
		sa, _ = zf.Reader.(ScannerAble)
	} else {
		sa, _ = r.(ScannerAble)
	}
	if sa != nil {
		return sa.NewScanner(ctx, filterExpr)
	}
	var f expr.Evaluator
	if filterExpr != nil {
		var err error
		if f, err = filterExpr.DataFilter(); err != nil {
			return nil, err
		}
	}
	sc := &scanner{reader: r, filter: f, ctx: ctx}
	sc.Puller = NewPuller(sc)
	return sc, nil
}

type scanner struct {
	Puller